diff --git a/src/Bunny/AbstractClient.php b/src/Bunny/AbstractClient.php index f58eef5..e96353d 100644 --- a/src/Bunny/AbstractClient.php +++ b/src/Bunny/AbstractClient.php @@ -489,4 +489,13 @@ protected function findChannelId() throw new ClientException("No available channels"); } + /** + * @return void + */ + public function sendHeartbeat() + { + $this->getWriter()->appendFrame(new HeartbeatFrame(), $this->getWriteBuffer()); + $this->flushWriteBuffer(); + } + }