[libanyevent-rabbitmq-perl] 83/151: Followed up the RabbitMQ 2.3.1

[Damyan Ivanov]

This is an automated email from the git hooks/post-receive script.

dmn pushed a commit to annotated tag debian/1.12-1
in repository libanyevent-rabbitmq-perl.

commit 61d23f19fb8f33b2b9dd4ba50b0cb262596984d8
Author: cooldaemon <cooldaemon at gmail.com>
Date:   Fri Mar 11 12:49:32 2011 +0900

    Followed up the RabbitMQ 2.3.1
---
 README                           |  2 +-
 lib/AnyEvent/RabbitMQ.pm         | 19 +++++++++++++------
 lib/AnyEvent/RabbitMQ/Channel.pm |  4 ++--
 lib/Net/RabbitFoot.pm            |  2 +-
 4 files changed, 17 insertions(+), 10 deletions(-)

diff --git a/README b/README
index 3eb6232..b1c5fcb 100644
--- a/README
+++ b/README
@@ -10,7 +10,7 @@ You can use Net::RabbitFoot to -
   * Publish, consume, get, ack and recover messages
   * Select, commit and rollback transactions
 
-Net::RabbitFoot is known to work with RabbitMQ versions 1.7.2 and version 0-8 of the AMQP specification.
+Net::RabbitFoot is known to work with RabbitMQ versions 2.3.1 and version 0-8 of the AMQP specification.
 
 INSTALLATION
 
diff --git a/lib/AnyEvent/RabbitMQ.pm b/lib/AnyEvent/RabbitMQ.pm
index 705997f..a15aa51 100644
--- a/lib/AnyEvent/RabbitMQ.pm
+++ b/lib/AnyEvent/RabbitMQ.pm
@@ -20,11 +20,12 @@ our $VERSION = '1.02';
 sub new {
     my $class = shift;
     return bless {
-        verbose   => 0,
+        verbose     => 0,
         @_,
-        _is_open  => 0,
-        _queue    => AnyEvent::RabbitMQ::LocalQueue->new,
-        _channels => {},
+        _is_open    => 0,
+        _queue      => AnyEvent::RabbitMQ::LocalQueue->new,
+        _channels   => {},
+        _login_user => '',
     }, $class;
 }
 
@@ -39,6 +40,11 @@ sub delete_channel {
     return delete $self->{_channels}->{$id};
 }
 
+sub login_user {
+    my $self = shift;
+    return $self->{_login_user};
+}
+
 sub load_xml_spec {
     my $self = shift;
     Net::AMQP::Protocol->load_xml_spec(@_); # die when fail in this line.
@@ -255,7 +261,8 @@ sub _open {
         },
         'Connection::OpenOk', 
         sub {
-            $self->{_is_open} = 1;
+            $self->{_is_open}   = 1;
+            $self->{_login_user} = $args{user};
             $args{on_success}->($self);
         },
         $args{on_failure},
@@ -550,7 +557,7 @@ You can use AnyEvent::RabbitMQ to -
   * Publish, consume, get, ack and recover messages
   * Select, commit and rollback transactions
 
-AnyEvnet::RabbitMQ is known to work with RabbitMQ versions 1.7.2 and version 0-8 of the AMQP specification.
+AnyEvnet::RabbitMQ is known to work with RabbitMQ versions 2.3.1 and version 0-8 of the AMQP specification.
 
 =head1 AUTHOR
 
diff --git a/lib/AnyEvent/RabbitMQ/Channel.pm b/lib/AnyEvent/RabbitMQ/Channel.pm
index 4711622..982494f 100644
--- a/lib/AnyEvent/RabbitMQ/Channel.pm
+++ b/lib/AnyEvent/RabbitMQ/Channel.pm
@@ -329,7 +329,7 @@ sub _header {
                 message_id       => '',
                 timestamp        => time,
                 type             => '',
-                user_id          => '',
+                user_id          => $self->{connection}->login_user,
                 app_id           => '',
                 cluster_id       => '',
                 %$args,
@@ -499,7 +499,7 @@ sub recover {
 
     $self->{connection}->_push_write(
         Net::AMQP::Protocol::Basic::Recover->new(
-            requeue => 0,
+            requeue => 1,
             %args,
         ),
         $self->{id},
diff --git a/lib/Net/RabbitFoot.pm b/lib/Net/RabbitFoot.pm
index 280ae97..852c0d9 100644
--- a/lib/Net/RabbitFoot.pm
+++ b/lib/Net/RabbitFoot.pm
@@ -101,7 +101,7 @@ You can use Net::RabbitFoot to -
   * Publish, consume, get, ack and recover messages
   * Select, commit and rollback transactions
 
-Net::RabbitFoot is known to work with RabbitMQ versions 1.7.2 and version 0-8 of the AMQP specification.
+Net::RabbitFoot is known to work with RabbitMQ versions 2.3.1 and version 0-8 of the AMQP specification.
 
 =head1 AUTHOR
 

-- 
Alioth's /usr/local/bin/git-commit-notice on /srv/git.debian.org/git/pkg-perl/packages/libanyevent-rabbitmq-perl.git