[HZ-5403] Queue for Asyncio Client (#788)

Straightforward  port of Queue and its tests to asyncio client.

Author: yuce

hazelcast/internal/asyncio_client.py

@@ -26,12 +26,14 @@
     MAP_SERVICE,
     MULTI_MAP_SERVICE,
     ProxyManager,
+    QUEUE_SERVICE,
     REPLICATED_MAP_SERVICE,
     VECTOR_SERVICE,
 )
 from hazelcast.internal.asyncio_proxy.list import List
 from hazelcast.internal.asyncio_proxy.map import Map
 from hazelcast.internal.asyncio_proxy.multi_map import MultiMap
+from hazelcast.internal.asyncio_proxy.queue import Queue
 from hazelcast.internal.asyncio_proxy.replicated_map import ReplicatedMap
 from hazelcast.internal.asyncio_reactor import AsyncioReactor
 from hazelcast.serialization import SerializationServiceV1
@@ -285,6 +287,17 @@ async def get_multi_map(self, name: str) -> MultiMap[KeyType, ValueType]:
         """
         return await self._proxy_manager.get_or_create(MULTI_MAP_SERVICE, name)
 
+    async def get_queue(self, name: str) -> Queue[KeyType]:
+        """Returns the distributed queue instance with the specified name.
+
+        Args:
+            name: Name of the distributed queue.
+
+        Returns:
+            Distributed queue instance with the specified name.
+        """
+        return await self._proxy_manager.get_or_create(QUEUE_SERVICE, name)
+
     async def get_replicated_map(self, name: str) -> ReplicatedMap[KeyType, ValueType]:
         """Returns the distributed ReplicatedMap instance with the specified
         name.

hazelcast/internal/asyncio_proxy/manager.py

@@ -3,6 +3,7 @@
 
 from hazelcast.internal.asyncio_proxy.list import create_list_proxy
 from hazelcast.internal.asyncio_proxy.multi_map import create_multi_map_proxy
+from hazelcast.internal.asyncio_proxy.queue import create_queue_proxy
 from hazelcast.internal.asyncio_proxy.vector_collection import (
     VectorCollection,
     create_vector_collection_proxy,
@@ -17,6 +18,7 @@
 LIST_SERVICE = "hz:impl:listService"
 MAP_SERVICE = "hz:impl:mapService"
 MULTI_MAP_SERVICE = "hz:impl:multiMapService"
+QUEUE_SERVICE = "hz:impl:queueService"
 REPLICATED_MAP_SERVICE = "hz:impl:replicatedMapService"
 VECTOR_SERVICE = "hz:service:vector"
 
@@ -27,6 +29,7 @@
     LIST_SERVICE: create_list_proxy,
     MAP_SERVICE: create_map_proxy,
     MULTI_MAP_SERVICE: create_multi_map_proxy,
+    QUEUE_SERVICE: create_queue_proxy,
     REPLICATED_MAP_SERVICE: create_replicated_map_proxy,
     VECTOR_SERVICE: create_vector_collection_proxy,
 }