Revision 15f14c26 ganeti/ganeti-eventd.py
b/ganeti/ganeti-eventd.py | ||
---|---|---|
47 | 47 |
conn = None |
48 | 48 |
while conn == None: |
49 | 49 |
handler_logger.info("Attempting to connect to %s", settings.RABBIT_HOST) |
50 |
conn = amqp.Connection( host=settings.RABBIT_HOST, |
|
50 |
try: |
|
51 |
conn = amqp.Connection( host=settings.RABBIT_HOST, |
|
51 | 52 |
userid=settings.RABBIT_USERNAME, |
52 | 53 |
password=settings.RABBIT_PASSWORD, |
53 | 54 |
virtual_host=settings.RABBIT_VHOST) |
54 |
time.sleep(1) |
|
55 |
except socket.error: |
|
56 |
time.sleep(1) |
|
57 |
pass |
|
55 | 58 |
|
56 | 59 |
handler_logger.info("Connection succesful, opening channel") |
57 | 60 |
return conn.channel() |
Also available in: Unified diff