diff --git a/CHANGELOG.md b/CHANGELOG.md index d6492c6..7fa0ed4 100644 --- a/CHANGELOG.md +++ b/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. diff --git a/VERSION b/VERSION index 238d6e8..b0f3d96 100644 --- a/VERSION +++ b/VERSION @@ -1 +1 @@ -1.0.7 +1.0.8 diff --git a/package.json b/package.json index 87524de..dba19ea 100644 --- a/package.json +++ b/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": { diff --git a/services/rmqPublish/topic.js b/services/rmqPublish/topic.js index 07ff042..af7d55f 100644 --- a/services/rmqPublish/topic.js +++ b/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(); } ); }