diff --git a/pika/adapters/select_connection.py b/pika/adapters/select_connection.py index 59e650882..143fb3232 100644 --- a/pika/adapters/select_connection.py +++ b/pika/adapters/select_connection.py @@ -5,6 +5,7 @@ import logging import select import time +from collections import OrderedDict from pika.adapters.base_connection import BaseConnection @@ -203,7 +204,7 @@ def __init__(self, fileno, handler, events, state_manager): self.events = events self.open = True self._handler = handler - self._timeouts = dict() + self._timeouts = OrderedDict() self._manage_event_state = state_manager def add_timeout(self, deadline, callback_method):