@adhityan/gc-nats - npm Package Compare versions

Comparing version 2.2.2 to 2.3.0

lib/worker.js

@@ -39,2 +39,4 @@ "use strict";
         const natsService = new nats_streaming_1.StreamingService(clientID, options, clusterID);
+        debug('nats serice object created', natsService);
+        debug('calling subscribe from startWorker actual', clientID);
         return natsService.subscribe(channel, messageReceived, messageValidation, durability, restartFrom);
@@ -56,2 +58,3 @@ });
                 debug('Worker wrapper constructor running');
+                this.startWorker();
             }
@@ -58,0 +61,0 @@ startWorker() {

package.json

 {
   "name": "@adhityan/gc-nats",
   "description": "Typescript Node.js client for NATS streaming server",
-  "version": "2.2.2",
+  "version": "2.3.0",
   "repository": {
@@ -6,0 +6,0 @@ "type": "git",

src/worker.ts

@@ -27,2 +27,5 @@ import Debug from 'debug';
     const natsService = new StreamingService(clientID, options, clusterID);
+    debug('nats serice object created', natsService);
+
+    debug('calling subscribe from startWorker actual', clientID);
     return natsService.subscribe(channel, messageReceived, messageValidation, durability, restartFrom);
@@ -47,2 +50,3 @@ }
                 debug('Worker wrapper constructor running'); 
+                this.startWorker();
             }
@@ -49,0 +53,0 @@

No alert changes

Improved metrics

Total package byte prevSize

41119

increased by1.08%

Lines of code

664

increased by0.91%

No dependency changes