[incubator-pulsar] branch branch-1.22 updated: Fix: NPE when cursor failed to close empty subscription

[jai1]

This is an automated email from the ASF dual-hosted git repository.

jai1 pushed a commit to branch branch-1.22
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git


The following commit(s) were added to refs/heads/branch-1.22 by this push:
     new 5ce64ff  Fix: NPE when cursor failed to close empty subscription
5ce64ff is described below

commit 5ce64ff0f2196ad791b2e19c64772c11a63e0030
Author: Jai Asher <j...@ccs.neu.edu>
AuthorDate: Wed May 2 01:27:53 2018 -0700

    Fix: NPE when cursor failed to close empty subscription
---
 .../pulsar/broker/service/persistent/PersistentSubscription.java      | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
index e742f14..5e6153b 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
@@ -533,7 +533,9 @@ public class PersistentSubscription implements Subscription 
{
                     disconnectFuture.complete(null);
                 }).exceptionally(exception -> {
                     IS_FENCED_UPDATER.set(this, FALSE);
-                    dispatcher.reset();
+                    if (dispatcher != null) {
+                        dispatcher.reset();
+                    }
                     log.error("[{}][{}] Error disconnecting consumers from 
subscription", topicName, subName,
                             exception);
                     disconnectFuture.completeExceptionally(exception);

-- 
To stop receiving notification emails like this one, please contact
j...@apache.org.