@@ -41,7 +41,7 @@ public static function connect(array $array): string
41
41
$ body .= chr ($ connect_flags );
42
42
43
43
$ keepAlive = !empty ($ array ['keep_alive ' ]) && (int ) $ array ['keep_alive ' ] >= 0 ? (int ) $ array ['keep_alive ' ] : 0 ;
44
- $ body .= pack ( ' n ' , $ keepAlive );
44
+ $ body .= PackTool:: shortInt ( $ keepAlive );
45
45
46
46
$ body .= PackTool::string ($ array ['client_id ' ]);
47
47
if (!empty ($ array ['will ' ])) {
@@ -74,7 +74,7 @@ public static function publish(array $array): string
74
74
$ body = PackTool::string ($ array ['topic ' ]);
75
75
$ qos = $ array ['qos ' ] ?? 0 ;
76
76
if ($ qos ) {
77
- $ body .= pack ( ' n ' , $ array ['message_id ' ]);
77
+ $ body .= PackTool:: shortInt ( $ array ['message_id ' ]);
78
78
}
79
79
$ body .= $ array ['message ' ];
80
80
$ dup = $ array ['dup ' ] ?? 0 ;
@@ -87,7 +87,7 @@ public static function publish(array $array): string
87
87
public static function subscribe (array $ array ): string
88
88
{
89
89
$ id = $ array ['message_id ' ];
90
- $ body = pack ( ' n ' , $ id );
90
+ $ body = PackTool:: shortInt ( $ id );
91
91
foreach ($ array ['topics ' ] as $ topic => $ qos ) {
92
92
$ body .= PackTool::string ($ topic );
93
93
$ body .= chr ($ qos );
@@ -100,7 +100,7 @@ public static function subscribe(array $array): string
100
100
public static function subAck (array $ array ): string
101
101
{
102
102
$ payload = $ array ['payload ' ];
103
- $ body = pack ( ' n ' , $ array ['message_id ' ]) . call_user_func_array (
103
+ $ body = PackTool:: shortInt ( $ array ['message_id ' ]) . call_user_func_array (
104
104
'pack ' ,
105
105
array_merge (['C* ' ], $ payload )
106
106
);
@@ -111,7 +111,7 @@ public static function subAck(array $array): string
111
111
112
112
public static function unSubscribe (array $ array ): string
113
113
{
114
- $ body = pack ( ' n ' , $ array ['message_id ' ]);
114
+ $ body = PackTool:: shortInt ( $ array ['message_id ' ]);
115
115
foreach ($ array ['topics ' ] as $ topic ) {
116
116
$ body .= PackTool::string ($ topic );
117
117
}
0 commit comments