Skip to content

Commit

Permalink
Add exclusive argument to Queue
Browse files Browse the repository at this point in the history
  • Loading branch information
levsh committed Oct 8, 2024
1 parent d8a8c30 commit 36d35c5
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions rmqaio.py
Original file line number Diff line number Diff line change
Expand Up @@ -797,6 +797,7 @@ class Queue:
name: Queue name.
type: Queue [type](https://www.rabbitmq.com/docs/queues#distributed).
durable: Queue durable [option](https://www.rabbitmq.com/docs/queues#durability).
exclusive: Queue exclusive [option](https://www.rabbitmq.com/docs/queues#exclusive-queues).
auto_delete: Queue auto-delete option.
prefetch_count: RabbitMQ channel [prefecth count](https://www.rabbitmq.com/docs/confirms#channel-qos-prefetch).
max_priority: Max [priority](https://www.rabbitmq.com/docs/priority) for `QueueType.CLASSIC` queue.
Expand All @@ -813,6 +814,7 @@ class Queue:
name: str
type: QueueType = QueueType.CLASSIC
durable: bool = False
exclusive: bool = False
auto_delete: bool = False
prefetch_count: int | None = 1
max_priority: int | None = None
Expand Down Expand Up @@ -905,6 +907,7 @@ async def fn():
await channel.queue_declare(
self.name,
durable=self.durable,
exclusive=self.exclusive,
auto_delete=self.auto_delete,
arguments=arguments,
timeout=timeout or self.timeout,
Expand Down

0 comments on commit 36d35c5

Please sign in to comment.