Method CreateOrUpdateConsumerAsync
CreateOrUpdateConsumerAsync(string, ConsumerConfig, CancellationToken)
Creates new consumer if it doesn't exists or updates an existing one with the same name.
ValueTask<INatsJSConsumer> CreateOrUpdateConsumerAsync(string stream, ConsumerConfig config, CancellationToken cancellationToken = default)
Parameters
stream
stringName of the stream to create or update consumer under.
config
ConsumerConfigConsumer configuration.
cancellationToken
CancellationTokenA CancellationToken used to cancel the API call.
Returns
- ValueTask<INatsJSConsumer>
The NATS JetStream consumer object which can be used retrieving data from the stream.
Exceptions
- NatsJSException
Ack policy is set to
none
or there was an issue retrieving the response.- NatsJSApiException
Server responded with an error.
- ArgumentException
The
stream
name is invalid.- ArgumentNullException
The
stream
name isnull
.