diff options
Diffstat (limited to 'kombu/transport/mongodb.py')
| -rw-r--r-- | kombu/transport/mongodb.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kombu/transport/mongodb.py b/kombu/transport/mongodb.py index fd048188..633fde0c 100644 --- a/kombu/transport/mongodb.py +++ b/kombu/transport/mongodb.py @@ -87,6 +87,9 @@ class Channel(virtual.Channel): self._broadcast_cursors = {} + # Evaluate connection + self.client + def _new_queue(self, queue, **kwargs): pass |