​
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