[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