Class NatsJSOrderedPushConsumer

Namespace

NATS.Client.JetStream

Assembly

NATS.Client.JetStream.dll

NATS JetStream ordered push consumer.

public class NatsJSOrderedPushConsumer : INatsJSPushConsumer, INatsJSConsumer

Inheritance

object

NatsJSOrderedPushConsumer

Implements

INatsJSPushConsumer

INatsJSConsumer

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

NatsJSOrderedPushConsumer(string, NatsJSContext, NatsJSOrderedConsumerOpts?, CancellationToken)

Creates a new NATS JetStream ordered push consumer.

Properties

Info

Consumer info object created during consume operations.

Methods

ConsumeAsync<T>(INatsDeserialize<T>?, NatsJSConsumeOpts?, CancellationToken)

Starts consuming messages from the ordered push consumer.

FetchAsync<T>(NatsJSFetchOpts, INatsDeserialize<T>?, CancellationToken)

Consume a set number of messages from the stream using this consumer.

NextAsync<T>(INatsDeserialize<T>?, NatsJSNextOpts?, CancellationToken)

Consume a single message from the stream using this consumer.

RefreshAsync(CancellationToken)

For ordered consumer this is a no-op.

ResetAsync(ulong, CancellationToken)

Not supported for ordered consumers, which recreate their underlying ephemeral consumer to seek.

UnpinAsync(string, CancellationToken)

For ordered consumer this is a no-op since ordered consumers use ephemeral consumers.