diff options
Diffstat (limited to 'kombu/transport/base.py')
-rw-r--r-- | kombu/transport/base.py | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/kombu/transport/base.py b/kombu/transport/base.py index 1da86377..b4b48687 100644 --- a/kombu/transport/base.py +++ b/kombu/transport/base.py @@ -205,6 +205,9 @@ class Transport(object): #: and that the :meth:`heartbeat_check` method has any effect. supports_heartbeats = False + #: Set to true if the transport supports the AIO interface. + supports_ev = False + def __init__(self, client, **kwargs): self.client = client @@ -234,6 +237,15 @@ class Transport(object): Unconvenient to use, and limited transport support.""" return {} + def on_poll_init(self, poller): + pass + + def on_poll_start(self): + raise NotImplementedError('transport: no eventloop support') + + def on_poll_empty(self): + pass + def verify_connection(self, connection): return True |