Class NatsJSExtensions

Namespace

NATS.Client.JetStream

Assembly

NATS.Client.JetStream.dll

public static class NatsJSExtensions

Inheritance

object

NatsJSExtensions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

AckTerminateAsync<T>(INatsJSMsg<T>, string, CancellationToken)

EnsureSuccess(PubAckResponse)

Make sure acknowledgment was successful and throw an exception otherwise.

IsSuccess(PubAckResponse)

Checks if there are no errors and message is not a duplicate.

NakAsync<T>(INatsJSMsg<T>, TimeSpan, CancellationToken)