[consumer] Fix consumers stuck on recovery entries

When pending entries existed in Redis but hadn't reached
the minimum idle time, XAUTOCLAIM didn't return '0-0' as the
next ID. Instead, it returned a different ID, causing the
consumer to remain stuck until all recovered entries were
processed, blocking new entries from being handled.

Signed-off-by: Jose Javier Merchante <[email protected]>

Author: jjmerchante

src/grimoirelab/core/consumers/consumer.py

@@ -193,7 +193,7 @@ def recover_stream_entries(self, recover_idle_time: int = RECOVER_IDLE_TIME) ->
 
                 yield Entry(message_id=message_id, event=json.loads(message_data))
 
-            if response[0] == b"0-0":
+            if not messages:
                 break
 
             if self._stop_event.is_set():