diff options
| author | Len Buckens <buckens.len@gmail.com> | 2014-06-03 17:34:47 +0200 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2014-07-07 14:17:02 +0100 |
| commit | 4471b29124f5d7dbb8dcd85c37869cb802c08e90 (patch) | |
| tree | 7c6f3dc3fe676b9eccf1e871e7d0eb3e47eaf3c5 /kombu/transport/mongodb.py | |
| parent | b0268c2220e867282366b7b6973a73cd12bc027f (diff) | |
| download | kombu-4471b29124f5d7dbb8dcd85c37869cb802c08e90.tar.gz | |
mongodb transport - evaluate connection
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 |