Revision b85320d0
| 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(confirm_buffer=100)
|
|
| 117 |
self.client = AMQPClient(confirm_buffer=25)
|
|
| 118 | 118 |
handler_logger.info("Attempting to connect to RabbitMQ hosts")
|
| 119 | 119 |
self.client.connect() |
| 120 | 120 |
self.client.exchange_declare(settings.EXCHANGE_GANETI, type='topic') |
Also available in: Unified diff