Skip to content

hyperion.ports.queue

hyperion.ports.queue

Port: message queue abstraction.

Abstract :class:Queue base. Message models live in :mod:hyperion.domain.messages; concrete adapters (InMemoryQueue, SQSQueue, FileQueue) live in hyperion.adapters.queue.*. The from_config family delegates backend selection to :mod:hyperion.composition (the single composition root).

Queue

Bases: ABC

send abstractmethod 

send(message)

Send a message to the queue.

Source code in hyperion/ports/queue.py 
42
43
44
@abc.abstractmethod
def send(self, message: Message) -> None:
    """Send a message to the queue."""

delete abstractmethod 

delete(receipt_handle)

Delete a message from the queue.

Source code in hyperion/ports/queue.py 
46
47
48
@abc.abstractmethod
def delete(self, receipt_handle: str) -> None:
    """Delete a message from the queue."""