aio-pika
aio-pika copied to clipboard
x-max-priority is limited to 127 instead of 255
Declaring a queue with the following arguments: {'x-max-priority': 255} raises:
../../lala/utils/rabbitmq.py:160: in _declare_tasks_queue
arguments=self.queue_arguments)
../../../../anaconda3/envs/lala/lib/python3.7/site-packages/aio_pika/robust_channel.py:173: in declare_queue
timeout=timeout,
../../../../anaconda3/envs/lala/lib/python3.7/site-packages/aio_pika/channel.py:303: in declare_queue
await queue.declare(timeout=timeout)
../../../../anaconda3/envs/lala/lib/python3.7/site-packages/aio_pika/queue.py:101: in declare
timeout=timeout,
../../../../anaconda3/envs/lala/lib/python3.7/asyncio/tasks.py:388: in wait_for
return await fut
../../../../anaconda3/envs/lala/lib/python3.7/site-packages/aiormq/channel.py:641: in queue_declare
arguments=arguments,
../../../../anaconda3/envs/lala/lib/python3.7/site-packages/aiormq/base.py:168: in wrap
return await self.create_task(func(self, *args, **kwargs))
../../../../anaconda3/envs/lala/lib/python3.7/site-packages/aiormq/base.py:27: in __inner
raise self.exception from e
../../../../anaconda3/envs/lala/lib/python3.7/asyncio/tasks.py:603: in _wrap_awaitable
return (yield from awaitable.__await__())
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <TaskWrapper: <Task cancelled coro=<Channel.rpc() done, defined at /Users/kenny/anaconda3/envs/lala/lib/python3.7/site-packages/aiormq/channel.py:101>>>
async def __inner(self):
try:
return await self.task
except asyncio.CancelledError as e:
> raise self.exception from e
E aiormq.exceptions.ChannelPreconditionFailed: PRECONDITION_FAILED - invalid arg 'x-max-priority' for queue 'test' in vhost 'my_vhost': {value_negative,-1}
../../../../anaconda3/envs/lala/lib/python3.7/site-packages/aiormq/base.py:27: ChannelPreconditionFailed
aio-pika version 6.6.1 rabbitmq version 3.8.5
pamqp.encode.DEPRECATED_RABBITMQ_SUPPORT = True
The same problem.
aiormq.exceptions.ChannelPreconditionFailed: PRECONDITION_FAILED - inequivalent arg 'x-max-priority' for queue 'test' in vhost '/': received '-1' but current is '255'