formatting

Tornhoof · Tornhoof · commit 8f4dd6471eaf · 2024-07-09T13:34:48.000+02:00
diff --git a/projects/Benchmarks/ConsumerDispatching/AsyncBasicConsumerFake.cs b/projects/Benchmarks/ConsumerDispatching/AsyncBasicConsumerFake.cs
@@ -18,8 +18,7 @@ public AsyncBasicConsumerFake(ManualResetEventSlim autoResetEvent)
             _autoResetEvent = autoResetEvent;
         }
 
-        public Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange,
-            string routingKey,
+        public Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey,
             IReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)
         {
             if (Interlocked.Increment(ref _current) == Count)
@@ -30,8 +29,7 @@ public Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redel
             return Task.CompletedTask;
         }
 
-        Task IBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered,
-            string exchange, string routingKey,
+        Task IBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey,
             IReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)
         {
             if (Interlocked.Increment(ref _current) == Count)
diff --git a/projects/RabbitMQ.Client/client/events/AsyncEventingBasicConsumer.cs b/projects/RabbitMQ.Client/client/events/AsyncEventingBasicConsumer.cs
@@ -76,8 +76,7 @@ await base.HandleBasicConsumeOk(consumerTag)
         }
 
         ///<summary>Fires the Received event.</summary>
-        public override Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered,
-            string exchange, string routingKey,
+        public override Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey,
             IReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)
         {
             var deliverEventArgs = new BasicDeliverEventArgs(consumerTag, deliveryTag, redelivered, exchange, routingKey, properties, body);
diff --git a/projects/RabbitMQ.Client/client/events/EventingBasicConsumer.cs b/projects/RabbitMQ.Client/client/events/EventingBasicConsumer.cs
@@ -86,8 +86,7 @@ public override void HandleBasicConsumeOk(string consumerTag)
         /// Accessing the body at a later point is unsafe as its memory can
         /// be already released.
         /// </remarks>
-        public override async Task HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered,
-            string exchange, string routingKey,
+        public override async Task HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey,
             IReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)
         {
             BasicDeliverEventArgs eventArgs = new BasicDeliverEventArgs(consumerTag, deliveryTag, redelivered, exchange, routingKey, properties, body);
diff --git a/projects/RabbitMQ.Client/client/impl/ConsumerDispatching/FallbackConsumer.cs b/projects/RabbitMQ.Client/client/impl/ConsumerDispatching/FallbackConsumer.cs
@@ -37,8 +37,7 @@ void IBasicConsumer.HandleBasicConsumeOk(string consumerTag)
             ESLog.Info($"Unhandled {nameof(IBasicConsumer.HandleBasicConsumeOk)} for tag {consumerTag}");
         }
 
-        Task IBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered,
-            string exchange, string routingKey,
+        Task IBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey,
             IReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)
         {
             ESLog.Info($"Unhandled {nameof(IBasicConsumer.HandleBasicDeliverAsync)} for tag {consumerTag}");
@@ -68,8 +67,7 @@ Task IAsyncBasicConsumer.HandleBasicConsumeOk(string consumerTag)
             return Task.CompletedTask;
         }
 
-        Task IAsyncBasicConsumer.HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered,
-            string exchange, string routingKey,
+        Task IAsyncBasicConsumer.HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey,
             IReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)
         {
             return ((IBasicConsumer)this).HandleBasicDeliverAsync(consumerTag, deliveryTag, redelivered, exchange, routingKey, properties, body);

Original file line number	Diff line number	Diff line change
`@@ -18,8 +18,7 @@ public AsyncBasicConsumerFake(ManualResetEventSlim autoResetEvent)`
`18`	`18`	`_autoResetEvent = autoResetEvent;`
`19`	`19`	`}`
`20`	`20`
`21`		`- public Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange,`
`22`		`- string routingKey,`
	`21`	`+ public Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey,`
`23`	`22`	`IReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)`
`24`	`23`	`{`
`25`	`24`	`if (Interlocked.Increment(ref _current) == Count)`
`@@ -30,8 +29,7 @@ public Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redel`
`30`	`29`	`return Task.CompletedTask;`
`31`	`30`	`}`
`32`	`31`
`33`		`- Task IBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered,`
`34`		`- string exchange, string routingKey,`
	`32`	`+ Task IBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey,`
`35`	`33`	`IReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)`
`36`	`34`	`{`
`37`	`35`	`if (Interlocked.Increment(ref _current) == Count)`
Original file line number	Diff line number	Diff line change
`@@ -76,8 +76,7 @@ await base.HandleBasicConsumeOk(consumerTag)`
`76`	`76`	`}`
`77`	`77`
`78`	`78`	`///<summary>Fires the Received event.</summary>`
`79`		`- public override Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered,`
`80`		`- string exchange, string routingKey,`
	`79`	`+ public override Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey,`
`81`	`80`	`IReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)`
`82`	`81`	`{`
`83`	`82`	`var deliverEventArgs = new BasicDeliverEventArgs(consumerTag, deliveryTag, redelivered, exchange, routingKey, properties, body);`
Original file line number	Diff line number	Diff line change
`@@ -37,8 +37,7 @@ void IBasicConsumer.HandleBasicConsumeOk(string consumerTag)`
`37`	`37`	`ESLog.Info($"Unhandled {nameof(IBasicConsumer.HandleBasicConsumeOk)} for tag {consumerTag}");`
`38`	`38`	`}`
`39`	`39`
`40`		`- Task IBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered,`
`41`		`- string exchange, string routingKey,`
	`40`	`+ Task IBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey,`
`42`	`41`	`IReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)`
`43`	`42`	`{`
`44`	`43`	`ESLog.Info($"Unhandled {nameof(IBasicConsumer.HandleBasicDeliverAsync)} for tag {consumerTag}");`
`@@ -68,8 +67,7 @@ Task IAsyncBasicConsumer.HandleBasicConsumeOk(string consumerTag)`
`68`	`67`	`return Task.CompletedTask;`
`69`	`68`	`}`
`70`	`69`
`71`		`- Task IAsyncBasicConsumer.HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered,`
`72`		`- string exchange, string routingKey,`
	`70`	`+ Task IAsyncBasicConsumer.HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey,`
`73`	`71`	`IReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)`
`74`	`72`	`{`
`75`	`73`	`return ((IBasicConsumer)this).HandleBasicDeliverAsync(consumerTag, deliveryTag, redelivered, exchange, routingKey, properties, body);`