Pass parameter consumeResult to handle.Cleanup - fixed cleanup state after exception
This commit is contained in:
parent
9351861fcc
commit
74a3aa19f7
@ -184,7 +184,7 @@ namespace Tapeti.Default
|
||||
{
|
||||
await MiddlewareHelper.GoAsync(
|
||||
bindingInfo.CleanupMiddleware,
|
||||
async (handler, next) => await handler.Cleanup(context, ConsumeResult.Success, next),
|
||||
async (handler, next) => await handler.Cleanup(context, consumeResult, next),
|
||||
() => Task.CompletedTask);
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user