From cc7c80758a8fe850a761d7f88f505b598bedd329 Mon Sep 17 00:00:00 2001
From: h3nng <ruihenng@gmail.com>
Date: Mon, 10 Oct 2016 07:06:46 +0800
Subject: [PATCH] Synchronized  'consumers' in PulsarClientImpl during cleanup
 (#54)

---
 .../java/com/yahoo/pulsar/client/impl/PulsarClientImpl.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-client/src/main/java/com/yahoo/pulsar/client/impl/PulsarClientImpl.java b/pulsar-client/src/main/java/com/yahoo/pulsar/client/impl/PulsarClientImpl.java
index 34f2c660852..462f35ea7d0 100644
--- a/pulsar-client/src/main/java/com/yahoo/pulsar/client/impl/PulsarClientImpl.java
+++ b/pulsar-client/src/main/java/com/yahoo/pulsar/client/impl/PulsarClientImpl.java
@@ -418,7 +418,7 @@ public class PulsarClientImpl implements PulsarClient {
     }
 
     void cleanupConsumer(ConsumerBase consumer) {
-        synchronized (consumer) {
+        synchronized (consumers) {
             consumers.remove(consumer);
         }
     }
-- 
GitLab