summaryrefslogtreecommitdiff
path: root/amqp/async.py
diff options
context:
space:
mode:
Diffstat (limited to 'amqp/async.py')
-rw-r--r--amqp/async.py13
1 files changed, 13 insertions, 0 deletions
diff --git a/amqp/async.py b/amqp/async.py
new file mode 100644
index 0000000..f1f802c
--- /dev/null
+++ b/amqp/async.py
@@ -0,0 +1,13 @@
+from __future__ import absolute_import
+
+_current_loop = None
+
+
+def get_event_loop():
+ return _current_loop
+
+
+def set_event_loop(loop):
+ global _current_loop
+ _current_loop = loop
+ return loop