Mascali/raspisms
1
0
Fork 0
mirror of https://github.com/RaspbianFrance/raspisms.git synced 2025-10-21 17:30:02 +02:00
Code Issues Projects Releases Wiki Activity

Improve redis queue handling of error

Browse source
This commit is contained in:
osaajani 2025-08-27 18:59:52 +02:00
parent 08cbb0f12e
commit 9e2bd47e34
1 changed files with 19 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

30
models/RedisQueue.php
View file

@ -86,21 +86,29 @@ class RedisQueue implements Queue
// Ignore error if the group already exists // Ignore error if the group already exists
} }
// Read a single message starting from the oldest (>)
$messages = $this->redis->xReadGroup($this->group, $this->consumer, [$stream => '>'], 1);
if (!count($messages))
{
return null;
}
// Find the message, acknowledge it and return it try
foreach ($messages as $stream_name => $entries)
{ {
foreach ($entries as $message_id => $message) // Read a single message starting from the oldest (>)
$messages = $this->redis->xReadGroup($this->group, $this->consumer, [$stream => '>'], 1);
if (!count($messages))
{ {
$success = $this->redis->xAck($stream, $this->group, [$message_id]); return null;
return $message['message'];
} }
// Find the message, acknowledge it and return it
foreach ($messages as $stream_name => $entries)
{
foreach ($entries as $message_id => $message)
{
$success = $this->redis->xAck($stream, $this->group, [$message_id]);
return $message['message'];
}
}
}
catch (Exception $e)
{
throw new \Exception('Redis server failed to answer !');
} }
return null; return null;