Skip to content

Commit d287c4f

Browse files
committed
Change filter string modifier to &
According to the spec. References rabbitmq/rabbitmq-server#12919
1 parent 07f798a commit d287c4f

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/test/java/com/rabbitmq/client/amqp/impl/SourceFiltersTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -314,7 +314,7 @@ void filterExpressionApplicationProperties() {
314314
msgs = consume(messageCount * 3, options -> options.property("foo", "bar"));
315315
msgs.forEach(m -> assertThat(m).hasProperty("foo", "bar"));
316316

317-
msgs = consume(messageCount * 4, options -> options.property("foo", "$p:b"));
317+
msgs = consume(messageCount * 4, options -> options.property("foo", "&p:b"));
318318
assertThat(msgs).allMatch(m -> m.property("foo").toString().startsWith("b"));
319319

320320
msgs = consume(messageCount, options -> options.propertySymbol("foo", "symbol"));
@@ -457,10 +457,10 @@ void filterExpressionStringModifier() {
457457
publish(1, m -> m.subject("foo bar"));
458458
publish(1, m -> m.subject("ab 12"));
459459

460-
List<Message> msgs = consume(2, m -> m.subject("$p:ab"));
460+
List<Message> msgs = consume(2, m -> m.subject("&p:ab"));
461461
msgs.forEach(m -> assertThat(m.subject()).startsWith("ab"));
462462

463-
msgs = consume(1, m -> m.subject("$s:bar"));
463+
msgs = consume(1, m -> m.subject("&s:bar"));
464464
msgs.forEach(m -> assertThat(m).hasSubject("foo bar"));
465465
}
466466

0 commit comments

Comments
 (0)