Change stream filter prefix

rabbitmq/rabbitmq-server#12919
rabbitmq · Dec 13, 2024 · a2a24b4 · a2a24b4
1 parent 16c54d6
commit a2a24b4
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());