[pulsar] branch master updated: [pulsar-broker] Handle NPE in unblock stuck subscrption task when dispatcher is not created (#10430)

[eolivelli]

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

eolivelli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 9982492  [pulsar-broker] Handle NPE in unblock stuck subscrption task 
when dispatcher is not created (#10430)
9982492 is described below

commit 99824922a109fb6f018719089187d18f182fd1e4
Author: Rajan Dhabalia <rdhaba...@apache.org>
AuthorDate: Mon May 3 23:48:42 2021 -0700

    [pulsar-broker] Handle NPE in unblock stuck subscrption task when 
dispatcher is not created (#10430)
---
 .../apache/pulsar/broker/service/persistent/PersistentSubscription.java | 2 +-
 1 file changed, 1 insertion(+), 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 ece65bc..992d3c3 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
@@ -1098,7 +1098,7 @@ public class PersistentSubscription implements 
Subscription {
     }
 
     public boolean checkAndUnblockIfStuck() {
-        return dispatcher.checkAndUnblockIfStuck();
+        return dispatcher != null ? dispatcher.checkAndUnblockIfStuck() : 
false;
     }
 
     private static final Logger log = 
LoggerFactory.getLogger(PersistentSubscription.class);