virtual queue_declare now returns namedtuple

This commit is contained in:
Ask Solem 2013-09-22 18:15:39 +01:00
parent 036b0dc504
commit 4e6be0d9fc
1 changed files with 3 additions and 1 deletions

View File

@ -20,6 +20,8 @@ from itertools import count
from multiprocessing.util import Finalize
from time import sleep, time
from amqp.protocol import queue_declare_ok_t
from kombu.exceptions import ResourceError, StdChannelError
from kombu.five import Empty, items
from kombu.utils import emergency_dump_state, say, uuid
@ -421,7 +423,7 @@ class Channel(AbstractChannel, base.StdChannel):
)
else:
self._new_queue(queue, **kwargs)
return queue, self._size(queue), 0
return queue_declare_ok_t(queue, self._size(queue), 0)
def queue_delete(self, queue, if_unusued=False, if_empty=False, **kwargs):
"""Delete queue."""