Fix some warnings

This commit is contained in:
Michael 2025-05-24 19:09:49 +00:00
parent 8e0a3d00bb
commit 2335af9bf2
3 changed files with 12 additions and 6 deletions

View file

@ -105,8 +105,12 @@ class Jetstream
$last_timeout = time();
while (true) {
try {
$message = $this->client->receive();
$data = json_decode($message);
$message = @$this->client->receive();
if (empty($message)) {
$this->logger->notice('Empty message received');
break;
}
$data = json_decode($message);
if (is_object($data)) {
$timestamp = $data->time_us;
$this->route($data);