Ручное подтверждение в EasyNetQ, возможно ли это? ⇐ C#

[Anonymous]

Я надеюсь использовать EasyNetQ для потребительской задачи, где я буду читать пакет сообщений (скажем, 100) из одной или нескольких очередей RabbitMQ и обрабатывать пакеты в восходящем направлении. Я не хочу подтверждать сообщения до тех пор, пока не завершится восходящий процесс, потому что, если мой процесс выйдет из строя во время восходящего процесса, я бы хотел, чтобы сообщения не удалялись.
Мой тестовый код на данный момент выглядит так (псевдокод — опущены детали синхронизации и т. д.):

Код: Выделить всё

var bus = RabbitHutch.CreateBus("host=localhost");
var consumer = bus.Advanced.Consume(queue, (body, properties, info) =>
{
MessageHandler(body, properties, info);
});

// ...

static void MessageHandler(ReadOnlyMemory content, MessageProperties props, MessageReceivedInfo info)
{
messageBatch.Add((content, info));

if (messageBatch.Count >= 100)
// trigger another thread to do batch processing
}

Поведение EasyNetQ по умолчанию заключается в том, что функция bus.Advanced.Consume выполняет подтверждение, как только функция-обработчик возвращает значение. Можно ли это отключить, и если да, то какую функцию я могу вызвать, чтобы отправить подтверждения позже?

NB. Пакетное использование сообщений RabbitMQ и подтверждение их всех одновременно решает этот вопрос для RabbitMQ.Client, но я хотел бы знать, возможно ли это в клиенте EasyNetQ.

Подробнее здесь: https://stackoverflow.com/questions/793 ... t-possible