|
|
|
@ -30,7 +30,7 @@ app.get('/', (_req, res) => {
|
|
|
|
res.status.send(200).send("Amigo Receipt Sender Service Homepage!")
|
|
|
|
res.status.send(200).send("Amigo Receipt Sender Service Homepage!")
|
|
|
|
})
|
|
|
|
})
|
|
|
|
|
|
|
|
|
|
|
|
amqp.connect('amqp://localhost' ).then(async conn=> {
|
|
|
|
amqp.connect(process.env.AMQP_SERVER).then(async conn=> {
|
|
|
|
const ch = await conn.createChannel()
|
|
|
|
const ch = await conn.createChannel()
|
|
|
|
const queue = ch.assertQueue(queueName, { durable: true })
|
|
|
|
const queue = ch.assertQueue(queueName, { durable: true })
|
|
|
|
if (queue) {
|
|
|
|
if (queue) {
|
|
|
|
|