Skip to content

Commit 61c4e4c

Browse files
committed
Mention filtering requires RabbitMQ 3.13+
1 parent a22d8ad commit 61c4e4c

File tree

3 files changed

+11
-1
lines changed

3 files changed

+11
-1
lines changed

src/docs/asciidoc/advanced-topics.adoc

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,8 @@
44

55
==== Filtering
66

7+
WARNING: Filtering requires *RabbitMQ 3.13* or more.
8+
79
RabbitMQ Stream provides a server-side filtering feature that avoids reading all the messages of a stream and filtering only on the client side.
810
This helps to save network bandwidth when a consuming application needs only a subset of messages, e.g. the messages from a given geographical region.
911

src/main/java/com/rabbitmq/stream/ConsumerBuilder.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -155,6 +155,8 @@ public interface ConsumerBuilder {
155155
/**
156156
* Configure the filtering.
157157
*
158+
* <p>RabbitMQ 3.13 or more is required.
159+
*
158160
* @return the filtering configuration
159161
*/
160162
FilterConfiguration filter();
@@ -251,7 +253,11 @@ interface FlowConfiguration {
251253
ConsumerBuilder builder();
252254
}
253255

254-
/** Filter configuration. */
256+
/**
257+
* Filter configuration.
258+
*
259+
* <p>RabbitMQ 3.13 or more is required.
260+
*/
255261
interface FilterConfiguration {
256262

257263
/**

src/main/java/com/rabbitmq/stream/ProducerBuilder.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -135,6 +135,8 @@ public interface ProducerBuilder {
135135
/**
136136
* Logic to extract a filter value from a message.
137137
*
138+
* <p>RabbitMQ 3.13 or more is required.
139+
*
138140
* @param filterValueExtractor
139141
* @return this builder instance
140142
*/

0 commit comments

Comments
 (0)