aries_cloudagent.transport.queue package¶
Submodules¶
aries_cloudagent.transport.queue.base module¶
Abstract message queue.
-
class
aries_cloudagent.transport.queue.base.
BaseMessageQueue
[source]¶ Bases:
abc.ABC
Abstract message 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.queue.basic module¶
Basic in memory queue.
-
class
aries_cloudagent.transport.queue.basic.
BasicMessageQueue
[source]¶ Bases:
aries_cloudagent.transport.queue.base.BaseMessageQueue
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
-