[pulsar-broker] Handle NPE in unblock stuck subscrption task when dispatcher is not created
@@ -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);
