Switch to unified view
| a/Allura/allura/lib/async.py | b/Allura/allura/lib/async.py | ||
|---|---|---|---|
| 1 | import logging |
1 | import logging |
| 2 | from Queue import Queue |
2 | from Queue import Queue |
| 3 | |||
| 4 | import kombu |
||
| 5 | 3 | ||
| 6 | log = logging.getLogger(__name__) |
4 | log = logging.getLogger(__name__) |
| 7 | 5 | ||
| 8 | class Connection(object): |
6 | class Connection(object): |
| 9 | 7 | ||
| 10 | def __init__(self, hostname, port, userid, password, vhost): |
8 | def __init__(self, hostname, port, userid, password, vhost): |
| 9 | import kombu |
||
| 11 | self._conn_proto = kombu.BrokerConnection( |
10 | self._conn_proto = kombu.BrokerConnection( |
| 12 | hostname=hostname, |
11 | hostname=hostname, |
| 13 | port=port, |
12 | port=port, |
| 14 | userid=userid, |
13 | userid=userid, |
| 15 | password=password, |
14 | password=password, |