From cc9027586f045b6aa96e832bb287971762fb339d Mon Sep 17 00:00:00 2001
From: Miguel Grinberg <miguelgrinberg50@gmail.com>
Date: Sun, 18 Sep 2016 14:32:49 -0700
Subject: [PATCH] add a TTL option to Kombu queues when RabbitMQ is used

---
 socketio/kombu_manager.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/socketio/kombu_manager.py b/socketio/kombu_manager.py
index ee1a772..7c0b06b 100644
--- 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):