summaryrefslogtreecommitdiff
path: root/kombu/transport/base.py
diff options
context:
space:
mode:
Diffstat (limited to 'kombu/transport/base.py')
-rw-r--r--kombu/transport/base.py12
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