diff --git a/kombu/transport/mongodb.py b/kombu/transport/mongodb.py index b923f5f4b..48ec88d50 100644 --- a/kombu/transport/mongodb.py +++ b/kombu/transport/mongodb.py @@ -313,6 +313,7 @@ def _parse_uri(self, scheme='mongodb://'): 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