Merging release 1.0.8 from develop to release-1.0

CHANGELOG.md

@@ -1,3 +1,6 @@
+## Notification v1.0.8
+- Fixed the issue where channel was not being closed when a message was published in a delayed queue.
+
 ## Notfication v1.0.7
 - Support of delayed messages.
 - Support of fanout exchanges for broadcasting.

VERSION

@@ -1 +1 @@
-1.0.7
+1.0.8

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@ostdotcom/notification",
-  "version": "1.0.7",
+  "version": "1.0.8",
   "description": "OST Notification helps publish critical events using EventEmitter and RabbmitMQ.",
   "main": "index.js",
   "scripts": {

services/rmqPublish/topic.js

@@ -176,6 +176,8 @@ class RmqPublishByTopic {
 
               ch.publish(oThis.delayedExchangeName, q.queue, new Buffer(msgString), { persistent: true });
               console.log(' [x] Sent to DLX "', oThis.delayedExchangeName, '" with routing key', currTopic);
+
+              ch.close();
             }
           );
         }