diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts index d7cc555a..9919eeb8 100644 --- a/src/services/rabbitmq.ts +++ b/src/services/rabbitmq.ts @@ -27,7 +27,7 @@ export async function init() { channel.assertQueue(queue, { durable: true }); //----> (1.5) assert queue and set durable (if "true" save to disk on RabbitMQ) channel.assertQueue(queue_org, { durable: true }); - channel.prefetch(1); + // channel.prefetch(1); sendToQueue = (payload: any, persistent = true) => { //----> (2) sendQueue To RabbitMQ and set persistent (if "true" redo the failed queue when server run again)