Error on publish confirm

[PaoloLaurenti]

Error on publish confirm

[cressie176]

Hi @PaoloLaurenti can you share the code from rabbitMQ-producer.js:15:67 please?

[cressie176]

On a separate note there's not point both checking and asserting the exchange

[PaoloLaurenti]

Hi @cressie176,
here's the rabbitMQ-producer.js file content:

function RabbitMQProducer (broker, publicationName) {
  this.broker = broker
  this.publicationName = publicationName

  this.publish = async function (message) {
    const publication = await this.broker.publish(this.publicationName, JSON.stringify(message))
    publication
      .on('success', messageId => {
        console.log('Message id was: ', messageId)
      })
      .on('error', (err, messageId) => {
        console.error('Error was: ', err)
      })
      .on('return', (messageId) => {
        console.warn('Message was returned: ', message.properties.messageId)
      })
  }
}

module.exports = RabbitMQProducer

The row 15 is

console.warn('Message was returned: ', message.properties.messageId)

The given broker object is created via this function:

async function setupRabbitMQBroker (rascalConfig, listener) {
  const broker = await rascal.BrokerAsPromised.create(rascal.withDefaultConfig(rascalConfig))
  broker.on('error', console.error)
  return broker
}

[PaoloLaurenti]

On a separate note there's not point both checking and asserting the exchange

Oh, OK, that's true. Thanks for the suggestion 👍

[cressie176]

Here's your problem...

.on('return', (messageId) => {
  console.warn('Message was returned: ', message.properties.messageId)
})

[PaoloLaurenti]

Oh man... you're right...
I am really sorry. 🙏

Thank you very much

[cressie176]

Don't worry. Happens to us all, especially when getting familiar with a new library.