Refactor and add async example for queue interactions

Removed obsolete client-side gRPC test script and updated the queue examples to enable all example cases. Introduced a new async example for sending and receiving messages using asyncio and KubeMQ queues for improved functionality.

Author: liornabat

examples/queues/async.py

@@ -0,0 +1,54 @@
+import asyncio
+import logging
+import os
+from logging.config import dictConfig
+
+
+
+from kubemq.queues import *
+
+async def example_send_receive():
+    with Client(
+        address="localhost:50000",
+    ) as client:
+        async def _send():
+            while True:
+                send_result = await client.send_queues_message_async(
+                    QueueMessage(
+                        channel="send_receive",
+                        body=b"message",
+                    ),
+                )
+                if send_result.is_error:
+                    print(f"Error sending message: {send_result.error}")
+                    await asyncio.sleep(1)
+                    continue
+                print(f"Queue Message Sent: {send_result}")
+                await asyncio.sleep(1)
+
+        async def _receive():
+            while True:
+                send_receive_result = await client.receive_queues_messages_async(
+                    channel="send_receive",
+                    max_messages=1,
+                    wait_timeout_in_seconds=1,
+                )
+                if send_receive_result.is_error:
+                    print(f"Error receiving message: {send_receive_result.error}")
+                    await asyncio.sleep(1)
+                    continue
+                for message in send_receive_result.messages:
+                    print(f"Id:{message.id}, Body:{message.body.decode('utf-8')}")
+                    message.ack()
+
+                await asyncio.sleep(1)
+
+        task1 = asyncio.create_task(_send())
+        task2 = asyncio.create_task(_receive())
+        tasks = [task1, task2]
+        await asyncio.gather(*tasks)
+
+
+if __name__ == "__main__":
+    asyncio.run(example_send_receive())
+

examples/queues/queues.py

@@ -405,20 +405,20 @@ def example_with_wait_pull():
 if __name__ == "__main__":
     try:
         example_send_receive()
-        # example_send_receive_with_auto_ack()
-        # example_send_receive_with_dlq()
-        # example_send_receive_with_delay()
-        # example_send_receive_with_expiration()
-        # example_with_message_ack()
-        # example_with_message_reject()
-        # example_with_message_requeue()
-        # example_with_ack_all()
-        # example_with_reject_all()
-        # example_with_requeue_all()
-        # example_with_visibility()
-        # example_with_visibility_expired()
-        # example_with_visibility_extension()
-        # example_with_wait_pull()
+        example_send_receive_with_auto_ack()
+        example_send_receive_with_dlq()
+        example_send_receive_with_delay()
+        example_send_receive_with_expiration()
+        example_with_message_ack()
+        example_with_message_reject()
+        example_with_message_requeue()
+        example_with_ack_all()
+        example_with_reject_all()
+        example_with_requeue_all()
+        example_with_visibility()
+        example_with_visibility_expired()
+        example_with_visibility_extension()
+        example_with_wait_pull()
     except Exception as err:
         print(err)
     finally: