fix: wait for dispatcher

Author: Sebastian-Iwanczyszyn

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjstools/messaging-rabbitmq-extension",
-  "version": "3.0.2",
+  "version": "3.0.4",
   "description": "Extension to handle messages and dispatch them over AMQP protocol",
   "author": "Sebastian Iwanczyszyn",
   "private": false,
@@ -66,7 +66,7 @@
     "@nestjs/core": "^11.0.0",
     "@nestjs/schematics": "^11.0.0",
     "@nestjs/testing": "^11.0.0",
-    "@nestjstools/messaging": "^3.0.0",
+    "@nestjstools/messaging": "^3.0.2",
     "@semantic-release/github": "^11.0.1",
     "@types/express": "^5.0.0",
     "@types/jest": "^29.5.2",

src/consumer/rabbitmq-messaging.consumer.ts

@@ -47,9 +47,13 @@ export class RabbitmqMessagingConsumer
           msg.properties.headers?.[RABBITMQ_HEADER_ROUTING_KEY] ??
           msg.fields.routingKey;
 
-        await dispatcher.dispatch(new ConsumerMessage(message, routingKey));
+        if (dispatcher.isReady()) {
+          await dispatcher.dispatch(new ConsumerMessage(message, routingKey));
+          amqpChannel.ack(msg);
+          return;
+        }
 
-        amqpChannel.ack(msg);
+        amqpChannel.nack(msg, false, true);
       },
       { noAck: false },
     );