rabbitmq-c icon indicating copy to clipboard operation
rabbitmq-c copied to clipboard

Declaring queue: invalid AMQP data

Open xiaoyongcheng opened this issue 4 years ago • 1 comments

amqp_queue_declare(m_conn_response, CHANNEL_ONE, queuename, 0, nMQDurable, 0, 0, arguments); die_on_amqp_error(amqp_get_rpc_reply(m_conn_response), "Declaring queue");

i try to create several consumers in code. These queues don't seem to be independent. I use threads to let a consumer queue do its own thing after it completes, When the first queue has data, A thread will be opened to consume after registration, but the registered amqp_queue_declare() function of the second queue will have an empty probability return,Unless I register all the queues.

I'm confused. What public resource did I use to make these queues independent? My env Ubuntu 16.04 default librabbitmq

thanks.

xiaoyongcheng avatar Nov 12 '20 08:11 xiaoyongcheng

If you want a given queue to be scoped to a single connection, they either need to be given a unique name, or mark the queue as exclusive (https://www.rabbitmq.com/queues.html#exclusive-queues).

alanxz avatar Nov 13 '20 21:11 alanxz