--- a/Allura/allura/lib/async.py
+++ b/Allura/allura/lib/async.py
@@ -27,6 +27,11 @@
def reset(self):
self._conn = self._connection_pool.acquire()
self._channel_pool = self._conn.ChannelPool(preload=2, limit=10)
+ self.queue = self._conn.SimpleQueue('task')
+
+ @property
+ def connection(self):
+ return self._conn
@contextmanager
def channel(self):
@@ -93,6 +98,7 @@
class MockAMQ(object):
def __init__(self, globals):
+ assert False
self.exchanges = defaultdict(list)
self.queue_bindings = defaultdict(list)
self.globals = globals