prefect.server.utilities.messaging.memory

Classes

MemoryMessage

Subscription

A subscription to a topic.

Messages are delivered to the subscription’s queue and retried up to a maximum number of times. If a message cannot be delivered after the maximum number of retries it is moved to the dead letter queue.

The dead letter queue is a directory of JSON files containing the serialized message.

Messages remain in the dead letter queue until they are removed manually.

Topic

Methods:

by_name

by_name(cls, name: str) -> 'Topic'

clear_all

clear_all(cls) -> None

subscribe

subscribe(self, **subscription_kwargs: Any) -> Subscription

unsubscribe

unsubscribe(self, subscription: Subscription) -> None

clear

clear(self) -> None

Cache

Publisher

Consumer