Clean up warnings

Author: Havret

src/ActiveMQ.Artemis.Client/Consumer.cs

@@ -28,7 +28,7 @@ public Consumer(ILoggerFactory loggerFactory, ReceiverLink receiverLink, Transac
             var channel = Channel.CreateBounded<Message>(configuration.Credit);
             _reader = channel.Reader;
             _writer = channel.Writer;
-            _receiverLink.Start(configuration.Credit, (receiver, m) =>
+            _receiverLink.Start(configuration.Credit, (_, m) =>
             {
                 var message = new Message(m);
                 if (_writer.TryWrite(message))

src/ActiveMQ.Artemis.Client/Management/RpcClient.cs

@@ -24,7 +24,7 @@ public RpcClient(SenderLink senderLink, ReceiverLink receiverLink, string replyT
             _receiverLink = receiverLink;
             _replyToAddress = replyToAddress;
 
-            _receiverLink.Start(200, (receiver, msg) =>
+            _receiverLink.Start(200, (_, msg) =>
             {
                 var message = new Message(msg);
                 var correlationId = message.GetCorrelationId<Guid>();

test/ActiveMQ.Artemis.Client.UnitTests/ActiveMQNetSpec.cs

@@ -77,7 +77,7 @@ protected static TestContainerHost CreateContainerHostThatWillNeverSendAttachFra
             var linkProcessor = host.CreateTestLinkProcessor();
 
             // do not complete link attachment, as a result no Attach frame will be sent back to the client
-            linkProcessor.SetHandler(context => true);
+            linkProcessor.SetHandler(_ => true);
 
             return host;
         }
@@ -87,7 +87,7 @@ protected static async Task DisposeHostAndWaitUntilConnectionNotified(TestContai
             var tcs = new TaskCompletionSource<bool>();
             using var cts = new CancellationTokenSource(Timeout);
             cts.Token.Register(() => tcs.TrySetCanceled());
-            connection.ConnectionClosed += (sender, args) =>
+            connection.ConnectionClosed += (_, _) =>
             {
                 tcs.TrySetResult(true);
             };
@@ -100,7 +100,7 @@ protected static async Task WaitUntilConnectionRecovered(IConnection connection)
             var tcs = new TaskCompletionSource<bool>();
             using var cts = new CancellationTokenSource(Timeout);
             cts.Token.Register(() => tcs.TrySetCanceled());
-            connection.ConnectionRecovered += (sender, args) =>
+            connection.ConnectionRecovered += (_, _) =>
             {
                 tcs.TrySetResult(true);
             };

test/ActiveMQ.Artemis.Client.UnitTests/AutoRecovering/AutoRecoveringConnectionSpec.cs

@@ -137,7 +137,7 @@ public async Task Should_trigger_ConnectionRecovered_when_connection_recovered()
 
             var connectionRecovered = new AutoResetEvent(false);
             Endpoint fallbackEndpoint = null;
-            connection.ConnectionRecovered += (sender, args) =>
+            connection.ConnectionRecovered += (_, args) =>
             {
                 fallbackEndpoint = args.Endpoint;
                 connectionRecovered.Set();
@@ -165,7 +165,7 @@ public async Task Should_trigger_ConnectionRecoveryError_when_connection_recover
 
             var connectionRecoveryFailed = new AutoResetEvent(false);
             Exception connectionRecoveryError = null;
-            connection.ConnectionRecoveryError += (sender, args) =>
+            connection.ConnectionRecoveryError += (_, args) =>
             {
                 connectionRecoveryError = args.Exception;
                 connectionRecoveryFailed.Set();

test/ActiveMQ.Artemis.Client.UnitTests/AutoRecovering/AutoRecoveringConsumerSpec.cs

@@ -289,7 +289,7 @@ public async Task Should_not_recreate_disposed_consumers()
             var host1 = CreateOpenedContainerHost(endpoint, testHandler);
 
             var connection = await CreateConnection(endpoint);
-            connection.ConnectionRecovered += (sender, args) => connectionRecovered.Set();
+            connection.ConnectionRecovered += (_, _) => connectionRecovered.Set();
             var consumer = await connection.CreateConsumerAsync("a1", RoutingType.Anycast);
 
             Assert.True(consumerAttached.WaitOne(Timeout));

test/ActiveMQ.Artemis.Client.UnitTests/AutoRecovering/AutoRecoveringProducerSpec.cs

@@ -121,7 +121,7 @@ public async Task Should_be_able_to_Send_message_when_Send_invoked_before_connec
 
             var connectionClosed = new ManualResetEvent(false);
             var connection = await CreateConnection(endpoint);
-            connection.ConnectionClosed += (_, args) => connectionClosed.Set();
+            connection.ConnectionClosed += (_, _) => connectionClosed.Set();
 
             var producer = await connection.CreateProducerAsync("a1", RoutingType.Anycast);
 

test/ActiveMQ.Artemis.Client.UnitTests/ProducerSendMessageSpec.cs

@@ -83,7 +83,7 @@ public async Task Should_be_able_to_cancel_SendAsync_when_no_outcome_from_remote
 
             // do not send outcome from a remote peer
             // as a result send should timeout
-            messageProcessor.SetHandler(context => true);
+            messageProcessor.SetHandler(_ => true);
 
             await using var connection = await CreateConnection(endpoint);
             var producer = await connection.CreateProducerAsync("a1", RoutingType.Anycast);

test/ActiveMQ.Artemis.Client.UnitTests/Utils/TestContainerHost.cs

@@ -13,7 +13,7 @@ public TestContainerHost(Endpoint endpoint, IHandler handler = null)
         {
             Endpoint = endpoint;            
             _host = new ContainerHost(endpoint.Address);
-            _host.Listeners[0].HandlerFactory = listener => handler;
+            _host.Listeners[0].HandlerFactory = _ => handler;
             _linkProcessor = new TestLinkProcessor();
             _host.RegisterLinkProcessor(_linkProcessor);
         }