Issue when obtaining consumer for a Priority queue


#1

Hi,

I have set priority on a particular queue in Rabbitmq via the web interface with the following argument “x-max-priority” key with a max priority of 10 as per the document
Now when we try to establish the consumer connection from zato to the priority queue we are receiving the following error trace and the consumer connection is not getting established.

2018-11-26 17:44:43,058 - INFO - 4151:DummyThread-547 - zato.server.connection.amqp_:144 - Could not create an AMQP consumer for channel ADequeue (5 attempts so far), e:`Traceback (most recent call last):
File “/opt/zato/3.0/code/zato-server/src/zato/server/connection/amqp_.py”, line 136, in _get_consumer
self.config.consumer_tag_prefix, get_component_name(‘amqp-consumer’)))
File “/opt/zato/3.0/code/local/lib/python2.7/site-packages/kombu/messaging.py”, line 386, in init
self.revive(self.channel)
File “/opt/zato/3.0/code/local/lib/python2.7/site-packages/kombu/messaging.py”, line 408, in revive
self.declare()
File “/opt/zato/3.0/code/local/lib/python2.7/site-packages/kombu/messaging.py”, line 421, in declare
queue.declare()
File “/opt/zato/3.0/code/local/lib/python2.7/site-packages/kombu/entity.py”, line 605, in declare
self._create_queue(nowait=nowait, channel=channel)
File “/opt/zato/3.0/code/local/lib/python2.7/site-packages/kombu/entity.py”, line 614, in _create_queue
self.queue_declare(nowait=nowait, passive=False, channel=channel)
File “/opt/zato/3.0/code/local/lib/python2.7/site-packages/kombu/entity.py”, line 649, in queue_declare
nowait=nowait,
File “/opt/zato/3.0/code/local/lib/python2.7/site-packages/amqp/channel.py”, line 1149, in queue_declare
spec.Queue.DeclareOk, returns_tuple=True,
File “/opt/zato/3.0/code/local/lib/python2.7/site-packages/amqp/abstract_channel.py”, line 79, in wait
self.connection.drain_events(timeout=timeout)
File “/opt/zato/3.0/code/local/lib/python2.7/site-packages/amqp/connection.py”, line 491, in drain_events
while not self.blocking_read(timeout):
File “/opt/zato/3.0/code/local/lib/python2.7/site-packages/amqp/connection.py”, line 497, in blocking_read
return self.on_inbound_frame(frame)
File “/opt/zato/3.0/code/local/lib/python2.7/site-packages/amqp/method_framing.py”, line 55, in on_frame
callback(channel, method_sig, buf, None)
File “/opt/zato/3.0/code/local/lib/python2.7/site-packages/amqp/connection.py”, line 501, in on_inbound_method
method_sig, payload, content,
File “/opt/zato/3.0/code/local/lib/python2.7/site-packages/amqp/abstract_channel.py”, line 128, in dispatch_method
listener(*args)
File “/opt/zato/3.0/code/local/lib/python2.7/site-packages/amqp/channel.py”, line 277, in _on_close
reply_code, reply_text, (class_id, method_id), ChannelError,
PreconditionFailed: Queue.declare: (406) PRECONDITION_FAILED - inequivalent arg ‘x-max-priority’ for queue ‘AQueue’ in vhost ‘/’: received none but current is the value ‘10’ of type ‘long’

Regards,
Sai Bhargav