Class NatsJSOrderedConsumer

Namespace

NATS.Client.JetStream

Assembly

NATS.Client.JetStream.dll

NATS JetStream ordered consumer.

public class NatsJSOrderedConsumer : INatsJSConsumer

Inheritance

object

NatsJSOrderedConsumer

Implements

INatsJSConsumer

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

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.