aries_cloudagent.transport.outbound.queue package¶
Subpackages¶
Submodules¶
aries_cloudagent.transport.outbound.queue.base module¶
Abstract outbound queue.
-
class
aries_cloudagent.transport.outbound.queue.base.
BaseOutboundMessageQueue
[source]¶ Bases:
abc.ABC
Abstract outbound queue class.
-
dequeue
(*, timeout: int = None)[source]¶ Dequeue a message.
Returns: The dequeued message, or None if a timeout occurs
Raises: - asyncio.CancelledError if the queue has been stopped
- asyncio.TimeoutError if the timeout is reached
-
aries_cloudagent.transport.outbound.queue.basic module¶
Basic in memory queue.
-
class
aries_cloudagent.transport.outbound.queue.basic.
BasicOutboundMessageQueue
[source]¶ Bases:
aries_cloudagent.transport.outbound.queue.base.BaseOutboundMessageQueue
Basic in memory queue implementation class.
-
dequeue
(*, timeout: int = None)[source]¶ Dequeue a message.
Returns: The dequeued message, or None if a timeout occurs
Raises: - asyncio.CancelledError if the queue has been stopped
- asyncio.TimeoutError if the timeout is reached
-