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'), - ); - } - }); - }); - } }