diff --git a/pika/channel.py b/pika/channel.py index 7cefced84..c39c72afb 100644 --- a/pika/channel.py +++ b/pika/channel.py @@ -50,7 +50,7 @@ def __init__(self, connection, channel_number, on_open_callback=None, force_bina self._blocked = collections.deque(list()) self._blocking = None self._has_on_flow_callback = False - self._cancelled = collections.deque(list(), maxlen=10) + self._cancelled = collections.deque(list()) self._consumers = dict() self._on_flowok_callback = None self._on_getok_callback = None