connection publish callback not executed

[vilten]

Hello,

when I tried prepare simple publish procedure, callback after publishing message is never executed.

var amqp = require('amqp')

var connection = amqp.createConnection({ host: 'localhost', port: 5672 })

// add this for better debuging connection.on('error', function(e) { console.log("Error from amqp: ", e) })

// Wait for connection to become established. connection.on('ready', function () { console.log('Connected.') connection.publish('my-queue', '', {}, _ => { console.log('Not executed') connection.end() }) })

[lcjury]

callback is a function that will get called if the exchange is in confirm mode

You're forced to setup an exchange with the option {confirm: true} to use the callback:

connection.on('ready', function () {
    console.log('Connected.')
    connection.exchange('', {confirm: true}, function(exchange) {
        exchange.publish('my-queue', '', {}, _ => {
            console.log('Executed')
            connection.end()
        });
    });
});