diff --git a/index.mjs b/index.mjs index a4e2533..fdffa56 100644 --- a/index.mjs +++ b/index.mjs @@ -42,7 +42,7 @@ amqp.connect(process.env.AMQP_SERVER).then(async conn => { } if (queuePaylaterExist) { queuePaylaterExist.then(() => { - return ch.consume(queueNota, async (msg) => { + return ch.consume(queuePaylater, async (msg) => { var messageBody = JSON.parse(msg.content.toString()) console.log(`[*PayLater] Message Received! email : ${messageBody.email}`) sendReceipt({ @@ -52,7 +52,7 @@ amqp.connect(process.env.AMQP_SERVER).then(async conn => { }) }, { noAck: true }) }).then(() => { - console.log('* Waiting for messages from queue ' + queueNota) + console.log('* Waiting for messages from queue ' + queuePaylater) }) } }).catch(console.warn)