Skip to content

Commit 057f2f3

Browse files
fix: wait for dispatcher
1 parent 017130c commit 057f2f3

File tree

2 files changed

+8
-4
lines changed

2 files changed

+8
-4
lines changed

package.json

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@nestjstools/messaging-rabbitmq-extension",
3-
"version": "3.0.2",
3+
"version": "3.0.4",
44
"description": "Extension to handle messages and dispatch them over AMQP protocol",
55
"author": "Sebastian Iwanczyszyn",
66
"private": false,
@@ -66,7 +66,7 @@
6666
"@nestjs/core": "^11.0.0",
6767
"@nestjs/schematics": "^11.0.0",
6868
"@nestjs/testing": "^11.0.0",
69-
"@nestjstools/messaging": "^3.0.0",
69+
"@nestjstools/messaging": "^3.0.2",
7070
"@semantic-release/github": "^11.0.1",
7171
"@types/express": "^5.0.0",
7272
"@types/jest": "^29.5.2",

src/consumer/rabbitmq-messaging.consumer.ts

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -47,9 +47,13 @@ export class RabbitmqMessagingConsumer
4747
msg.properties.headers?.[RABBITMQ_HEADER_ROUTING_KEY] ??
4848
msg.fields.routingKey;
4949

50-
await dispatcher.dispatch(new ConsumerMessage(message, routingKey));
50+
if (dispatcher.isReady()) {
51+
await dispatcher.dispatch(new ConsumerMessage(message, routingKey));
52+
amqpChannel.ack(msg);
53+
return;
54+
}
5155

52-
amqpChannel.ack(msg);
56+
amqpChannel.nack(msg, false, true);
5357
},
5458
{ noAck: false },
5559
);

0 commit comments

Comments
 (0)