Add feature flag warning

Gsantomaggio · Gsantomaggio · commit 2b72a3fe76a5 · 2023-09-18T17:22:35.000+02:00
Signed-off-by: Gabriele Santomaggio &lt;G.santomaggio@gmail.com&gt;
diff --git a/RabbitMQ.Stream.Client/RawConsumer.cs b/RabbitMQ.Stream.Client/RawConsumer.cs
@@ -83,7 +83,8 @@ internal void Validate()
             if (IsFiltering && !AvailableFeaturesSingleton.Instance.PublishFilter)
             {
                 throw new UnsupportedOperationException("Broker does not support filtering. You need " +
-                                                        "RabbitMQ 3.13.0 or later.");
+                                                        "RabbitMQ 3.13.0 or later and " +
+                                                        "the stream_filtering feature flag enabled.");
             }
 
             switch (ConsumerFilter)
diff --git a/RabbitMQ.Stream.Client/RawProducer.cs b/RabbitMQ.Stream.Client/RawProducer.cs
@@ -45,7 +45,8 @@ internal void Validate()
             if (Filter is { FilterValue: not null } && !AvailableFeaturesSingleton.Instance.PublishFilter)
             {
                 throw new UnsupportedOperationException("Broker does not support filtering. " +
-                                                        "You need RabbitMQ 3.13.0 or later.");
+                                                        "You need RabbitMQ 3.13.0 or later and" +
+                                                        "the stream_filtering feature flag enabled.");
             }
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -83,7 +83,8 @@ internal void Validate()`
`83`	`83`	`if (IsFiltering && !AvailableFeaturesSingleton.Instance.PublishFilter)`
`84`	`84`	`{`
`85`	`85`	`throw new UnsupportedOperationException("Broker does not support filtering. You need " +`
`86`		`- "RabbitMQ 3.13.0 or later.");`
	`86`	`+ "RabbitMQ 3.13.0 or later and " +`
	`87`	`+ "the stream_filtering feature flag enabled.");`
`87`	`88`	`}`
`88`	`89`
`89`	`90`	`switch (ConsumerFilter)`
Original file line number	Diff line number	Diff line change
`@@ -45,7 +45,8 @@ internal void Validate()`
`45`	`45`	`if (Filter is { FilterValue: not null } && !AvailableFeaturesSingleton.Instance.PublishFilter)`
`46`	`46`	`{`
`47`	`47`	`throw new UnsupportedOperationException("Broker does not support filtering. " +`
`48`		`- "You need RabbitMQ 3.13.0 or later.");`
	`48`	`+ "You need RabbitMQ 3.13.0 or later and" +`
	`49`	`+ "the stream_filtering feature flag enabled.");`
`49`	`50`	`}`
`50`	`51`	`}`
`51`	`52`	`}`