fix: close the open channel after publishing msg

avdkishore · Jan 31, 2020 · c85e6d8 · c85e6d8
1 parent 389e6a9
commit c85e6d8
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/index.js b/src/index.js
@@ -156,6 +156,7 @@ export default class RabbitMQ {
         .sendToQueue(queueName, data, publishOptions)
         .then(() => {
           logger.log('data', { note: `Message sent to queue ${queueName}`, custom: { data } });
+          channelWrapper.close();
           return Promise.resolve(data);
         })
         .catch(err => {