Implement filters

Signed-off-by: Gabriele Santomaggio <[email protected]>

Author: Gsantomaggio

RabbitMQ.AMQP.Client/Consts.cs

@@ -23,17 +23,15 @@ public static class Consts
         /// The default virtual host, <c>/</c>
         /// </summary>
         public const string DefaultVirtualHost = "/";
-        
+
         // amqp:sql-filter
         private const string AmqpSqlFilter = "amqp:sql-filter";
         internal static readonly Symbol s_streamSqlFilterSymbol = new(AmqpSqlFilter);
         internal const string SqlFilter = "SqlFilter";
-        
+
         internal const string AmqpPropertiesFilter = "amqp:properties-filter";
-        internal  const string AmqpApplicationPropertiesFilter = "amqp:application-properties-filter";
-        
-        
-        
+        internal const string AmqpApplicationPropertiesFilter = "amqp:application-properties-filter";
+
         // sql-filter
         private const string RmqStreamFilter = "rabbitmq:stream-filter";
         private const string RmqStreamOffsetSpec = "rabbitmq:stream-offset-spec";
@@ -43,7 +41,5 @@ public static class Consts
         internal static readonly Symbol s_streamOffsetSpecSymbol = new(RmqStreamOffsetSpec);
         internal static readonly Symbol s_streamMatchUnfilteredSymbol = new(RmqStreamMatchUnfiltered);
 
-
-
     }
 }

RabbitMQ.AMQP.Client/IConsumerBuilder.cs

@@ -101,7 +101,6 @@ public interface IStreamOptions
             /// <see cref="FilterMatchUnfiltered(bool)"/>
             IStreamFilterOptions Filter();
 
-
             /// <summary>
             /// Return the consumer builder.
             /// </summary>
@@ -194,8 +193,7 @@ public interface IStreamFilterOptions
             /// <param name="value">application property value</param>
             /// <returns><see cref="IStreamFilterOptions"/></returns>
             IStreamFilterOptions PropertySymbol(string key, string value);
-            
-            
+
             /// <summary>
             /// <para>SQL filter expression.</para>
             ///
@@ -204,7 +202,6 @@ public interface IStreamFilterOptions
             /// Documentation: <see href="https://www.rabbitmq.com/docs/next/stream-filtering#sql-filter-expressions">SQL Filtering</see>
             IStreamFilterOptions Sql(string sql);
 
-
             /// <summary>
             /// Return the stream options.
             /// </summary>

RabbitMQ.AMQP.Client/Impl/AmqpConsumerBuilder.cs

@@ -113,7 +113,6 @@ public abstract class StreamOptions : IConsumerBuilder.IStreamOptions
         private static readonly Regex s_offsetValidator = new Regex("^[0-9]+[YMDhms]$",
             RegexOptions.Compiled | RegexOptions.CultureInvariant);
 
-
         private readonly Map _filters;
 
         protected StreamOptions(Map filters)
@@ -170,7 +169,6 @@ public IConsumerBuilder.IStreamOptions FilterMatchUnfiltered(bool matchUnfiltere
             return this;
         }
 
-
         public abstract IConsumerBuilder Builder();
 
         private void SetOffsetSpecificationFilter(object value)
@@ -256,7 +254,6 @@ public IConsumerBuilder.IStreamFilterOptions Sql(string sql)
                 throw new ArgumentNullException(nameof(sql));
             }
 
-
             _filters[Consts.SqlFilter] =
                 new DescribedValue(Consts.s_streamSqlFilterSymbol, sql);
             return this;
@@ -315,7 +312,6 @@ public IConsumerBuilder.IStreamFilterOptions PropertySymbol(string key, string v
         private StreamFilterOptions PropertyFilter(string propertyKey, object propertyValue)
         {
 
-
             DescribedValue propertiesFilterValue = Filter(Consts.AmqpPropertiesFilter);
             Map propertiesFilter = (Map)propertiesFilterValue.Value;
             // Note: you MUST use a symbol as the key
@@ -325,7 +321,7 @@ private StreamFilterOptions PropertyFilter(string propertyKey, object propertyVa
 
         private StreamFilterOptions ApplicationPropertyFilter(string propertyKey, object propertyValue)
         {
-           
+
             DescribedValue applicationPropertiesFilterValue = Filter(Consts.AmqpApplicationPropertiesFilter);
             Map applicationPropertiesFilter = (Map)applicationPropertiesFilterValue.Value;
             // Note: do NOT put a symbol as the key