Merge pull request #15 from pcnfernando/master

Add null check during pause and resume
siddhi-io · May 28, 2019 · 782afa4 · 782afa4
2 parents 7acab1c + 7b679e4
commit 782afa4
Showing 1 changed file with 12 additions and 2 deletions.
diff --git a/component/src/main/java/io/siddhi/extension/io/nats/source/NATSSource.java b/component/src/main/java/io/siddhi/extension/io/nats/source/NATSSource.java
@@ -213,12 +213,22 @@ public void destroy() {
 
     @Override
     public void pause() {
-        natsMessageProcessor.pause();
+        if (natsMessageProcessor != null) {
+            natsMessageProcessor.pause();
+            if (log.isDebugEnabled()) {
+                log.debug("Nats source paused for destination: " + destination);
+            }
+        }
     }
 
     @Override
     public void resume() {
-        natsMessageProcessor.resume();
+        if (natsMessageProcessor != null) {
+            natsMessageProcessor.resume();
+            if (log.isDebugEnabled()) {
+                log.debug("Nats source resumed for destination: " + destination);
+            }
+        }
     }
 
     private void subscribe(NATSSourceState natsSourceState) {