Skip to content

Commit d7415fd

Browse files
abparticularabparticular
committed
Convert SC primary instance loggers to ILogger
1 parent 4f25d49 commit d7415fd

File tree

68 files changed

+549
-518
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

68 files changed

+549
-518
lines changed

‎src/ServiceControl.AcceptanceTests.RavenDB/StartupModeTests.cs‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
using System.Threading.Tasks;
66
using Hosting.Commands;
77
using Microsoft.Extensions.Hosting;
8+
using Microsoft.Extensions.Logging.Abstractions;
89
using NServiceBus;
910
using NUnit.Framework;
1011
using Particular.ServiceControl.Hosting;
@@ -57,7 +58,7 @@ public async Task CanRunMaintenanceMode()
5758
public async Task CanRunImportFailedMessagesMode()
5859
=> await new TestableImportFailedErrorsCommand().Execute(new HostArguments(Array.Empty<string>()), settings);
5960

60-
class TestableImportFailedErrorsCommand : ImportFailedErrorsCommand
61+
class TestableImportFailedErrorsCommand() : ImportFailedErrorsCommand(NullLogger<ImportFailedErrorsCommand>.Instance)
6162
{
6263
protected override EndpointConfiguration CreateEndpointConfiguration(Settings settings)
6364
{

‎src/ServiceControl.AcceptanceTests/Recoverability/MessageFailures/When_a_retry_fails_to_be_sent.cs‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88
using AcceptanceTesting.EndpointTemplates;
99
using Infrastructure;
1010
using Microsoft.Extensions.DependencyInjection;
11+
using Microsoft.Extensions.Logging.Abstractions;
1112
using NServiceBus;
1213
using NServiceBus.AcceptanceTesting;
1314
using NServiceBus.Routing;
@@ -146,7 +147,7 @@ public class MyContext : ScenarioContext
146147
public class MessageThatWillFail : ICommand;
147148

148149
public class FakeReturnToSender(IErrorMessageDataStore errorMessageStore, MyContext myContext)
149-
: ReturnToSender(errorMessageStore)
150+
: ReturnToSender(errorMessageStore, NullLogger<ReturnToSender>.Instance)
150151
{
151152
public override Task HandleMessage(MessageContext message, IMessageDispatcher sender, string errorQueueTransportAddress, CancellationToken cancellationToken = default)
152153
{

‎src/ServiceControl.AcceptanceTests/TestSupport/ServiceControlComponentRunner.cs‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
using Microsoft.AspNetCore.TestHost;
1616
using Microsoft.Extensions.DependencyInjection;
1717
using Microsoft.Extensions.Hosting;
18+
using Microsoft.Extensions.Logging.Abstractions;
1819
using NLog;
1920
using NServiceBus;
2021
using NServiceBus.AcceptanceTesting;
@@ -102,7 +103,7 @@ async Task InitializeServiceControl(ScenarioContext context)
102103

103104
using (new DiagnosticTimer($"Creating infrastructure for {instanceName}"))
104105
{
105-
var setupCommand = new SetupCommand();
106+
var setupCommand = new SetupCommand(NullLogger<SetupCommand>.Instance);
106107
await setupCommand.Execute(new HostArguments([]), settings);
107108
}
108109

‎src/ServiceControl.Persistence.Tests/MonitoringDataStoreTests.cs‎

Lines changed: 10 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
using System;
44
using System.Linq;
55
using System.Threading.Tasks;
6+
using Microsoft.Extensions.Logging.Abstractions;
67
using NUnit.Framework;
78
using ServiceControl.Monitoring;
89
using ServiceControl.Operations;
@@ -13,7 +14,7 @@ class MonitoringDataStoreTests : PersistenceTestBase
1314
[Test]
1415
public async Task Endpoints_load_from_dataStore_into_monitor()
1516
{
16-
var endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents());
17+
var endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents(), NullLogger<EndpointInstanceMonitor>.Instance);
1718
var endpoint1 = new EndpointDetails() { HostId = Guid.NewGuid(), Host = "Host1", Name = "Name1" };
1819
await MonitoringDataStore.CreateIfNotExists(endpoint1);
1920

@@ -26,7 +27,7 @@ public async Task Endpoints_load_from_dataStore_into_monitor()
2627
[Test]
2728
public async Task Endpoints_added_more_than_once_are_treated_as_same_endpoint()
2829
{
29-
var endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents());
30+
var endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents(), NullLogger<EndpointInstanceMonitor>.Instance);
3031
var endpoint1 = new EndpointDetails() { HostId = Guid.NewGuid(), Host = "Host1", Name = "Name1" };
3132
await MonitoringDataStore.CreateIfNotExists(endpoint1);
3233
await MonitoringDataStore.CreateIfNotExists(endpoint1);
@@ -40,7 +41,7 @@ public async Task Endpoints_added_more_than_once_are_treated_as_same_endpoint()
4041
[Test]
4142
public async Task Updating_existing_endpoint_does_not_create_new_ones()
4243
{
43-
var endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents());
44+
var endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents(), NullLogger<EndpointInstanceMonitor>.Instance);
4445
var endpoint1 = new EndpointDetails() { HostId = Guid.NewGuid(), Host = "Host1", Name = "Name1" };
4546
await MonitoringDataStore.CreateIfNotExists(endpoint1);
4647
await MonitoringDataStore.CreateOrUpdate(endpoint1, endpointInstanceMonitoring);
@@ -54,7 +55,7 @@ public async Task Updating_existing_endpoint_does_not_create_new_ones()
5455
[Test]
5556
public async Task Endpoint_is_created_if_doesnt_exist()
5657
{
57-
var endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents());
58+
var endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents(), NullLogger<EndpointInstanceMonitor>.Instance);
5859
var endpoint1 = new EndpointDetails() { HostId = Guid.NewGuid(), Host = "Host1", Name = "Name1" };
5960
var endpoint2 = new EndpointDetails() { HostId = Guid.NewGuid(), Host = "Host2", Name = "Name2" };
6061
await MonitoringDataStore.CreateIfNotExists(endpoint1);
@@ -69,7 +70,7 @@ public async Task Endpoint_is_created_if_doesnt_exist()
6970
[Test]
7071
public async Task Endpoint_is_created_if_doesnt_exist_on_update()
7172
{
72-
var endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents());
73+
var endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents(), NullLogger<EndpointInstanceMonitor>.Instance);
7374
var endpoint1 = new EndpointDetails() { HostId = Guid.NewGuid(), Host = "Host1", Name = "Name1" };
7475
var endpoint2 = new EndpointDetails() { HostId = Guid.NewGuid(), Host = "Host2", Name = "Name2" };
7576
await MonitoringDataStore.CreateIfNotExists(endpoint1);
@@ -84,7 +85,7 @@ public async Task Endpoint_is_created_if_doesnt_exist_on_update()
8485
[Test]
8586
public async Task Endpoint_is_updated()
8687
{
87-
var endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents());
88+
var endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents(), NullLogger<EndpointInstanceMonitor>.Instance);
8889
var endpoint1 = new EndpointDetails() { HostId = Guid.NewGuid(), Host = "Host1", Name = "Name1" };
8990
await MonitoringDataStore.CreateIfNotExists(endpoint1);
9091

@@ -93,7 +94,7 @@ public async Task Endpoint_is_updated()
9394
Assert.That(endpointInstanceMonitoring.IsMonitored(endpointInstanceMonitoring.GetEndpoints()[0].Id), Is.False);
9495

9596
await MonitoringDataStore.UpdateEndpointMonitoring(endpoint1, true);
96-
endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents());
97+
endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents(), NullLogger<EndpointInstanceMonitor>.Instance);
9798

9899
CompleteDatabaseOperation();
99100
await MonitoringDataStore.WarmupMonitoringFromPersistence(endpointInstanceMonitoring);
@@ -104,7 +105,7 @@ public async Task Endpoint_is_updated()
104105
[Test]
105106
public async Task Endpoint_is_deleted()
106107
{
107-
var endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents());
108+
var endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents(), NullLogger<EndpointInstanceMonitor>.Instance);
108109
var endpoint1 = new EndpointDetails() { HostId = Guid.NewGuid(), Host = "Host1", Name = "Name1" };
109110
await MonitoringDataStore.CreateIfNotExists(endpoint1);
110111

@@ -114,7 +115,7 @@ public async Task Endpoint_is_deleted()
114115

115116
await MonitoringDataStore.Delete(endpointInstanceMonitoring.GetEndpoints()[0].Id);
116117

117-
endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents());
118+
endpointInstanceMonitoring = new EndpointInstanceMonitoring(new FakeDomainEvents(), NullLogger<EndpointInstanceMonitor>.Instance);
118119

119120
CompleteDatabaseOperation();
120121
await MonitoringDataStore.WarmupMonitoringFromPersistence(endpointInstanceMonitoring);

‎src/ServiceControl.Persistence.Tests/Recoverability/ReturnToSenderDequeuerTests.cs‎

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010
using MessageFailures;
1111
using MessageFailures.Api;
1212
using Microsoft.Extensions.DependencyInjection;
13+
using Microsoft.Extensions.Logging.Abstractions;
1314
using NServiceBus.Extensibility;
1415
using NServiceBus.Transport;
1516
using NUnit.Framework;
@@ -47,7 +48,7 @@ public async Task It_removes_staging_id_header()
4748
};
4849
var message = CreateMessage(Guid.NewGuid().ToString(), headers);
4950

50-
await new ReturnToSender(null).HandleMessage(message, sender, "error");
51+
await new ReturnToSender(null, NullLogger<ReturnToSender>.Instance).HandleMessage(message, sender, "error");
5152

5253
Assert.That(sender.Message.Headers.ContainsKey("ServiceControl.Retry.StagingId"), Is.False);
5354
}
@@ -66,7 +67,7 @@ public async Task It_fetches_the_body_from_storage_if_provided()
6667
};
6768
var message = CreateMessage(Guid.NewGuid().ToString(), headers);
6869

69-
await new ReturnToSender(new FakeErrorMessageDataStore()).HandleMessage(message, sender, "error");
70+
await new ReturnToSender(new FakeErrorMessageDataStore(), NullLogger<ReturnToSender>.Instance).HandleMessage(message, sender, "error");
7071

7172
Assert.That(Encoding.UTF8.GetString(sender.Message.Body.ToArray()), Is.EqualTo("MessageBodyId"));
7273
}
@@ -84,7 +85,7 @@ public async Task It_uses_retry_to_if_provided()
8485
};
8586
var message = CreateMessage(Guid.NewGuid().ToString(), headers);
8687

87-
await new ReturnToSender(null).HandleMessage(message, sender, "error");
88+
await new ReturnToSender(null, NullLogger<ReturnToSender>.Instance).HandleMessage(message, sender, "error");
8889

8990
Assert.Multiple(() =>
9091
{
@@ -105,7 +106,7 @@ public async Task It_sends_directly_to_target_if_retry_to_is_not_provided()
105106
};
106107
var message = CreateMessage(Guid.NewGuid().ToString(), headers);
107108

108-
await new ReturnToSender(null).HandleMessage(message, sender, "error");
109+
await new ReturnToSender(null, NullLogger<ReturnToSender>.Instance).HandleMessage(message, sender, "error");
109110

110111
Assert.Multiple(() =>
111112
{
@@ -129,7 +130,7 @@ public async Task It_restores_body_id_and_target_addres_after_failure()
129130

130131
try
131132
{
132-
await new ReturnToSender(null).HandleMessage(message, sender, "error");
133+
await new ReturnToSender(null, NullLogger<ReturnToSender>.Instance).HandleMessage(message, sender, "error");
133134
}
134135
catch (Exception)
135136
{

0 commit comments

Comments
 (0)