We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 25c20aa commit a80ae4aCopy full SHA for a80ae4a
βfeed-crawler/src/common/rmq-access.tsβ
@@ -27,6 +27,8 @@ export class RabbitMQConnection {
27
const channel = await this.rabbitMQManager.getChannel();
28
await channel.consume(queue, async (message) => {
29
try {
30
+ if (!message) return;
31
+
32
const parsedMessage = JSON.parse(message.content.toString());
33
await onMessage(parsedMessage);
34
βserver/src/common/rabbitmq/rabbitmq.service.tsβ
@@ -22,6 +22,8 @@ export class RabbitMQService {
22
23
24
25
26
0 commit comments