use strict;
use Test::More;
use AnyMQ;
use AnyMQ::Topic;
my $bus = AnyMQ->new;

my $channel = AnyMQ::Topic->new_with_traits
     (traits => ['WithBacklog'], backlog_length => 30, bus => $bus);

$channel->publish({ data => 1});
$channel->publish({ data => 2});

my $client = AnyMQ->new_listener($channel);

my $q = AE::cv;
$client->poll_once(sub {
                       my @msg = @_;
                       is( scalar @msg, 2);
                       is_deeply(\@msg, [{data => 1}, {data => 2}]);
                       $q->send();
                   });
$q->recv;
done_testing;