Added logger

src/Connection/Client.php

@@ -12,19 +12,23 @@
 use Bunny\Protocol;
 use Contributte\RabbitMQ\Connection\Exception\WaitTimeoutException;
 use Nette\Utils\Strings;
+use Psr\Log\LoggerInterface;
 use function time;
 
 /**
  * @codeCoverageIgnore
  */
 class Client extends BunnyClient
 {
+	protected ?LoggerInterface $logger;
+
 	/**
 	 * Constructor.
 	 *
 	 * @param array<string|mixed> $options
+	 * @param LoggerInterface|null $logger
 	 */
-	public function __construct(array $options = [])
+	public function __construct(array $options = [], ?LoggerInterface $logger = null)
 	{
 		parent::__construct($options);
 
@@ -34,6 +38,8 @@ public function __construct(array $options = [])
 		$this->options['heartbeat_callback'] = is_callable($options['heartbeat_callback'])
 			? $options['heartbeat_callback']
 			: null;
+
+		$this->logger = $logger;
 	}
 
 	/**
@@ -45,6 +51,7 @@ public function sendHeartbeat(): void
 		$this->flushWriteBuffer();
 
 		$this->options['heartbeat_callback'] && $this->options['heartbeat_callback']();
+		$this->logger?->debug('Bunny: heartbeat called');
 	}
 
 	public function syncDisconnect(int $replyCode = 0, string $replyText = ""): bool
@@ -78,6 +85,7 @@ protected function write(): void
 	{
 		if ($this->stream && feof($this->stream)) {
 			$this->syncDisconnect(Constants::STATUS_RESOURCE_ERROR, "Connection closed by server unexpectedly");
+			$this->logger?->debug('Bunny: Broken pipe detected, server closed stream');
 			throw new ClientException("Broken pipe or closed connection.");
 		}
 
@@ -89,6 +97,9 @@ protected function write(): void
 			}
 
 			error_clear_last();
+			$this->logger?->debug('Bunny: Broken pipe detected, send of bytes failed', [
+				'last_error' => $last,
+			]);
 			throw new ClientException('Broken pipe or closed connection.');
 		}
 	}
@@ -213,4 +224,10 @@ public function waitForConfirm(int $channel, ?int $timeout = null): Protocol\Met
 			$this->enqueue($frame);
 		}
 	}
+
+	protected function feedReadBuffer(): bool
+	{
+		$this->logger?->debug('Bunny: read buffer called');
+		return parent::feedReadBuffer();
+	}
 }