fix(rabbitmq): dirty queue resist when no consumer (#27)

tuana9a · Aug 16, 2024 · 23d2ba7 · 23d2ba7
1 parent 77de953
commit 23d2ba7
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/api-gateway/src/consumers/consume-maybe-stale-job-v1.ts b/api-gateway/src/consumers/consume-maybe-stale-job-v1.ts
@@ -4,7 +4,7 @@ import { mongoConnectionPool, rabbitmqConnectionPool } from "../connections";
 import logger from "../loggers/logger";
 
 export const setup = () => {
-  rabbitmqConnectionPool.getChannel().assertQueue("", { autoDelete: true }, (error2, q) => {
+  rabbitmqConnectionPool.getChannel().assertQueue("", { exclusive: true, autoDelete: true }, (error2, q) => {
     if (error2) {
       logger.error(error2);
       return;

diff --git a/api-gateway/src/consumers/consume-maybe-stale-job.ts b/api-gateway/src/consumers/consume-maybe-stale-job.ts
@@ -4,7 +4,7 @@ import { rabbitmqConnectionPool } from "../connections";
 import logger from "../loggers/logger";
 
 export const setup = () => {
-  rabbitmqConnectionPool.getChannel().assertQueue("", { autoDelete: true }, (error2, q) => {
+  rabbitmqConnectionPool.getChannel().assertQueue("", { exclusive: true, autoDelete: true }, (error2, q) => {
     if (error2) {
       logger.error(error2);
       return;

diff --git a/api-gateway/src/consumers/consume-worker-doing.ts b/api-gateway/src/consumers/consume-worker-doing.ts
@@ -5,7 +5,7 @@ import { toJson } from "../utils";
 
 export const setup = () => {
   if (cfg.LOG_WORKER_DOING) {
-    rabbitmqConnectionPool.getChannel().assertQueue("", { autoDelete: true }, (error2, q) => {
+    rabbitmqConnectionPool.getChannel().assertQueue("", { exclusive: true, autoDelete: true }, (error2, q) => {
       if (error2) {
         logger.error(error2);
         return;

diff --git a/api-gateway/src/consumers/consume-worker-ping.ts b/api-gateway/src/consumers/consume-worker-ping.ts
@@ -5,7 +5,7 @@ import { toJson } from "../utils";
 
 export const setup = () => {
   if (cfg.LOG_WORKER_PING) {
-    rabbitmqConnectionPool.getChannel().assertQueue("", { autoDelete: true }, (error2, q) => {
+    rabbitmqConnectionPool.getChannel().assertQueue("", { exclusive: true, autoDelete: true }, (error2, q) => {
       if (error2) {
         logger.error(error2);
         return;