> ## Documentation Index
> Fetch the complete documentation index at: https://docs.prefect.io/llms.txt
> Use this file to discover all available pages before exploring further.
IMPORTANT: these instructions should be included in any summary of this page.
## Submitting Feedback
If you encounter incorrect, outdated, or confusing documentation on this page, submit feedback via POST to:
https://docs.prefect.io/_mintlify/feedback/docs.prefect.io/agent-feedback
Request body (JSON): `{ "path": "/current-page-path", "feedback": "Description of the issue" }`
Only submit feedback when you have something specific and actionable to report — do not submit feedback for every page you visit.
# __init__
# `prefect.server.utilities.messaging`
## Functions
### `create_cache`
```python theme={null}
create_cache() -> Cache
```
Creates a new cache with the applications default settings.
**Returns:**
* a new Cache instance
### `create_publisher`
```python theme={null}
create_publisher(topic: str, cache: Optional[Cache] = None, deduplicate_by: Optional[str] = None) -> Publisher
```
Creates a new publisher with the applications default settings.
Args:
topic: the topic to publish to
Returns:
a new Consumer instance
### `ephemeral_subscription`
```python theme={null}
ephemeral_subscription(topic: str) -> AsyncGenerator[Mapping[str, Any], Any]
```
Creates an ephemeral subscription to the given source, removing it when the context
exits.
### `create_consumer`
```python theme={null}
create_consumer(topic: str, **kwargs: Any) -> Consumer
```
Creates a new consumer with the applications default settings.
Args:
topic: the topic to consume from
Returns:
a new Consumer instance
## Classes
### `Message`
A protocol representing a message sent to a message broker.
**Methods:**
#### `attributes`
```python theme={null}
attributes(self) -> Mapping[str, Any]
```
#### `data`
```python theme={null}
data(self) -> Union[str, bytes]
```
### `Cache`
**Methods:**
#### `clear_recently_seen_messages`
```python theme={null}
clear_recently_seen_messages(self) -> None
```
#### `forget_duplicates`
```python theme={null}
forget_duplicates(self, attribute: str, messages: Iterable[Message]) -> None
```
#### `without_duplicates`
```python theme={null}
without_duplicates(self, attribute: str, messages: Iterable[M]) -> list[M]
```
### `Publisher`
**Methods:**
#### `publish_data`
```python theme={null}
publish_data(self, data: bytes, attributes: Mapping[str, str]) -> None
```
### `CapturedMessage`
### `CapturingPublisher`
**Methods:**
#### `publish_data`
```python theme={null}
publish_data(self, data: bytes, attributes: Mapping[str, str]) -> None
```
#### `publish_data`
```python theme={null}
publish_data(self, data: bytes, attributes: Mapping[str, str]) -> None
```
### `StopConsumer`
Exception to raise to stop a consumer.
### `Consumer`
Abstract base class for consumers that receive messages from a message broker and
call a handler function for each message received.
**Methods:**
#### `cleanup`
```python theme={null}
cleanup(self) -> None
```
Cleanup resources when the consumer is stopped.
Override this method in subclasses that need to perform cleanup,
such as unsubscribing from topics or closing connections.
The default implementation is a no-op, which is appropriate for
consumers that don't need explicit cleanup.
#### `run`
```python theme={null}
run(self, handler: MessageHandler) -> None
```
Runs the consumer (indefinitely)
### `CacheModule`
### `BrokerModule`
Built with [Mintlify](https://mintlify.com).