Made exchange durable. Always retry after disconnect.

Fixes #100

socketio/kombu_manager.py

@@ -66,7 +66,7 @@ def _connection(self):
         return kombu.Connection(self.url)
 
     def _exchange(self):
-        return kombu.Exchange(self.channel, type='fanout', durable=False)
+        return kombu.Exchange(self.channel, type='fanout')
 
     def _queue(self):
         queue_name = 'flask-socketio.' + str(uuid.uuid4())
@@ -76,13 +76,24 @@ def _queue(self):
     def _producer(self):
         return self._connection().Producer(exchange=self._exchange())
 
+    def __error_callback(self, exception, interval):
+        self.server.logger.exception('Sleeping {}s'.format(interval))
+
     def _publish(self, data):
-        self.producer.publish(pickle.dumps(data))
+        connection = self._connection()
+        publish = connection.ensure(self.producer, self.producer.publish, errback=self.__error_callback)
+        publish(pickle.dumps(data))
 
     def _listen(self):
         reader_queue = self._queue()
-        with self._connection().SimpleQueue(reader_queue) as queue:
-            while True:
-                message = queue.get(block=True)
-                message.ack()
-                yield message.payload
+
+        while True:
+            connection = self._connection().ensure_connection(errback=self.__error_callback)
+            try:
+                with connection.SimpleQueue(reader_queue) as queue:
+                    while True:
+                        message = queue.get(block=True)
+                        message.ack()
+                        yield message.payload
+            except connection.connection_errors:
+                self.server.logger.exception("Connection error while reading from queue")