Skip to content

NatsPublisherConfig

faststream.nats.publisher.config.NatsPublisherConfig `dataclass` #

NatsPublisherConfig(
    *,
    _outer_config: NatsBrokerConfig = NatsBrokerConfig(),
    middlewares: Sequence[PublisherMiddleware[Any]],
    subject: str,
    reply_to: str,
    headers: dict[str, str] | None,
    stream: Optional[JStream],
    timeout: float | None,
)

Bases: PublisherUsecaseConfig

subject `instance-attribute` #

subject: str

reply_to `instance-attribute` #

reply_to: str

headers `instance-attribute` #

headers: dict[str, str] | None

stream `instance-attribute` #

stream: Optional[JStream]

timeout `instance-attribute` #

timeout: float | None

middlewares `instance-attribute` #

middlewares: Sequence[PublisherMiddleware[Any]]