@@ -90,7 +90,7 @@ public function __construct($address, $port, $clientid, $cafile = null)
9090 * @param $clientid
9191 * @param null $cafile
9292 */
93- public function broker ($ address , $ port , $ clientid , $ cafile = null ): void
93+ public function broker ($ address , $ port , $ clientid , $ cafile = null )
9494 {
9595 $ this ->address = $ address ;
9696 $ this ->port = $ port ;
@@ -315,7 +315,7 @@ public function subscribeAndWaitForMessage($topic, $qos): string
315315 * @param $topics
316316 * @param int $qos
317317 */
318- public function subscribe ($ topics , $ qos = 0 ): void
318+ public function subscribe ($ topics , $ qos = 0 )
319319 {
320320 $ i = 0 ;
321321 $ buffer = '' ;
@@ -350,7 +350,7 @@ public function subscribe($topics, $qos = 0): void
350350 /**
351351 * Sends a keep alive ping
352352 */
353- public function ping (): void
353+ public function ping ()
354354 {
355355 $ head = chr (0xc0 );
356356 $ head .= chr (0x00 );
@@ -362,7 +362,7 @@ public function ping(): void
362362 /**
363363 * sends a proper disconnect cmd
364364 */
365- public function disconnect (): void
365+ public function disconnect ()
366366 {
367367 $ head = ' ' ;
368368 $ head [0 ] = chr (0xe0 );
@@ -373,7 +373,7 @@ public function disconnect(): void
373373 /**
374374 * Sends a proper disconnect, then closes the socket
375375 */
376- public function close (): void
376+ public function close ()
377377 {
378378 $ this ->disconnect ();
379379 stream_socket_shutdown ($ this ->socket , STREAM_SHUT_WR );
@@ -387,7 +387,7 @@ public function close(): void
387387 * @param int $qos
388388 * @param bool $retain
389389 */
390- public function publish ($ topic , $ content , $ qos = 0 , $ retain = false ): void
390+ public function publish ($ topic , $ content , $ qos = 0 , $ retain = false )
391391 {
392392 $ i = 0 ;
393393 $ buffer = '' ;
@@ -637,7 +637,7 @@ protected function strwritestring($str, &$i): string
637637 *
638638 * @param $string
639639 */
640- public function printstr ($ string ): void
640+ public function printstr ($ string )
641641 {
642642 $ strlen = strlen ($ string );
643643 for ($ j = 0 ; $ j < $ strlen ; $ j ++) {
@@ -654,7 +654,7 @@ public function printstr($string): void
654654 /**
655655 * @param string $message
656656 */
657- protected function _debugMessage (string $ message ): void
657+ protected function _debugMessage (string $ message )
658658 {
659659 if ($ this ->debug === true ) {
660660 echo date ('r: ' ) . $ message . PHP_EOL ;
@@ -664,7 +664,7 @@ protected function _debugMessage(string $message): void
664664 /**
665665 * @param string $message
666666 */
667- protected function _errorMessage (string $ message ): void
667+ protected function _errorMessage (string $ message )
668668 {
669669 error_log ('Error: ' . $ message );
670670 }
0 commit comments