History | View | Annotate | Download (14.8 kB)
Make amqp_puka get logger as argument
Fix dispatcher logging
Add support for dead-letter-exchange to amqp_puka
Also add support for custom headers when publishing messages.
Implement basic_nack and basic_reject AMQP methods
Basic_nack method is not support by puka. We are implementingbasic_nack as basic_ack since they have the same effect whenmultiple and requeue options are not used.
Reconnect to different Broker if idle for too long
Modify snf-dispatcher and add a timeout option to basic_wait method. Iftimeout is reached, the connection to the current RabbitMQ broker isclosed and dispatcher tries to connect to a different one.
This commit is supplementary of 6d27ead, which detects connection...
Detect and handle connection problems in amqp_puka
Use the TCP keepalive feature in amqp_puka in order to detect connectionerrors to the RabbitMQ broker, and retry to a different one. Also setupthe keepalive parameters to relative small values, to detect failures...
Various fixes about logging
Fix logging from snf-manage commands. Modify snf-manage implementationin order to setup the loggers for all snf-manage commands. Configurationis based on SNF_MANAGE_LOGGING_SETUP setting from snf-common or onbasicConfig if that setting is missing....
Change eventd and dispatcher AMQP retries
Set unlimited connection retries to AMQP hosts for snf-ganeti-eventd,since death of snf-ganeti-eventd results in loss of events.Also increase retries of snf-dispatcher.
Fix bug in amqp_puka
Make AMQPConnectionError an exception
Fix bug in puka client
Redeclare exchanges when reconnecting
Refactor AMQP client