Commit cbe73426 authored by Gabrecht, Marco's avatar Gabrecht, Marco
Browse files

1

parent 4ae555d4
Pipeline #41181 passed with stages
in 1 minute and 8 seconds
......@@ -8,7 +8,7 @@ channel = os.environ.get("CHANNEL", "xqueue")
queue = MQueue(channel, redis.Redis(host=host, port=port, db=0))
for since, msg in queue.listen(since=0):
for since, msg in queue.listen(since=1614769663096):
# We would normally process the messages here.
# However, to avoid overflowing the log we skip message processing.
# You can print the message, if you want.
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment