From 6b3f82cf9fe1e6b60c25ac3b5154be9a93eccb62 Mon Sep 17 00:00:00 2001 From: ankitsingh Date: Mon, 2 Dec 2019 13:15:48 +0530 Subject: [PATCH 1/4] channel close when published in delayed queue. --- services/rmqPublish/topic.js | 2 ++ 1 file changed, 2 insertions(+) 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(); } ); } From 27bcc1469e0004c030298ad4ca8cf373486fa264 Mon Sep 17 00:00:00 2001 From: ankitsingh Date: Mon, 2 Dec 2019 15:20:49 +0530 Subject: [PATCH 2/4] version change. --- package.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/package.json b/package.json index 87524de..2b2ddad 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@ostdotcom/notification", - "version": "1.0.7", + "version": "1.0.8-beta.1", "description": "OST Notification helps publish critical events using EventEmitter and RabbmitMQ.", "main": "index.js", "scripts": { From e11bed6ca1c4dfe04dfd9452ffd1e6f8d6e0b90e Mon Sep 17 00:00:00 2001 From: ankitsingh Date: Tue, 3 Dec 2019 12:17:41 +0530 Subject: [PATCH 3/4] minor change in changelog. --- CHANGELOG.md | 3 +++ 1 file changed, 3 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index d6492c6..f765901 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,3 +1,6 @@ +## Notification v1.0.8-beta.1 +- 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. From 12f318555736a70a3cb119c07b89b3a33456a2f0 Mon Sep 17 00:00:00 2001 From: Kedar Chandrayan Date: Mon, 9 Dec 2019 13:23:58 +0530 Subject: [PATCH 4/4] self version bump --- CHANGELOG.md | 2 +- VERSION | 2 +- package.json | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index f765901..7fa0ed4 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,4 +1,4 @@ -## Notification v1.0.8-beta.1 +## 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 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 2b2ddad..dba19ea 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@ostdotcom/notification", - "version": "1.0.8-beta.1", + "version": "1.0.8", "description": "OST Notification helps publish critical events using EventEmitter and RabbmitMQ.", "main": "index.js", "scripts": {