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