|
|
|
@@ -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) |
|
|
|
|
