I am using RabbitMq 3.2.1 in Ubuntu 14.04. I have configured the exchange using nodejs module "amqp" like below.
var options = {
type: 'topic',
passive: false,
durable: true,
confirm: false,
autoDelete: false
};
I am also publishing message with the below configuration.
var options = {
mandatory: false,
immediate: false,
contentType: 'application/json',
deliveryMode: 1,
priority: 1
};
With this, when I publish the message it all received by the consumer even-though if all the consumers were busy the message is waited in queue and it was consumed later by consumer when it is free.But the issue I am facing one of the message is never received by the consumer.
I have doubted that it all due to configuration I disabled for mandatory and immediate as false. But I need to make the message in queue if all consumers were busy and consumed later when it available.
Can anyone help what may be the issue?
via Soorya Prakash
No comments:
Post a Comment