diff --git a/src/NATS.Client.JetStream/INatsJSContext.cs b/src/NATS.Client.JetStream/INatsJSContext.cs index defc997aa..631fbcb39 100644 --- a/src/NATS.Client.JetStream/INatsJSContext.cs +++ b/src/NATS.Client.JetStream/INatsJSContext.cs @@ -144,6 +144,7 @@ IAsyncEnumerable ListConsumerNamesAsync( /// Server responded with an error. /// The name is invalid. /// The name is null. + /// This feature is only available on NATS server v2.11 and later. ValueTask PauseConsumerAsync(string stream, string consumer, DateTimeOffset pauseUntil, CancellationToken cancellationToken = default); /// @@ -157,6 +158,7 @@ IAsyncEnumerable ListConsumerNamesAsync( /// Server responded with an error. /// The name is invalid. /// The name is null. + /// This feature is only available on NATS server v2.11 and later. ValueTask ResumeConsumerAsync(string stream, string consumer, CancellationToken cancellationToken = default); /// diff --git a/src/NATS.Client.JetStream/Models/ConsumerConfig.cs b/src/NATS.Client.JetStream/Models/ConsumerConfig.cs index 7e53da07b..7a80ae7c5 100644 --- a/src/NATS.Client.JetStream/Models/ConsumerConfig.cs +++ b/src/NATS.Client.JetStream/Models/ConsumerConfig.cs @@ -236,6 +236,7 @@ public ConsumerConfig(string name) /// /// If the consumer is paused, this contains until which time it is paused. /// + /// This feature is only available on NATS server v2.11 and later. [System.Text.Json.Serialization.JsonPropertyName("pause_until")] [System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.WhenWritingDefault)] public DateTimeOffset? PauseUntil { get; set; } diff --git a/src/NATS.Client.JetStream/Models/ConsumerInfo.cs b/src/NATS.Client.JetStream/Models/ConsumerInfo.cs index e3c342f3c..3fa9fc878 100644 --- a/src/NATS.Client.JetStream/Models/ConsumerInfo.cs +++ b/src/NATS.Client.JetStream/Models/ConsumerInfo.cs @@ -102,6 +102,7 @@ public record ConsumerInfo /// /// Whether the consumer is paused. /// + /// This feature is only available on NATS server v2.11 and later. [System.Text.Json.Serialization.JsonPropertyName("paused")] [System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.WhenWritingDefault)] public bool IsPaused { get; set; } @@ -109,6 +110,7 @@ public record ConsumerInfo /// /// If the consumer is , this contains how much time is remaining until this consumer is unpaused. /// + /// This feature is only available on NATS server v2.11 and later. [System.Text.Json.Serialization.JsonPropertyName("pause_remaining")] [System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.WhenWritingDefault)] [System.Text.Json.Serialization.JsonConverter(typeof(NatsJSJsonNullableNanosecondsConverter))] diff --git a/src/NATS.Client.JetStream/Models/ConsumerPauseRequest.cs b/src/NATS.Client.JetStream/Models/ConsumerPauseRequest.cs index 44da8b082..5df24d4f0 100644 --- a/src/NATS.Client.JetStream/Models/ConsumerPauseRequest.cs +++ b/src/NATS.Client.JetStream/Models/ConsumerPauseRequest.cs @@ -3,6 +3,7 @@ namespace NATS.Client.JetStream.Models; /// /// A request to the JetStream $JS.API.CONSUMER.PAUSE API /// +/// This feature is only available on NATS server v2.11 and later. internal record ConsumerPauseRequest { [System.Text.Json.Serialization.JsonPropertyName("pause_until")]