Minor fixes

boomerang-io · Apr 5, 2022 · e1baa92 · e1baa92
1 parent e8e95e5
commit e1baa92
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/src/main/java/io/boomerang/eventing/nats/jetstream/PullBasedSubReceiver.java b/src/main/java/io/boomerang/eventing/nats/jetstream/PullBasedSubReceiver.java
@@ -131,7 +131,7 @@ final protected void stopConsumerSubscription(Connection connection) {
 
   @Override
   final public Boolean isSubscriptionActive() {
-    return super.isSubscribed() && jetstreamSubscription != null && jetstreamSubscription.isActive()
+    return super.isSubscribed() && jetstreamSubscription != null
         && pullSubscriptionThread.isAlive();
   }
 }
diff --git a/src/main/java/io/boomerang/eventing/nats/jetstream/PushBasedSubReceiver.java b/src/main/java/io/boomerang/eventing/nats/jetstream/PushBasedSubReceiver.java
@@ -97,7 +97,6 @@ final protected void stopConsumerSubscription(Connection connection) {
 
   @Override
   public Boolean isSubscriptionActive() {
-    return super.isSubscribed() && jetstreamSubscription != null
-        && jetstreamSubscription.isActive();
+    return super.isSubscribed() && jetstreamSubscription != null && dispatcher != null;
   }
 }