From 2d7cc9180933efe5fd10f6824b29c83f81ce46c3 Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Mon, 18 Jul 2022 15:49:11 +0800
Subject: [PATCH] Update Client.php

---
 src/Client.php | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/Client.php b/src/Client.php
index e0b9d95..09e0287 100644
--- a/src/Client.php
+++ b/src/Client.php
@@ -229,7 +229,7 @@ class_alias('\Workerman\Mqtt\Protocols\Mqtt', $class_name);
         $this->_remoteAddress = $address;
         $this->_connection    = new AsyncTcpConnection($address, $context);
         // support tcp address
-        $this->_connection->protocol = '\Workerman\Protocols\Mqtt';
+        $this->_connection->protocol = $class_name;
         $this->onReconnect    = array($this, 'onMqttReconnect');
         $this->onMessage      = function(){};
         if ($this->_options['ssl']) {