Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Import SimpleQueue/SimpleBuffer lazily

This commit is contained in:
Ask Solem 2011-01-27 11:40:30 +01:00
parent b9a0b59590
commit 9c17749769
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
kombu/connection.py
View File

@ -16,7 +16,6 @@ from Queue import Empty, Queue as _Queue
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 @@ class BrokerConnection(object):
object.
"""
from kombu.simple import SimpleQueue
channel_autoclose = False
if channel is None:
channel = self.channel()
@ -350,6 +351,8 @@ class BrokerConnection(object):
and acknowledgements are disabled (``no_ack``).
"""
from kombu.simple import SimpleBuffer
channel_autoclose = False
if channel is None:
channel = self.channel()