diff options
Diffstat (limited to 'kombu/transport/redis.py')
| -rw-r--r-- | kombu/transport/redis.py | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py index d8cd2332..8d3dcb77 100644 --- a/kombu/transport/redis.py +++ b/kombu/transport/redis.py @@ -942,8 +942,7 @@ class Transport(virtual.Transport): def on_poll_start(): cycle_poll_start() [add_reader(fd, on_readable, fd) for fd in cycle.fds] - self.on_poll_start = on_poll_start - loop.call_soon(on_poll_start) + loop.on_tick.add(on_poll_start) loop.call_repeatedly(10, cycle.maybe_restore_messages) def on_readable(self, fileno): @@ -956,7 +955,6 @@ class Transport(virtual.Transport): 'Message for queue {0!r} without consumers: {1}'.format( queue, message)) self._callbacks[queue](message) - self.on_poll_start() def _get_errors(self): """Utility to import redis-py's exceptions at runtime.""" |