Код: Выделить всё
public Task Consume(ConsumeContext context)
{
context.Commit();
// accepted incoming message
// the message was deleted from queue
// and it will not be redelivered
CallOperationWhichHasARiskBeRetried();
// Called operation successfully
context.Publish(new { });
}
public Task Consume(ConsumeContext context)
{
context.Commit();
// accepted incoming message
// the message was deleted from queue
// and it will not be redelivered
CallOperationWhichHasARiskBeRetried();
// thrown exception
// should publish Fault event
}
Подробнее здесь: https://stackoverflow.com/questions/774 ... ing-a-code