Skip to content

Commit 6f2ed86

Browse files
committed
Remove multiple blank lines.
1 parent f80eb4e commit 6f2ed86

27 files changed

+0
-57
lines changed

RabbitMQ.AMQP.Client/ByteCapacity.cs

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@ private ByteCapacity(long bytes) : this(bytes, bytes.ToString())
2727
private const int GigabytesMultiplier = 1000 * 1000 * 1000;
2828
private const long TerabytesMultiplier = 1000L * 1000L * 1000L * 1000L;
2929

30-
3130
public static ByteCapacity B(long bytes)
3231
{
3332
return new ByteCapacity(bytes);
@@ -53,7 +52,6 @@ public static ByteCapacity Tb(long terabytes)
5352
return new ByteCapacity(terabytes * TerabytesMultiplier);
5453
}
5554

56-
5755
private static readonly Regex s_sizeRegex = new Regex(@"^(\d+)([kKmMgGtTpP]?[bB]?)$", RegexOptions.Compiled);
5856

5957
public static ByteCapacity From(string value)
@@ -82,7 +80,6 @@ public long ToBytes()
8280
return _bytes;
8381
}
8482

85-
8683
public bool Equals(ByteCapacity? other)
8784
{
8885
if (ReferenceEquals(null, other))

RabbitMQ.AMQP.Client/IConsumerBuilder.cs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,6 @@ public interface IConsumerBuilder
4040

4141
Task<IConsumer> BuildAndStartAsync(CancellationToken cancellationToken = default);
4242

43-
4443
public interface IStreamOptions
4544
{
4645
IStreamOptions Offset(long offset);
@@ -50,7 +49,6 @@ public interface IStreamOptions
5049
IConsumerBuilder Builder();
5150
}
5251

53-
5452
/// <summary>
5553
/// ListenerContext is a helper class that holds the contexts for the listener
5654
/// </summary>

RabbitMQ.AMQP.Client/IEntitiesInfo.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,6 @@ public interface IQueueInfo : IEntityInfo
3939
uint ConsumerCount();
4040
}
4141

42-
4342
public enum ExchangeType
4443
{
4544
DIRECT,

RabbitMQ.AMQP.Client/IManagement.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@ public BadRequestException(string message) : base(message)
2929
}
3030
}
3131

32-
3332
/// <summary>
3433
/// IManagement interface and is responsible for managing the AMQP resources.
3534
/// RabbitMQ uses AMQP end point: "/management" to manage the resources like queues, exchanges, and bindings.

RabbitMQ.AMQP.Client/IMessage.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ public interface IMessage
2424
string Subject();
2525
IMessage Subject(string subject);
2626

27-
2827
public IMessage Annotation(string key, object value);
2928

3029
public object Annotation(string key);

RabbitMQ.AMQP.Client/Impl/AmqpConnection.cs

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,6 @@ public class AmqpConnection : AbstractLifeCycle, IConnection
5050
private readonly TaskCompletionSource<bool> _connectionClosedTcs =
5151
new(TaskCreationOptions.RunContinuationsAsynchronously);
5252

53-
5453
/// <summary>
5554
/// Read-only collection of publishers.
5655
/// See <see cref="IPublisher"/>
@@ -61,7 +60,6 @@ public ReadOnlyCollection<IPublisher> GetPublishers()
6160
return Publishers.Values.ToList().AsReadOnly();
6261
}
6362

64-
6563
/// <summary>
6664
/// Read-only collection of consumers.
6765
/// See <see cref="IConsumer"/>
@@ -89,7 +87,6 @@ await connection.OpenAsync()
8987
return connection;
9088
}
9189

92-
9390
public IManagement Management()
9491
{
9592
return _management;

RabbitMQ.AMQP.Client/Impl/AmqpConsumer.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,6 @@ public override async Task OpenAsync()
5353
_configuration.ListenerContext?.Invoke(
5454
new IConsumerBuilder.ListenerContext(new ListenerStreamOptions(_configuration.Filters)));
5555

56-
5756
Attach attach = Utils.CreateAttach(_configuration.Address, DeliveryMode.AtLeastOnce, _id,
5857
_configuration.Filters);
5958

RabbitMQ.AMQP.Client/Impl/AmqpConsumerBuilder.cs

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -66,21 +66,18 @@ public IConsumerBuilder SubscriptionListener(Action<IConsumerBuilder.ListenerCon
6666
return this;
6767
}
6868

69-
7069
public IConsumerBuilder.IStreamOptions Stream()
7170
{
7271
return new ConsumerBuilderStreamOptions(this, _configuration.Filters);
7372
}
7473

75-
7674
public async Task<IConsumer> BuildAndStartAsync(CancellationToken cancellationToken = default)
7775
{
7876
if (_configuration.Handler is null)
7977
{
8078
throw new ConsumerException("Message handler is not set");
8179
}
8280

83-
8481
AmqpConsumer consumer = new(_configuration);
8582

8683
// TODO pass cancellationToken
@@ -91,7 +88,6 @@ await consumer.OpenAsync()
9188
}
9289
}
9390

94-
9591
/// <summary>
9692
/// The base class for the stream options.
9793
/// The class set the right filters used to create the consumer
@@ -144,7 +140,6 @@ public IConsumerBuilder.IStreamOptions FilterMatchUnfiltered(bool matchUnfiltere
144140
public abstract IConsumerBuilder Builder();
145141
}
146142

147-
148143
/// <summary>
149144
/// The stream options for the Subscribe Listener event.
150145
/// For the user perspective, it is used to set the stream options for the listener
@@ -177,7 +172,6 @@ public ConsumerBuilderStreamOptions(IConsumerBuilder consumerBuilder, Map filter
177172
_consumerBuilder = consumerBuilder;
178173
}
179174

180-
181175
public override IConsumerBuilder Builder()
182176
{
183177
return _consumerBuilder;

RabbitMQ.AMQP.Client/Impl/AmqpManagement.cs

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,6 @@ public IQueueSpecification Queue(string name)
7676
return Queue().Name(name);
7777
}
7878

79-
8079
/// <summary>
8180
/// Get the queue info for the given queue specification
8281
/// See <see cref="IQueueInfo"/> for more information
@@ -88,7 +87,6 @@ public Task<IQueueInfo> GetQueueInfoAsync(IQueueSpecification queueSpec,
8887
return GetQueueInfoAsync(queueSpec.QueueName, cancellationToken);
8988
}
9089

91-
9290
/// <summary>
9391
/// Get the queue info for the given queue name
9492
/// See <see cref="IQueueInfo"/> for more information
@@ -108,7 +106,6 @@ public async Task<IQueueInfo> GetQueueInfoAsync(string queueName,
108106
return new DefaultQueueInfo((Map)response.Body);
109107
}
110108

111-
112109
internal IQueueSpecification Queue(QueueSpec spec)
113110
{
114111
return Queue().Name(spec.QueueName)
@@ -117,7 +114,6 @@ internal IQueueSpecification Queue(QueueSpec spec)
117114
.Arguments(spec.QueueArguments);
118115
}
119116

120-
121117
/// <summary>
122118
/// Create a new AMQPExchange specification
123119
/// See <see cref="IExchangeSpecification"/> for more information
@@ -129,7 +125,6 @@ public IExchangeSpecification Exchange()
129125
return new AmqpExchangeSpecification(this);
130126
}
131127

132-
133128
/// <summary>
134129
///
135130
/// Create a new AMQPExchange specification with the given name

RabbitMQ.AMQP.Client/Impl/AmqpMessage.cs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@ public AmqpMessage()
2222
NativeMessage = new Message();
2323
}
2424

25-
2625
public AmqpMessage(object body)
2726
{
2827
NativeMessage = new Message(body);
@@ -46,7 +45,6 @@ private void EnsureProperties()
4645
NativeMessage.Properties ??= new Properties();
4746
}
4847

49-
5048
private void ThrowIfAnnotationsNotSet()
5149
{
5250
if (NativeMessage.MessageAnnotations == null)

0 commit comments

Comments
 (0)