Import SimpleQueue/SimpleBuffer lazily

simplegeo · Jan 27, 2011 · 9c17749 · 9c17749
1 parent b9a0b59
commit 9c17749
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/kombu/connection.py b/kombu/connection.py
@@ -16,7 +16,6 @@
 
 from kombu import exceptions
 from kombu.transport import get_transport_cls
-from kombu.simple import SimpleQueue, SimpleBuffer
 from kombu.utils import retry_over_time
 from kombu.utils.compat import OrderedDict
 from kombu.utils.functional import wraps
@@ -332,6 +331,8 @@ def SimpleQueue(self, name, no_ack=None, queue_opts=None,
            object.
 
         """
+        from kombu.simple import SimpleQueue
+
         channel_autoclose = False
         if channel is None:
             channel = self.channel()
@@ -350,6 +351,8 @@ def SimpleBuffer(self, name, no_ack=None, queue_opts=None,
         and acknowledgements are disabled (``no_ack``).
 
         """
+        from kombu.simple import SimpleBuffer
+
         channel_autoclose = False
         if channel is None:
             channel = self.channel()