From 4e6be0d9fcc1c600cc99cea05d13c1c9a6ea1fb5 Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Sun, 22 Sep 2013 18:15:39 +0100 Subject: [PATCH] virtual queue_declare now returns namedtuple --- kombu/transport/virtual/__init__.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/kombu/transport/virtual/__init__.py b/kombu/transport/virtual/__init__.py index ab014f84..bfc10976 100644 --- a/kombu/transport/virtual/__init__.py +++ b/kombu/transport/virtual/__init__.py @@ -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."""