File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
src/main/java/com/rabbitmq/client/amqp/impl Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -115,9 +115,6 @@ public Consumer build() {
115
115
if (this .messageHandler == null ) {
116
116
throw new IllegalArgumentException ("Message handler cannot be null" );
117
117
}
118
-
119
- // TODO validate stream (filtering) configuration
120
-
121
118
return this .connection .createConsumer (this );
122
119
}
123
120
@@ -167,6 +164,9 @@ public StreamOptions offset(String interval) {
167
164
168
165
@ Override
169
166
public StreamOptions filterValues (String ... values ) {
167
+ if (values == null || values .length == 0 ) {
168
+ throw new IllegalArgumentException ("At least one stream filter value must specified" );
169
+ }
170
170
this .filters .put ("rabbitmq:stream-filter" , Arrays .asList (values ));
171
171
return this ;
172
172
}
You can’t perform that action at this time.
0 commit comments