add a TTL option to Kombu queues when RabbitMQ is used

9 years ago · cc9027586f
1 changed files with 2 additions and 1 deletions
--- a/socketio/kombu_manager.py
+++ b/socketio/kombu_manager.py
@ -50,7 +50,8 @@ class KombuManager(PubSubManager):  # pragma: no cover

    def _queue(self, conn=None):
        exchange = kombu.Exchange(self.channel, type='fanout', durable=False)
-        queue = kombu.Queue(str(uuid.uuid4()), exchange)
+        queue = kombu.Queue(str(uuid.uuid4()), exchange,
+                            queue_arguments={'x-expires': 300000})
        return queue

    def _publish(self, data):