diff --git a/kombu/transport/mongodb.py b/kombu/transport/mongodb.py index b923f5f4..48ec88d5 100644 --- a/kombu/transport/mongodb.py +++ b/kombu/transport/mongodb.py @@ -313,6 +313,7 @@ class Channel(virtual.Channel): if self.connect_timeout else None), } options.update(parsed['options']) + options.update(client.transport_options) options = self._prepare_client_options(options) return hostname, dbname, options