add a TTL option to Kombu queues when RabbitMQ is used

Author: miguelgrinberg

socketio/kombu_manager.py

@@ -50,7 +50,8 @@ def __init__(self, url='amqp://guest:guest@localhost:5672//',
 
     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):