Fix for failing services on py3 with kombu driver
Change-Id: I41f6cfbbe965cc1430b8711de6a09f99c9ca011e
Closes-bug: 1661201
(cherry picked from commit a2856b10e9)
This commit is contained in:
committed by
Renat Akhmerov
parent
443d7aa863
commit
e86619c7cd
@@ -32,7 +32,7 @@ class KombuRPCListener(ConsumerMixin):
|
|||||||
self._connections = itertools.cycle(connections)
|
self._connections = itertools.cycle(connections)
|
||||||
self._callback_queue = callback_queue
|
self._callback_queue = callback_queue
|
||||||
self._thread = None
|
self._thread = None
|
||||||
self.connection = self._connections.next()
|
self.connection = six.next(self._connections)
|
||||||
|
|
||||||
# TODO(ddeja): Those 2 options should be gathered from config.
|
# TODO(ddeja): Those 2 options should be gathered from config.
|
||||||
self._sleep_time = 1
|
self._sleep_time = 1
|
||||||
|
|||||||
Reference in New Issue
Block a user