Changes for version 0.2.0 - 2011-04-19

  • 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.

Modules

interact with RabbitMQ over AMQP using librabbitmq