Merge pull request #16 from boomerang-io/fix/updateCode

Fix/update code

pom.xml

@@ -5,7 +5,7 @@
 
 	<groupId>io.boomerang</groupId>
 	<artifactId>lib-eventing</artifactId>
-	<version>0.4.4</version>
+	<version>0.4.5</version>
 	<name>Boomerang Lib Eventing</name>
 	<url>https://github.com/boomerang-io/lib.eventing</url>
 

src/main/java/io/boomerang/eventing/nats/jetstream/PullBasedSubReceiver.java

@@ -111,6 +111,7 @@ public void run() {
                 jsse);
           } catch (IllegalStateException e) {
             logger.error("An exception was raised when pulling new messages from the consumer!", e);
+            return;
           }
         }
       }