diff --git a/index.mjs b/index.mjs index 03b778e..d2783f8 100644 --- a/index.mjs +++ b/index.mjs @@ -38,7 +38,7 @@ amqp.connect(process.env.AMQP_SERVER).then(async conn=> { return ch.consume(queueName, async (msg) => { var messageBody = JSON.parse(msg.content.toString()) console.log(`[*] Message Received! email : ${messageBody.email} and pesan : ${messageBody.html}`) - // sendReceipt(messageBody.email, messageBody.html) + sendReceipt(messageBody.email, messageBody.html) }, { noAck: true }) }).then(() => { console.log('* Waiting for messages from queue ' + queueName)