1. 29 Oct, 2012 4 commits
  2. 24 Oct, 2012 4 commits
  3. 23 Oct, 2012 10 commits
  4. 22 Oct, 2012 1 commit
  5. 19 Oct, 2012 7 commits
  6. 18 Oct, 2012 2 commits
    • Christos Stavrakakis's avatar
      Reconnect to different Broker if idle for too long · 0456269f
      Christos Stavrakakis authored
      Modify snf-dispatcher and add a timeout option to basic_wait method.  If
      timeout is reached, the connection to the current RabbitMQ broker is
      closed and dispatcher tries to connect to a different one.
      
      This commit is supplementary of 6d27ead, which detects connection
      failures using the TCP keepalive feature. However, while the connection
      is active, the RabbitMQ broker may have a problem. This commit tries
      to detect such problems, and considers idle connections such a case.
      0456269f
    • Christos Stavrakakis's avatar
      Detect and handle connection problems in amqp_puka · 4e91219d
      Christos Stavrakakis authored
      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.
      4e91219d
  7. 17 Oct, 2012 6 commits
  8. 16 Oct, 2012 6 commits