root / logic / amqp_connection.py @ 4f6e36d9
History | View | Annotate | Download (522 Bytes)
1 |
import time |
---|---|
2 |
from amqplib import client_0_8 as amqp |
3 |
from django.conf import settings |
4 |
|
5 |
conn = None
|
6 |
|
7 |
class AMQPConnection: |
8 |
|
9 |
def connect(self): |
10 |
while conn == None: |
11 |
try:
|
12 |
conn = amqp.Connection(host=settings.RABBIT_HOST, |
13 |
userid=settings.RABBIT_USERNAME, |
14 |
password=settings.RABBIT_PASSWORD, |
15 |
virtual_host=settings.RABBIT_VHOST) |
16 |
except socket.error:
|
17 |
time.sleep(1)
|
18 |
|
19 |
|
20 |
|