Table of Contents

Class NatsJSOrderedConsumer

Namespace
NATS.Client.JetStream
Assembly
NATS.Client.JetStream.dll

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.