Fix for bug #640400, enables the exclusive flag on the temporary queues.

This commit is contained in:
Eric Day
2010-11-03 15:50:24 -07:00
parent 8ddacae180
commit 84d50e41ad

View File

@@ -206,6 +206,7 @@ class DirectConsumer(Consumer):
self.routing_key = msg_id
self.exchange = msg_id
self.auto_delete = True
self.exclusive = True
super(DirectConsumer, self).__init__(connection=connection)