diff --git a/index.mjs b/index.mjs index 443d7ba..488a9e3 100644 --- a/index.mjs +++ b/index.mjs @@ -38,7 +38,7 @@ amqp.connect('amqp://localhost' ).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("michael.pandu270@gmail.com", "Berikut detail nota terbaru anda") + sendReceipt(messageBody.email, messageBody.html) }, { noAck: true }) }).then(() => { console.log('* Waiting for messages from queue ' + queueName) @@ -53,7 +53,7 @@ function sendReceipt(recepientEmail, receipt) { to: [{email: recepientEmail, name: 'Customer'}], subject: "test", textContent: "testing", - htmlContent: "

test

" + htmlContent: receipt } apiInstance.sendTransacEmail(sendSmtpEmail).then(function(data) { console.log('API called successfully. Returned data: ' + data)