Interface INatsJSConsumer

Namespace: NATS.Client.JetStream

Assembly: NATS.Client.JetStream.dll

public interface INatsJSConsumer

Properties

Info: Consumer info object as retrieved from NATS JetStream server at the time this object was created, updated or refreshed.

Methods

ConsumeAsync<T>(INatsDeserialize<T>?, NatsJSConsumeOpts?, CancellationToken): Starts an enumerator consuming messages from the stream using this consumer.

FetchAsync<T>(NatsJSFetchOpts, INatsDeserialize<T>?, CancellationToken): Consume a set number of messages from the stream using this consumer.

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): Consume a single message from the stream using this consumer.

RefreshAsync(CancellationToken): Retrieve the consumer info from the server and update this consumer.

Edit this page