[libanyevent-rabbitmq-perl] 132/151: Add TLS connection support. RT#81729

Damyan Ivanov dmn at moszumanska.debian.org
Thu Jan 16 11:03:10 UTC 2014


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 4116b9f3693ef74474daf40934bd68c0e1945779
Author: Tomas Doran <bobtfish at bobtfish.net>
Date:   Mon Feb 25 12:54:45 2013 +0000

    Add TLS connection support. RT#81729
---
 Changes                  | 2 ++
 lib/AnyEvent/RabbitMQ.pm | 7 ++++++-
 2 files changed, 8 insertions(+), 1 deletion(-)

diff --git a/Changes b/Changes
index 23a7c98..1cb5172 100644
--- a/Changes
+++ b/Changes
@@ -1,5 +1,7 @@
 Revision history for Perl extension AnyEvent::RabbitMQ
 
+        - Add TLS connection support. RT#81729
+
 1.09   Mon Feb 25 12:03:00 2013
         - Support AMQP heartbeat.
 
diff --git a/lib/AnyEvent/RabbitMQ.pm b/lib/AnyEvent/RabbitMQ.pm
index 101cc06..01e9783 100644
--- a/lib/AnyEvent/RabbitMQ.pm
+++ b/lib/AnyEvent/RabbitMQ.pm
@@ -117,7 +117,7 @@ sub connect {
                 sprintf('Error connecting to AMQP Server %s:%s: %s', $args{host}, $args{port}, $!)
             );
 
-            $self->{_handle} = AnyEvent::Handle->new(
+            my %handle_args = (
                 fh       => $fh,
                 on_error => sub {
                     my ($handle, $fatal, $message) = @_;
@@ -136,6 +136,10 @@ sub connect {
                         if exists $self->{drain_condvar};
                 },
             );
+            if ($args{tls}) {
+                $handle_args{tls} = 'connect';
+            }
+            $self->{_handle} = AnyEvent::Handle->new(%handle_args);
             $self->_read_loop($args{on_close}, $args{on_read_failure});
             $self->_start(%args,);
         },
@@ -574,6 +578,7 @@ AnyEvent::RabbitMQ - An asynchronous and multi channel Perl AMQP client.
       pass       => 'guest',
       vhost      => '/',
       timeout    => 1,
+      tls        => 0, # Or 1 if you'd like SSL
       on_success => sub {
           $ar->open_channel(
               on_success => sub {

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



More information about the Pkg-perl-cvs-commits mailing list