diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts index 8bd75016..ecd30f66 100644 --- a/src/services/rabbitmq.ts +++ b/src/services/rabbitmq.ts @@ -19,8 +19,12 @@ export async function init() { const connection = await amqp.connect(url); //----> (1.3) set up url with amqp protocol + console.log(connection ? "[AMQ] connection success" : "[AMQ] connection failed"); + const channel = await connection.createChannel(); //----> (1.4) create Channel + console.log(channel ? "[AMQ] create channel success" : "[AMQ] create channel failed"); + 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);