diff --git a/coolamqp/handler.py b/coolamqp/handler.py index f7567a860d4e4e24c6564c4dc342bf0595cf6ba6..33049f8b8f00bd0eb57d7464b559077da2a8bbea 100644 --- a/coolamqp/handler.py +++ b/coolamqp/handler.py @@ -100,6 +100,9 @@ class ClusterHandlerThread(threading.Thread): elif isinstance(order, DeleteQueue): self.backend.queue_delete(order.queue) elif isinstance(order, ConsumeQueue): + if order.queue.consumer_tag in self.queues_by_consumer_tags: + return # already consuming, belay that + self.backend.queue_declare(order.queue) if order.queue.exchange is not None: diff --git a/requirements.txt b/requirements.txt new file mode 100644 index 0000000000000000000000000000000000000000..8fd8878cd83409543ba2c8fb0467b0d4b28d3abd --- /dev/null +++ b/requirements.txt @@ -0,0 +1 @@ +amqp \ No newline at end of file diff --git a/setup.cfg b/setup.cfg new file mode 100644 index 0000000000000000000000000000000000000000..224a77957f5db48dfa25c8bb4a35f535202da203 --- /dev/null +++ b/setup.cfg @@ -0,0 +1,2 @@ +[metadata] +description-file = README.md \ No newline at end of file