Method CreateOrUpdatePushConsumerAsync

Namespace

NATS.Client.JetStream

Assembly

NATS.Client.JetStream.dll

CreateOrUpdatePushConsumerAsync(NatsJSPushConsumerOpts?, CancellationToken)

Creates a new push consumer if it doesn't exist or updates an existing one with the same name.

ValueTask<INatsJSPushConsumer> CreateOrUpdatePushConsumerAsync(NatsJSPushConsumerOpts? opts = null, CancellationToken cancellationToken = default)

Parameters

opts NatsJSPushConsumerOpts

Push consumer options.

cancellationToken CancellationToken

A CancellationToken used to cancel the API call.

Returns

ValueTask<INatsJSPushConsumer>

The NATS JetStream push consumer object.