++ed by:
Author image Theo Schlossnagle
and 1 contributors

Changes for version 0.2.0

  • fixed memory leak in amqp_table
  • add a connect timeout that both times out connect() calls and sets SO_{SND.RCV}TIMEO on the socket
  • add a heartbeat method
  • a hearbeat frame can be received in the internal_recv function causing an unexpected failure consuming; these are now ignored.
  • make queue_declare return message and consumer counts (additionally) when called in array context.


interact with RabbitMQ over AMQP using librabbitmq