fix(amqp): remove event listener when channel is closed (#203)

Author: JulienZD

lib/adapters/amqp.js

@@ -30,28 +30,37 @@ module.exports = (config) => {
             queue,
             (message) => {
               if (message !== null) {
-                debug(`Got ${key} event from APMQ channel`)
+                debug(`Got ${key} event from AMQP channel`)
                 app.emit('sync-in', message.content)
               }
             },
             { noAck: true }
           )
-          // Publish the received message to the queue
-          app.on('sync-out', (data) => {
-            try {
+
+          function publishToQueue(data) {
+           try {
               const publishResponse = channel.publish(
                 key,
                 queue,
                 Buffer.from(data)
               )
-              debug(`Publish success: |${publishResponse}| APMQ channel`)
+              debug(`Publish success: |${publishResponse}| AMQP channel`)
             } catch (error) {
-              debug(`Publish fail: |${error.message}| APMQ channel`)
+              debug(`Publish fail: |${error.message}| AMQP channel`)
             }
+          }
+
+          // Publish the received message to the queue
+          app.on('sync-out', publishToQueue)
+
+          channel.on('close', () => {
+            debug('Channel closed')
+            app.off('sync-out', publishToQueue)
           })
+
           return channel
         } catch (error) {
-          debug(`Publish fail: |${error.message}| APMQ channel`)
+          debug(`Publish fail: |${error.message}| AMQP channel`)
         }
       }
     })