Method CreateOrderedPushConsumerAsync

Namespace

NATS.Client.JetStream

Assembly

NATS.Client.JetStream.dll

CreateOrderedPushConsumerAsync(NatsJSOrderedConsumerOpts?, CancellationToken)

Creates a new ordered push consumer on this stream.

ValueTask<INatsJSPushConsumer> CreateOrderedPushConsumerAsync(NatsJSOrderedConsumerOpts? opts = null, CancellationToken cancellationToken = default)

Parameters

opts NatsJSOrderedConsumerOpts

Ordered consumer options.

cancellationToken CancellationToken

A CancellationToken used to cancel the API call.

Returns

ValueTask<INatsJSPushConsumer>

The NATS JetStream push consumer object which can be used to retrieve ordered data.