Revision 996e5d53
| b/snf-cyclades-gtools/synnefo/ganeti/eventd.py | ||
|---|---|---|
| 119 | 119 |
self.logger = logger |
| 120 | 120 |
self.cluster_name = cluster_name |
| 121 | 121 |
|
| 122 |
self.client = AMQPClient(confirm_buffer=25) |
|
| 122 |
self.client = AMQPClient(hosts=settings.AMQP_HOSTS, confirm_buffer=25)
|
|
| 123 | 123 |
handler_logger.info("Attempting to connect to RabbitMQ hosts")
|
| 124 | 124 |
|
| 125 | 125 |
self.client.connect() |
| b/snf-cyclades-gtools/synnefo/ganeti/hook.py | ||
|---|---|---|
| 164 | 164 |
|
| 165 | 165 |
# FIXME: We need a reconciliation mechanism between the DB and |
| 166 | 166 |
# Ganeti, for cases exactly like this. |
| 167 |
self.client = AMQPClient(max_retries=2 * len(settings.AMQP_HOSTS)) |
|
| 167 |
self.client = AMQPClient(hosts=settings.AMQP_HOSTS, |
|
| 168 |
max_retries = 2 * len(settings.AMQP_HOSTS)) |
|
| 168 | 169 |
self.client.connect() |
| 169 | 170 |
|
| 170 | 171 |
def on_master(self): |
| 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