fixup

lukebakken · lukebakken · commit 141c4b5a94ad · 2024-11-01T15:05:56.000-07:00
diff --git a/RabbitMQ.AMQP.Client/Impl/AmqpConsumerBuilder.cs b/RabbitMQ.AMQP.Client/Impl/AmqpConsumerBuilder.cs
@@ -139,6 +139,9 @@ public IConsumerBuilder.IStreamOptions Offset(string interval)
 
         public IConsumerBuilder.IStreamOptions FilterValue(string value)
         {
+            // Note:
+            // The value must implement IList for AMQP.NET to serialized it
+            // as expected.
             var values = new List<string> { value };
             _filters[s_streamFilterSymbol] =
                 new DescribedValue(s_streamFilterSymbol, values);

Original file line number	Diff line number	Diff line change
`@@ -139,6 +139,9 @@ public IConsumerBuilder.IStreamOptions Offset(string interval)`
`139`	`139`
`140`	`140`	`public IConsumerBuilder.IStreamOptions FilterValue(string value)`
`141`	`141`	`{`
	`142`	`+ // Note:`
	`143`	`+ // The value must implement IList for AMQP.NET to serialized it`
	`144`	`+ // as expected.`
`142`	`145`	`var values = new List<string> { value };`
`143`	`146`	`_filters[s_streamFilterSymbol] =`
`144`	`147`	`new DescribedValue(s_streamFilterSymbol, values);`