for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
declare(strict_types=1);
namespace unreal4u\MQTT\Internals;
/**
* Performs some cleanup on the socket after disconnecting, this class is NOT a part of the MQTT protocol
*/
final class DisconnectCleanup extends ProtocolBase implements ReadableContentInterface
{
use ReadableContent;
* @inheritdoc
public function performSpecialActions(ClientInterface $client, WritableContentInterface $originalRequest): bool
$successFullyClosed = $client->shutdownConnection();
$this->logger->info('Sent shutdown signal to socket', ['successFullyClosed' => $successFullyClosed]);
$client->setConnected(false);
return true;
}
public function getOriginControlPacket(): int
return 0;
unreal4u /
mqtt
