Module consumer 

JetStream consumer types and builders.

Structs

FetchBuilder

Builder for fetching messages from a pull consumer.

JetStreamMessage

A typed message from a JetStream consumer.

PullBatch

A batch of messages from a fetch operation.

PullConsumer

A typed pull consumer with configurable codec.

PullConsumerBuilder

Builder for creating pull consumers.

PullMessages

A stream of messages from a pull consumer.

PushConsumer

A typed push consumer with configurable codec.

PushConsumerBuilder

Builder for creating push consumers.

PushMessages

A stream of messages from a push consumer.

Enums

AckPolicy

Acknowledgment policy for consumers.

DeliverPolicy

Deliver policy for consumers.

ReplayPolicy

Replay policy for consumers.