Add sync disconnect to the Bunny\Client so we can disconnect synced without Promises. The main reason for this is, that client itself is sync (async is in async/client.php) and if connection is lost during app, it will end fatal error with exception, that can`t be catch. This will put the disconnect back to the sync state, so no more promise and no mo trouble if connection is dropped. (#47)

Author: Radovan Kepák

src/Connection/Client.php

@@ -5,7 +5,9 @@
 namespace Contributte\RabbitMQ\Connection;
 
 use Bunny\Client as BunnyClient;
+use Bunny\ClientStateEnum;
 use Bunny\Exception\BunnyException;
+use Bunny\Exception\ClientException;
 use Bunny\Protocol\HeartbeatFrame;
 
 class Client extends BunnyClient
@@ -17,4 +19,31 @@ public function sendHeartbeat(): void {
 		$this->getWriter()->appendFrame(new HeartbeatFrame(), $this->writeBuffer);
 		$this->flushWriteBuffer();
 	}
+
+	public function syncDisconnect(): bool
+	{
+		try {
+			if ($this->state !== ClientStateEnum::CONNECTED) {
+				return false;
+			}
+
+			$this->state = ClientStateEnum::DISCONNECTING;
+
+			foreach ($this->channels as $channel) {
+				$channelId = $channel->getChannelId();
+
+				$this->channelClose($channelId, 0, '', 0, 0);
+				$this->removeChannel($channelId);
+			}
+
+			$this->connectionClose(0, '', 0, 0);
+			$this->closeStream();
+		} catch (ClientException $e) {
+			// swallow, we do not care we are not connected, we want to close connection anyway
+		}
+
+		$this->init();
+		
+		return true;
+	}
 }

src/Connection/Connection.php

@@ -56,7 +56,7 @@ public function __construct(
 	public function __destruct()
 	{
 		if ($this->bunnyClient->isConnected()) {
-			$this->bunnyClient->disconnect();
+			$this->bunnyClient->syncDisconnect();
 		}
 	}