Close message processor downstream.

Azure · Jul 8, 2020 · 545b3b3 · 545b3b3
1 parent c548afc
commit 545b3b3
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...ging-servicebus/src/main/java/com/azure/messaging/servicebus/ServiceBusAsyncConsumer.java b/...ging-servicebus/src/main/java/com/azure/messaging/servicebus/ServiceBusAsyncConsumer.java
@@ -88,8 +88,7 @@ Mono<Void> updateDisposition(String lockToken, DispositionStatus dispositionStat
     @Override
     public void close() {
         if (!isDisposed.getAndSet(true)) {
-            processor.onComplete();
-            linkProcessor.cancel();
+            processor.dispose();
         }
     }