[libanyevent-rabbitmq-perl] 117/151: heartbeat handle & response
Damyan Ivanov
dmn at moszumanska.debian.org
Thu Jan 16 11:03:09 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 9bc9819ce794c969c5441416ff6617987a8e1148
Author: Viktor Voronin <voronin at x12.su>
Date: Wed Nov 28 00:58:33 2012 +0400
heartbeat handle & response
---
lib/AnyEvent/RabbitMQ.pm | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/lib/AnyEvent/RabbitMQ.pm b/lib/AnyEvent/RabbitMQ.pm
index 48e89e0..48b8dd5 100644
--- a/lib/AnyEvent/RabbitMQ.pm
+++ b/lib/AnyEvent/RabbitMQ.pm
@@ -173,6 +173,10 @@ sub _read_loop {
my $id = $frame->channel;
if (0 == $id) {
+ if ($frame->type_id == 8) {
+ $self->_push_write(Net::AMQP::Frame::Heartbeat->new());
+ return;
+ }
return if !$self->_check_close_and_clean($frame, $close_cb,);
$self->{_queue}->push($frame);
} else {
--
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