Merge pull request #5 from ifo20/fix-heartbeat-interval

Heartbeat interval should be timeout/2
rabbitmq · Jul 14, 2021 · de74e8a · de74e8a
2 parents c85c116 + 5be8d54
commit de74e8a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/connection.go b/connection.go
@@ -783,7 +783,7 @@ func (c *Connection) openTune(config Config, auth Authentication) error {
 
 	// "The client should start sending heartbeats after receiving a
 	// Connection.Tune method"
-	go c.heartbeater(c.Config.Heartbeat, c.NotifyClose(make(chan *Error, 1)))
+	go c.heartbeater(c.Config.Heartbeat/2, c.NotifyClose(make(chan *Error, 1)))
 
 	if err := c.send(&methodFrame{
 		ChannelId: 0,