« Previous | Next » 

Revision 6d27eadd

ID6d27eadd200961f87bae3f740e1db6fec2d74c2a

Added by Christos Stavrakakis over 9 years ago

Detect and handle connection problems in amqp_puka

Use the TCP keepalive feature in amqp_puka in order to detect connection
errors to the RabbitMQ broker, and retry to a different one. Also setup
the keepalive parameters to relative small values, to detect failures
relatively soon.

Also, modify and-dispatcher to use the AMQP prefetch_count option of the
basic_consume method, which makes the RabbitMQ broker to not deliver
more than prefetch_count messages to the snf-dispatcher, before
receiving acknowledgement for the previous messages.

Files

  • added
  • modified
  • copied
  • renamed
  • deleted

View differences