Merge pull request #99 from rabbitmq/rabbitmq-server-12919

Change stream filter prefix
rabbitmq · Dec 13, 2024 · 8202d00 · 8202d00
2 parents 16c54d6 + a2a24b4
commit 8202d00
Showing 1 changed file with 3 additions and 3 deletions.
diff --git 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<IMessage> msgs = await ConsumeAsync(2, options => options.Subject("$p:ab"));
+        IEnumerable<IMessage> 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());