/ 
Net-Async-AMQP-0.012
River stage zero No dependents

Changes for version 0.012 - 2014-12-11

  • No new features.
  • Bugs fixed:
  • Heartbeat handling overhaul - the send/receive heartbeat timers are independent, so we can now pick up heartbeat failure when we're not actively sending.
  • Fixes for channel/connection close handling - all Futures representing channel activities will now be marked as failed on channel closure
  • Default values for user+password (guest/guest) are now applied - this avoids the following RabbitMQ error: "AMQPLAIN auth info [{<<76,79,71,73,78>>,void,undefined},{<<80,65,83,83,87,79,82,68>>,void,undefined}] is missing LOGIN or PASSWORD field"
  • Internal changes:
  • Timers and stream are now children of the top-level Net::Async::AMQP object rather than attached directly to the loop

Modules

Net::Async::AMQP
provides client interface to AMQP using IO::Async
Net::Async::AMQP::Channel
represents a single channel in an MQ connection
Net::Async::AMQP::ConnectionManager
handle MQ connections
Net::Async::AMQP::ConnectionManager::Channel
channel proxy object
Net::Async::AMQP::ConnectionManager::Connection
connection proxy object
Net::Async::AMQP::Queue
provides client interface to AMQP using IO::Async

Provides

Net::Async::AMQP::Server
in lib/Net/Async/AMQP/Server.pm
Net::Async::AMQP::Server::Connection
in lib/Net/Async/AMQP/Server/Connection.pm
Net::Async::AMQP::Server::Protocol
in lib/Net/Async/AMQP/Server/Protocol.pm

Examples

Other files