Fix terminate all job

messaging/queueing-consumer.py

@@ -8,9 +8,9 @@ channel = os.environ.get("CHANNEL", "xqueue")
 
 queue = MQueue(channel, redis.Redis(host=host, port=port, db=0))
 
-for since, msg in queue.listen_as_group("consumers"):
+for since, msg in queue.listen():
     # We would normally process the messages here.
-    # However, to not overflow the log we skip this here.
+    # However, to avoid overflowing the log we skip message processing.
     # You can print the message, if you want.
     # print(f"{ since }: { msg }")
     print()