fix: DLQ not closing channel after publishing message (#7)

Author: Sebastian-Iwanczyszyn

src/consumer/rabbitmq-messaging.consumer.ts

@@ -44,15 +44,16 @@ export class RabbitmqMessagingConsumer implements IMessagingConsumer<AmqpChannel
     return Promise.resolve();
   }
 
-  onError(errored: ConsumerDispatchedMessageError, channel: AmqpChannel): Promise<void> {
+  async onError(errored: ConsumerDispatchedMessageError, channel: AmqpChannel): Promise<void> {
     if (channel.config.deadLetterQueueFeature) {
       const publisher = channel.connection.createPublisher();
       const envelope = {
         headers: { 'messaging-routing-key': errored.dispatchedConsumerMessage.routingKey },
         exchange: 'dead_letter.exchange',
         routingKey: `${channel.config.queue}_dead_letter`
       };
-      publisher.send(envelope, errored.dispatchedConsumerMessage.message);
+      await publisher.send(envelope, errored.dispatchedConsumerMessage.message);
+      await publisher.close();
     }
 
     return Promise.resolve();