File tree Expand file tree Collapse file tree 2 files changed +6
-2
lines changed
src/main/java/com/rabbitmq/stream/impl Expand file tree Collapse file tree 2 files changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -76,7 +76,9 @@ class StreamConsumer implements Consumer {
7676 ConsumerUpdateListener consumerUpdateListener ,
7777 ConsumerFlowStrategy flowStrategy ) {
7878 if (Utils .filteringEnabled (subscriptionProperties ) && !environment .filteringSupported ()) {
79- throw new IllegalArgumentException ("Filtering is not supported by the broker" );
79+ throw new IllegalArgumentException (
80+ "Filtering is not supported by the broker "
81+ + "(requires RabbitMQ 3.13+ and stream_filtering feature flag activated" );
8082 }
8183 this .id = ID_SEQUENCE .getAndIncrement ();
8284 Runnable trackingClosingCallback ;
Original file line number Diff line number Diff line change @@ -95,7 +95,9 @@ class StreamProducer implements Producer {
9595 Function <Message , String > filterValueExtractor ,
9696 StreamEnvironment environment ) {
9797 if (filterValueExtractor != null && !environment .filteringSupported ()) {
98- throw new IllegalArgumentException ("Filtering is not supported by the broker" );
98+ throw new IllegalArgumentException (
99+ "Filtering is not supported by the broker "
100+ + "(requires RabbitMQ 3.13+ and stream_filtering feature flag activated" );
99101 }
100102 this .id = ID_SEQUENCE .getAndIncrement ();
101103 this .environment = environment ;
You can’t perform that action at this time.
0 commit comments