miguelgrinberg
diff --git a/‎socketio/kombu_manager.py‎
Lines changed: 1 addition & 1 deletion b/‎socketio/kombu_manager.py‎
Lines changed: 1 addition & 1 deletion
@@ -64,7 +64,7 @@ def initialize(self):
                 'with ' + self.server.async_mode)
 
     def _connection(self):
-        return kombu.Connection(self.url)
+        return kombu.Connection(self.url, transport_options=self.transport_options)
 
     def _exchange(self):
         return kombu.Exchange(self.channel, type='fanout', durable=False)