diff options
Diffstat (limited to 'kombu/messaging.py')
| -rw-r--r-- | kombu/messaging.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kombu/messaging.py b/kombu/messaging.py index 98d59d45..8b923950 100644 --- a/kombu/messaging.py +++ b/kombu/messaging.py @@ -11,6 +11,7 @@ import numbers from itertools import count +from .common import maybe_declare from .compression import compress from .connection import maybe_channel, is_connection from .entity import Exchange, Queue, DELIVERY_MODES @@ -107,7 +108,6 @@ class Producer(object): """Declare the exchange if it hasn't already been declared during this session.""" if entity: - from .common import maybe_declare return maybe_declare(entity, self.channel, retry, **retry_policy) def publish(self, body, routing_key=None, delivery_mode=None, |