Revision history for Net-Async-AMQP
0.006 2014-08-25 18:01:14+01:00 Europe/London
No new features.
Bugs fixed:
* Handle channel close correctly
* Pass type information from messages - previously we were using the 'type' header
instead.
0.005 2014-08-18 05:11:08+01:00 Europe/London
No new featues.
Tests fixed:
* Don't try to connect to a 'default' AMQP server,
skip if env vars were not provided
0.004 2014-08-17 18:40:45+01:00 Europe/London
API CHANGES:
* The Net::Async::AMQP class is now an IO::Async::Notifier, to bring it in line with
other IO::Aync code. One side effect of this change is that events are now raised through
a message bus rather than directly on the Net::Async::AMQP instance itself.
Existing code will need to change this:
my $amqp = Net::Async::AMQP->new(loop => $loop);
to this:
$loop->add->(my $amqp = Net::Async::AMQP->new);
and this:
$amqp->subscribe_to_event(...);
to this:
$amqp->bus->subscribe_to_event(...);
New features:
* Connection manager for automatically connecting and assigning channels
* Some loadtesting scripts, for performance+stability testing on the server
implementation (not available yet, should be in the next release)
Bugs fixed:
* If we establish TCP connection but fail to negotiate auth with server,
previously this would leave the connection future unresolved. It will now
fail with a message indicating that the remote closed the connection.
* Net::AMQP was generating an invalid initial connection header
(AMQP\x01\x01$major$minor rather than AMQP\x00$major$minor$rev as the
AMQP 0.9.1 spec seems to require), we now generate our own header.
RabbitMQ seems happy with either.
0.003 2014-02-27 07:56:25+00:00 Europe/London
Bugs fixed:
* Connection close sends a real connection close, rather than a channel close request
0.002 2014-02-27 07:10:14+00:00 Europe/London
New features:
* Support parameters when declaring queues (passive, durable, exclusive)
0.001 2014-01-05 04:52:26 Europe/London
Initial CPAN release