From 844738119d07ee3fd94eca4de8bb63d151e4a621 Mon Sep 17 00:00:00 2001 From: Savio Resende Date: Wed, 22 May 2024 21:00:53 -0500 Subject: [PATCH] Removed not necessary scheduler based messages. --- src/Services/Server.php | 23 ----------------------- 1 file changed, 23 deletions(-) diff --git a/src/Services/Server.php b/src/Services/Server.php index 16e8b27..c584fb4 100644 --- a/src/Services/Server.php +++ b/src/Services/Server.php @@ -239,8 +239,6 @@ public function handleStart(OpenSwooleServer $server): void } event(JackedServerStarted::class, $server->host, $server->port); - - $this->startDirectMessageTick($server); } public function handleRequest(Request $request, Response $response): void @@ -402,25 +400,4 @@ private function getServerConfig(bool $ssl): array 'open_http_protocol' => true, ] : [])); } - - private function startDirectMessageTick(OpenSwooleServer $server): void - { - $server->tick(1000, function () use ($server) { - Cache::lock('conveyor-messages', 2)->block(6, function () use ($server) { - foreach (Cache::pull('conveyor-messages', []) as $message) { - $data = DirectMessage::fromArray($message); - ConveyorBroadcast::forceBroadcastToChannel( - data: json_encode([ - 'action' => BroadcastAction::NAME, - 'data' => $data->message, - ]), - channel: $data->channel, - server: $server, - channelPersistence: Arr::get($this->wsPersistence, 'channels'), - ackPersistence: Arr::get($this->wsPersistence, 'messages-acknowledgments'), - ); - } - }); - }); - } }