Revision db400d82 snf-cyclades-gtools/synnefo/ganeti/eventd.py
b/snf-cyclades-gtools/synnefo/ganeti/eventd.py | ||
---|---|---|
114 | 114 |
def __init__(self, logger): |
115 | 115 |
pyinotify.ProcessEvent.__init__(self) |
116 | 116 |
self.logger = logger |
117 |
self.client = AMQPClient() |
|
117 |
self.client = AMQPClient(confirm_buffer=100)
|
|
118 | 118 |
handler_logger.info("Attempting to connect to RabbitMQ hosts") |
119 | 119 |
self.client.connect() |
120 |
self.client.exchange_declare(settings.EXCHANGE_GANETI, type='topic') |
|
120 | 121 |
handler_logger.info("Connected succesfully") |
121 | 122 |
|
122 | 123 |
self.op_handlers = {"INSTANCE": self.process_instance_op, |
... | ... | |
179 | 180 |
self.logger.debug("Delivering msg: %s (key=%s)", msg, routekey) |
180 | 181 |
|
181 | 182 |
# Send the message to RabbitMQ |
182 |
self.client.basic_publish(exchange=settings.EXCHANGE_GANETI, |
|
183 |
routing_key=routekey, |
|
184 |
body=msg) |
|
185 |
|
|
183 |
self.client.basic_publish(settings.EXCHANGE_GANETI, |
|
184 |
routekey, |
|
185 |
msg) |
|
186 | 186 |
|
187 | 187 |
def process_instance_op(self, op, job_id): |
188 | 188 |
""" Process OP_INSTANCE_* opcodes. |
Also available in: Unified diff