From dd248fa1cb934a9fd3a0c7166da4a2a8a26bb755 Mon Sep 17 00:00:00 2001
From: Simon Chen <ckq614@gmail.com>
Date: Fri, 14 Jun 2024 02:33:10 +0000
Subject: [PATCH] reset heartbeat miss counter

---
 amqprs/src/net/reader_handler.rs | 1 +
 1 file changed, 1 insertion(+)

diff --git a/amqprs/src/net/reader_handler.rs b/amqprs/src/net/reader_handler.rs
index 442a991..d385125 100644
--- a/amqprs/src/net/reader_handler.rs
+++ b/amqprs/src/net/reader_handler.rs
@@ -254,6 +254,7 @@ impl ReaderHandler {
                 res = self.stream.read_frame() => {
                     // any frame can be considered as heartbeat
                     expiration = time::Instant::now() + time::Duration::from_secs(max_interval);
+                    heartbeat_miss = 0;
                     #[cfg(feature="traces")]
                     trace!("server heartbeat deadline is updated to {:?}", expiration);