Revision 996e5d53 snf-cyclades-gtools/synnefo/ganeti/progress_monitor.py
| b/snf-cyclades-gtools/synnefo/ganeti/progress_monitor.py | ||
|---|---|---|
| 130 | 130 |
# determine the routekey for AMPQ |
| 131 | 131 |
prefix = opts.instance_name.split('-')[0]
|
| 132 | 132 |
routekey = "ganeti.%s.event.progress" % prefix |
| 133 |
amqp_client = AMQPClient() |
|
| 133 |
amqp_client = AMQPClient(hosts=settings.AMQP_HOSTS, confirm_buffer=2)
|
|
| 134 | 134 |
amqp_client.connect() |
| 135 |
amqp_client.exchange_declare(settings.EXCHANGE_GANETI, type='topic') |
|
| 135 | 136 |
|
| 136 | 137 |
pid = os.fork() |
| 137 | 138 |
if pid == 0: |
| ... | ... | |
| 202 | 203 |
# Sleep for a while |
| 203 | 204 |
time.sleep(3) |
| 204 | 205 |
|
| 206 |
amqp_client.close() |
|
| 207 |
|
|
| 205 | 208 |
|
| 206 | 209 |
if __name__ == "__main__": |
| 207 | 210 |
sys.exit(main()) |
Also available in: Unified diff