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
}
Как я могу пометить потребляемое сообщение как потребляемое, чтобы следующий код не был переведен в любом случае, если потребитель внезапно отключается от сети,
Я искал в MassTransit Documentation, но я не нашел.>
[code] 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 } [/code] Как я могу пометить потребляемое сообщение как потребляемое, чтобы следующий код не был переведен в любом случае, если потребитель внезапно отключается от сети, Я искал в MassTransit Documentation, но я не нашел.>