Merge branch 'master' into asyncio-reliabletopic

# Conflicts:
#	hazelcast/internal/asyncio_client.py
#	hazelcast/internal/asyncio_proxy/manager.py

Author: yuce

hazelcast/internal/asyncio_client.py

@@ -26,6 +26,7 @@
     MAP_SERVICE,
     MULTI_MAP_SERVICE,
     ProxyManager,
+    QUEUE_SERVICE,
     RELIABLE_TOPIC_SERVICE,
     REPLICATED_MAP_SERVICE,
     RINGBUFFER_SERVICE,
@@ -34,6 +35,7 @@
 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.reliable_topic import ReliableTopic
 from hazelcast.internal.asyncio_proxy.replicated_map import ReplicatedMap
 from hazelcast.internal.asyncio_proxy.ringbuffer import Ringbuffer
@@ -289,6 +291,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 (
     create_vector_collection_proxy,
 )
@@ -19,6 +20,7 @@
 LIST_SERVICE = "hz:impl:listService"
 MAP_SERVICE = "hz:impl:mapService"
 MULTI_MAP_SERVICE = "hz:impl:multiMapService"
+QUEUE_SERVICE = "hz:impl:queueService"
 RELIABLE_TOPIC_SERVICE = "hz:impl:reliableTopicService"
 REPLICATED_MAP_SERVICE = "hz:impl:replicatedMapService"
 RINGBUFFER_SERVICE = "hz:impl:ringbufferService"
@@ -92,6 +94,7 @@ async def create_reliable_topic_proxy(service_name, name, context):
     LIST_SERVICE: create_list_proxy,
     MAP_SERVICE: create_map_proxy,
     MULTI_MAP_SERVICE: create_multi_map_proxy,
+    QUEUE_SERVICE: create_queue_proxy,
     RELIABLE_TOPIC_SERVICE: create_reliable_topic_proxy,
     REPLICATED_MAP_SERVICE: create_replicated_map_proxy,
     RINGBUFFER_SERVICE: create_ringbuffer_proxy,