Estoy tratando de consumir un mensaje de rabbitmq en el nodo js. Se está consumiendo correctamente. Aquí estoy haciendo alguna operación (llamada API) durante el consumo de mensajes. Ahora quiero reconocer una vez que api respondió solo al estado 200 . De lo contrario, el mensaje no se deque. Cómo puedo hacer eso ? Gracias por adelantado
let config = { protocol: 'amqp', hostname: '10.25.8.5', username: '****', password: '******' }; amqp.connect(config, function(error0, connection) { if (error0) { throw error0; } connection.createChannel(function(error1, channel) { if (error1) {throw error1;} var queue = 'test_queue'; channel.assertQueue(queue, { durable: false }); console.log(" [*] Waiting for messages", queue); channel.consume(queue, function(msg) { let consumedData = msg.content.toString(); // Other process by calling api . console.log(" [x] Received ", consumedData); }, { noAck: true }); }); });