From a2a24b4ec0cb43b7e9163eb5c8ef6dc2048d0d0f Mon Sep 17 00:00:00 2001 From: Luke Bakken Date: Wed, 11 Dec 2024 07:44:16 -0800 Subject: [PATCH] Change stream filter prefix https://github.com/rabbitmq/rabbitmq-server/pull/12919 --- Tests/Consumer/StreamConsumerTests.cs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/Tests/Consumer/StreamConsumerTests.cs b/Tests/Consumer/StreamConsumerTests.cs index a4286de..b5fd8b4 100644 --- a/Tests/Consumer/StreamConsumerTests.cs +++ b/Tests/Consumer/StreamConsumerTests.cs @@ -647,7 +647,7 @@ public async Task FilterExpressionApplicationProperties() Assert.Equal(expected6, (string)m.Property("foo")); } - msgs = await ConsumeAsync(messageCount * 4, options => options.Property("foo", "$p:b")); + msgs = await ConsumeAsync(messageCount * 4, options => options.Property("foo", "&p:b")); foreach (IMessage m in msgs) { Assert.StartsWith("b", (string)m.Property("foo")); @@ -949,13 +949,13 @@ public async Task FilterExpressionStringModifier() await PublishAsync(q, 1, (_, msg) => msg.Subject("foo bar")); await PublishAsync(q, 1, (_, msg) => msg.Subject("ab 12")); - IEnumerable msgs = await ConsumeAsync(2, options => options.Subject("$p:ab")); + IEnumerable msgs = await ConsumeAsync(2, options => options.Subject("&p:ab")); foreach (IMessage m in msgs) { Assert.StartsWith("ab", m.Subject()); } - msgs = await ConsumeAsync(1, options => options.Subject("$s:bar")); + msgs = await ConsumeAsync(1, options => options.Subject("&s:bar")); foreach (IMessage m in msgs) { Assert.Equal("foo bar", m.Subject());