diff --git a/src/Transports/Pulsar/Wolverine.Pulsar/PulsarListener.cs b/src/Transports/Pulsar/Wolverine.Pulsar/PulsarListener.cs index eaf98c4a1..62ef97d1b 100644 --- a/src/Transports/Pulsar/Wolverine.Pulsar/PulsarListener.cs +++ b/src/Transports/Pulsar/Wolverine.Pulsar/PulsarListener.cs @@ -79,7 +79,7 @@ public async ValueTask DeferAsync(Envelope envelope) public async ValueTask DisposeAsync() { - await _localCancellation.CancelAsync(); + _localCancellation.Cancel(); if (_consumer != null) {