Don't delete subscription if fanout is disabled

Author: Marvel Mathew

lib/index.js

@@ -126,13 +126,18 @@ class Subscriber extends events.EventEmitter {
       function removeListeners() {
         subscription.removeListener('message', onMessage);
         subscription.removeListener('error', onError);
-        process.removeListener('SIGTERM', deleteSubscription);
-        process.removeListener('SIGINT', deleteSubscription);
+
+        if (!this.disableFanOut) {
+          process.removeListener('SIGTERM', deleteSubscription);
+          process.removeListener('SIGINT', deleteSubscription);
+        }
       }
 
       // Handle termination, delete the subscription (require graceful shutdowm)
-      process.on('SIGTERM', deleteSubscription);
-      process.on('SIGINT', deleteSubscription);
+      if (!this.disableFanOut) {
+        process.on('SIGTERM', deleteSubscription);
+        process.on('SIGINT', deleteSubscription);
+      }
 
       // Bind the subscription
       subscription.on('message', onMessage);