Make queues FIFO.

lib/Test/Net/RabbitMQ.pm

@@ -3,7 +3,7 @@ use Moose;
 use warnings;
 use strict;
 
-our $VERSION = '0.07';
+our $VERSION = '0.08';
 
 # Bindings are stored in the following form:
 # {
@@ -158,7 +158,7 @@ sub get {
 
     die "Unknown queue: $queue" unless $self->_queue_exists($queue);
 
-    my $message = pop(@{ $self->_get_queue($queue) });
+    my $message = shift(@{ $self->_get_queue($queue) });
 
     return undef unless defined($message);
 
@@ -269,7 +269,7 @@ sub recv {
     my $queue = $self->queue;
     die "No queue, did you consume() first?" unless defined($queue);
 
-    my $message = pop(@{ $self->_get_queue($self->queue) });
+    my $message = shift(@{ $self->_get_queue($self->queue) });
 
     return undef unless defined $message;
 

t/fifo.t

@@ -0,0 +1,29 @@
+use Test::More;
+use Test::Exception;
+
+use Test::Net::RabbitMQ;
+
+my $mq = Test::Net::RabbitMQ->new;
+isa_ok($mq, 'Test::Net::RabbitMQ', 'instantiated');
+
+$mq->connect;
+
+$mq->channel_open(1);
+
+$mq->exchange_declare(1, 'fifo');
+$mq->queue_declare(1, 'new-fifo');
+
+$mq->queue_bind(1, 'new-fifo', 'fifo', 'fifo.new');
+
+$mq->publish(1, 'fifo.new', 'foo', { exchange => 'fifo' });
+$mq->publish(1, 'fifo.new', 'bar', { exchange => 'fifo' });
+
+$mq->consume(1, 'new-fifo');
+
+my $msg = $mq->recv;
+cmp_ok($msg->{body}, 'eq', 'foo', 'first recv matches first published');
+
+$msg = $mq->recv;
+cmp_ok($msg->{body}, 'eq', 'bar', 'second recv matches second published');
+
+done_testing;