From 9bc9819ce794c969c5441416ff6617987a8e1148 Mon Sep 17 00:00:00 2001
From: Viktor Voronin <voronin@x12.su>
Date: Wed, 28 Nov 2012 00:58:33 +0400
Subject: [PATCH] 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 {