While closing-topic: remove producer from set in separate thread than…

… same set-iterator thread (apache#32)
merlimat · Sep 22, 2016 · 7d317bd · 7d317bd
1 parent 4e1bde9
commit 7d317bd
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/pulsar-broker/src/main/java/com/yahoo/pulsar/broker/service/Producer.java b/pulsar-broker/src/main/java/com/yahoo/pulsar/broker/service/Producer.java
@@ -328,8 +328,10 @@ void closeNow() {
     public CompletableFuture<Void> disconnect() {
         if (!closeFuture.isDone()) {
             log.info("Disconnecting producer: {}", this);
-            cnx.closeProducer(this);
-            closeNow();
+            cnx.ctx().executor().execute(() -> {
+                cnx.closeProducer(this);
+                closeNow();
+            });
         }
         return closeFuture;
     }