Class NatsJSOrderedConsumer
NATS JetStream ordered consumer.
public class NatsJSOrderedConsumer : INatsJSConsumer
- Inheritance
-
NatsJSOrderedConsumer
- Implements
- Inherited Members
Constructors
- NatsJSOrderedConsumer(string, NatsJSContext, NatsJSOrderedConsumerOpts, CancellationToken)
Creates a new NATS JetStream ordered consumer.
Properties
- Info
Consumer info object created during consume and fetch operations.
Methods
- ConsumeAsync<T>(INatsDeserialize<T>?, NatsJSConsumeOpts?, CancellationToken)
Consume messages from the stream in order.
- FetchAsync<T>(NatsJSFetchOpts, INatsDeserialize<T>?, CancellationToken)
Fetch messages from the stream in order.
- FetchNoWaitAsync<T>(NatsJSFetchOpts, INatsDeserialize<T>?, CancellationToken)
Consume a set number of messages from the stream using this consumer. Returns immediately if no messages are available.
- NextAsync<T>(INatsDeserialize<T>?, NatsJSNextOpts?, CancellationToken)
Get the next message from the stream in order.
- RefreshAsync(CancellationToken)
For ordered consumer this is a no-op.