Merge branch 'hotfix/2.0.1'
This commit is contained in:
commit
ae2acc6614
@ -184,7 +184,7 @@ namespace Tapeti.Default
|
|||||||
{
|
{
|
||||||
await MiddlewareHelper.GoAsync(
|
await MiddlewareHelper.GoAsync(
|
||||||
bindingInfo.CleanupMiddleware,
|
bindingInfo.CleanupMiddleware,
|
||||||
async (handler, next) => await handler.Cleanup(context, ConsumeResult.Success, next),
|
async (handler, next) => await handler.Cleanup(context, consumeResult, next),
|
||||||
() => Task.CompletedTask);
|
() => Task.CompletedTask);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user