File tree Expand file tree Collapse file tree 3 files changed +1
-4
lines changed Expand file tree Collapse file tree 3 files changed +1
-4
lines changed Original file line number Diff line number Diff line change @@ -101,15 +101,14 @@ public interface IStreamOptions
101101 /// <see cref="FilterMatchUnfiltered(bool)"/>
102102 IStreamFilterOptions Filter ( ) ;
103103
104-
105104 /// <summary>
106105 /// <para>SQL filter expression.</para>
107106 ///
108107 /// </summary>
109108 /// <para>Requires RabbitMQ 4.2 or more.</para>
110109 /// Documentation: <see href="https://www.rabbitmq.com/docs/next/stream-filtering#sql-filter-expressions">SQL Filtering</see>
111110 IStreamFilterOptions Sql ( string sql ) ;
112-
111+
113112 /// <summary>
114113 /// Return the consumer builder.
115114 /// </summary>
Original file line number Diff line number Diff line change @@ -260,7 +260,6 @@ protected override void Dispose(bool disposing)
260260
261261 internal Connection ? NativeConnection => _nativeConnection ;
262262
263-
264263 // TODO this couples AmqpConnection with AmqpPublisher, yuck
265264 internal void AddPublisher ( Guid id , IPublisher consumer )
266265 {
Original file line number Diff line number Diff line change @@ -117,7 +117,6 @@ public abstract class StreamOptions : IConsumerBuilder.IStreamOptions
117117 // amqp:sql-filter
118118 private const string AmqpSqlFilter = "amqp:sql-filter" ;
119119
120-
121120 private static readonly Symbol s_streamFilterSymbol = new ( RmqStreamFilter ) ;
122121 private static readonly Symbol s_streamOffsetSpecSymbol = new ( RmqStreamOffsetSpec ) ;
123122 private static readonly Symbol s_streamMatchUnfilteredSymbol = new ( RmqStreamMatchUnfiltered ) ;
You can’t perform that action at this time.
0 commit comments