Skip to content

Commit d72038a

Browse files
committed
Remove unused parameter from RabbitMQQuery ctor
1 parent 7b64f5f commit d72038a

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

src/ServiceControl.Transports.RabbitMQ/RabbitMQQuery.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ public class RabbitMQQuery : BrokerThroughputQuery
2727
.AddTimeout(TimeSpan.FromMinutes(2)) // Add timeout if it keeps failing
2828
.Build();
2929

30-
public RabbitMQQuery(ILogger<RabbitMQQuery> logger, TimeProvider timeProvider, TransportSettings transportSettings, ITransportCustomization transportCustomization) : base(logger, "RabbitMQ")
30+
public RabbitMQQuery(ILogger<RabbitMQQuery> logger, TimeProvider timeProvider, ITransportCustomization transportCustomization) : base(logger, "RabbitMQ")
3131
{
3232
this.logger = logger;
3333
this.timeProvider = timeProvider;

src/ServiceControl.Transports.RabbitMQClassicConventionalRouting.Tests/RabbitMQQueryTests.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ public async Task GetQueueNames_FindsQueues()
3636
var additionalQueues = Enumerable.Range(1, 10).Select(i => $"myqueue{i}").ToArray();
3737
await configuration.TransportCustomization.ProvisionQueues(transportSettings, additionalQueues);
3838

39-
var query = new RabbitMQQuery(NullLogger<RabbitMQQuery>.Instance, provider, transportSettings, configuration.TransportCustomization);
39+
var query = new RabbitMQQuery(NullLogger<RabbitMQQuery>.Instance, provider, configuration.TransportCustomization);
4040
query.Initialize(ReadOnlyDictionary<string, string>.Empty);
4141

4242
var queueNames = new List<IBrokerQueue>();

src/ServiceControl.Transports.RabbitMQQuorumDirectRouting.Tests/RabbitMQQueryTests.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ public async Task TestConnectionWithInvalidSettings()
3232

3333
configuration.TransportCustomization.CustomizePrimaryEndpoint(new EndpointConfiguration(transportSettings.EndpointName), transportSettings);
3434

35-
var query = new RabbitMQQuery(NullLogger<RabbitMQQuery>.Instance, provider, transportSettings, configuration.TransportCustomization);
35+
var query = new RabbitMQQuery(NullLogger<RabbitMQQuery>.Instance, provider, configuration.TransportCustomization);
3636
query.Initialize(ReadOnlyDictionary<string, string>.Empty);
3737

3838
(bool success, _, string diagnostics) = await query.TestConnection(cancellationTokenSource.Token);
@@ -56,7 +56,7 @@ public async Task TestConnectionWithValidSettings()
5656

5757
configuration.TransportCustomization.CustomizePrimaryEndpoint(new EndpointConfiguration(transportSettings.EndpointName), transportSettings);
5858

59-
var query = new RabbitMQQuery(NullLogger<RabbitMQQuery>.Instance, provider, transportSettings, configuration.TransportCustomization);
59+
var query = new RabbitMQQuery(NullLogger<RabbitMQQuery>.Instance, provider, configuration.TransportCustomization);
6060
query.Initialize(ReadOnlyDictionary<string, string>.Empty);
6161

6262
(bool success, _, string diagnostics) = await query.TestConnection(cancellationTokenSource.Token);
@@ -83,7 +83,7 @@ public async Task RunScenario()
8383

8484
await CreateTestQueue(transportSettings.EndpointName);
8585

86-
var query = new RabbitMQQuery(NullLogger<RabbitMQQuery>.Instance, provider, transportSettings, configuration.TransportCustomization);
86+
var query = new RabbitMQQuery(NullLogger<RabbitMQQuery>.Instance, provider, configuration.TransportCustomization);
8787
query.Initialize(ReadOnlyDictionary<string, string>.Empty);
8888

8989
var queueNames = new List<IBrokerQueue>();

0 commit comments

Comments
 (0)