Skip to content

Commit 82e3ae7

Browse files
tiksntiksn
authored
Merge pull request #1009 from fossa-app/event-hander-trace-and-metrics
feat: Add event bus handlers for company, branch, department, and employee creation and update events.
2 parents 2e1f03a + f8925e1 commit 82e3ae7

10 files changed

Lines changed: 90 additions & 27 deletions

‎src/API.Infrastructure/Messages/Events/BranchCreatedEventBusHandler.cs‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
1-
using Fossa.API.Core.Messages.Events;
1+
using System.Diagnostics.Metrics;
2+
using Fossa.API.Core.Messages.Events;
23
using Fossa.Messaging;
34
using Fossa.Messaging.Messages.Events;
45
using Microsoft.Extensions.Logging;
@@ -7,7 +8,10 @@ namespace Fossa.API.Infrastructure.Messages.Events;
78

89
public class BranchCreatedEventBusHandler : CompanyEventBusHandler<BranchCreatedEvent, BranchChangedProtoEvent>
910
{
10-
public BranchCreatedEventBusHandler(IMessagePublisher messagePublisher, ILogger<BranchCreatedEventBusHandler> logger) : base(messagePublisher, logger)
11+
public BranchCreatedEventBusHandler(
12+
IMessagePublisher messagePublisher,
13+
IMeterFactory meterFactory,
14+
ILogger<BranchCreatedEventBusHandler> logger) : base(messagePublisher, meterFactory, logger)
1115
{
1216
}
1317

‎src/API.Infrastructure/Messages/Events/BranchUpdatedEventBusHandler.cs‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
1-
using Fossa.API.Core.Messages.Events;
1+
using System.Diagnostics.Metrics;
2+
using Fossa.API.Core.Messages.Events;
23
using Fossa.Messaging;
34
using Fossa.Messaging.Messages.Events;
45
using Microsoft.Extensions.Logging;
@@ -7,7 +8,10 @@ namespace Fossa.API.Infrastructure.Messages.Events;
78

89
public class BranchUpdatedEventBusHandler : CompanyEventBusHandler<BranchUpdatedEvent, BranchChangedProtoEvent>
910
{
10-
public BranchUpdatedEventBusHandler(IMessagePublisher messagePublisher, ILogger<BranchUpdatedEventBusHandler> logger) : base(messagePublisher, logger)
11+
public BranchUpdatedEventBusHandler(
12+
IMessagePublisher messagePublisher,
13+
IMeterFactory meterFactory,
14+
ILogger<BranchUpdatedEventBusHandler> logger) : base(messagePublisher, meterFactory, logger)
1115
{
1216
}
1317

‎src/API.Infrastructure/Messages/Events/CompanyCreatedEventBusHandler.cs‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
1-
using Fossa.API.Core.Messages.Events;
1+
using System.Diagnostics.Metrics;
2+
using Fossa.API.Core.Messages.Events;
23
using Fossa.Messaging;
34
using Fossa.Messaging.Messages.Events;
45
using Microsoft.Extensions.Logging;
@@ -7,7 +8,10 @@ namespace Fossa.API.Infrastructure.Messages.Events;
78

89
public class CompanyCreatedEventBusHandler : CompanyEventBusHandler<CompanyCreatedEvent, CompanyChangedProtoEvent>
910
{
10-
public CompanyCreatedEventBusHandler(IMessagePublisher messagePublisher, ILogger<CompanyCreatedEventBusHandler> logger) : base(messagePublisher, logger)
11+
public CompanyCreatedEventBusHandler(
12+
IMessagePublisher messagePublisher,
13+
IMeterFactory meterFactory,
14+
ILogger<CompanyCreatedEventBusHandler> logger) : base(messagePublisher, meterFactory, logger)
1115
{
1216
}
1317

‎src/API.Infrastructure/Messages/Events/CompanyEventBusHandler.cs‎

Lines changed: 33 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,6 @@
1-
using Fossa.API.Core.Messages.Events;
1+
using System.Diagnostics;
2+
using System.Diagnostics.Metrics;
3+
using Fossa.API.Core.Messages.Events;
24
using Fossa.Messaging;
35
using Google.Protobuf;
46
using Microsoft.Extensions.Logging;
@@ -9,12 +11,19 @@ public abstract partial class CompanyEventBusHandler<TEvent, TProtoEvent> : INot
911
where TEvent : ICompanyEvent<Guid>
1012
where TProtoEvent : IMessage
1113
{
14+
private static readonly ActivitySource _activitySource = new("Fossa.API.Infrastructure");
15+
private readonly Counter<long> _errorCounter;
1216
private readonly IMessagePublisher _messagePublisher;
1317
private readonly ILogger<CompanyEventBusHandler<TEvent, TProtoEvent>> _logger;
1418

15-
protected CompanyEventBusHandler(IMessagePublisher messagePublisher, ILogger<CompanyEventBusHandler<TEvent, TProtoEvent>> logger)
19+
protected CompanyEventBusHandler(
20+
IMessagePublisher messagePublisher,
21+
IMeterFactory meterFactory,
22+
ILogger<CompanyEventBusHandler<TEvent, TProtoEvent>> logger)
1623
{
1724
_messagePublisher = messagePublisher ?? throw new ArgumentNullException(nameof(messagePublisher));
25+
var meter = (meterFactory ?? throw new ArgumentNullException(nameof(meterFactory))).Create("Fossa.API.Infrastructure");
26+
_errorCounter = meter.CreateCounter<long>("fossa.api.infrastructure.company_event_bus_handler.error_count");
1827
_logger = logger ?? throw new ArgumentNullException(nameof(logger));
1928
}
2029

@@ -28,6 +37,21 @@ public async Task Handle(TEvent notification, CancellationToken cancellationToke
2837
var entityName = ResolveEntityName(notification);
2938
var entityId = ResolveEntityId(notification);
3039
var companyId = notification.CompanyId.AsPrimitive();
40+
var eventType = typeof(TEvent).Name;
41+
var eventHandlerType = GetType().Name;
42+
43+
using var activity = _activitySource.StartActivity(
44+
"Handle Company Event",
45+
ActivityKind.Internal,
46+
parentContext: default,
47+
tags: new Dictionary<string, object?>
48+
{
49+
{ "company_id", companyId },
50+
{ "entity_name", entityName },
51+
{ "entity_id", entityId },
52+
{ "event_type", eventType },
53+
{ "event_handler_type", eventHandlerType }
54+
});
3155

3256
try
3357
{
@@ -41,6 +65,13 @@ await _messagePublisher.PublishAsync(
4165
}
4266
catch (Exception ex)
4367
{
68+
_errorCounter.Add(1,
69+
new KeyValuePair<string, object?>("company_id", companyId),
70+
new KeyValuePair<string, object?>("entity_name", entityName),
71+
new KeyValuePair<string, object?>("entity_id", entityId),
72+
new KeyValuePair<string, object?>("event_type", eventType),
73+
new KeyValuePair<string, object?>("event_handler_type", eventHandlerType));
74+
4475
LogHandlerError(_logger, companyId, entityName, entityId, ex);
4576
}
4677
}

‎src/API.Infrastructure/Messages/Events/CompanyUpdatedEventBusHandler.cs‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
1-
using Fossa.API.Core.Messages.Events;
1+
using System.Diagnostics.Metrics;
2+
using Fossa.API.Core.Messages.Events;
23
using Fossa.Messaging;
34
using Fossa.Messaging.Messages.Events;
45
using Microsoft.Extensions.Logging;
@@ -7,7 +8,10 @@ namespace Fossa.API.Infrastructure.Messages.Events;
78

89
public class CompanyUpdatedEventBusHandler : CompanyEventBusHandler<CompanyUpdatedEvent, CompanyChangedProtoEvent>
910
{
10-
public CompanyUpdatedEventBusHandler(IMessagePublisher messagePublisher, ILogger<CompanyUpdatedEventBusHandler> logger) : base(messagePublisher, logger)
11+
public CompanyUpdatedEventBusHandler(
12+
IMessagePublisher messagePublisher,
13+
IMeterFactory meterFactory,
14+
ILogger<CompanyUpdatedEventBusHandler> logger) : base(messagePublisher, meterFactory, logger)
1115
{
1216
}
1317

‎src/API.Infrastructure/Messages/Events/DepartmentCreatedEventBusHandler.cs‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
1-
using Fossa.API.Core.Messages.Events;
1+
using System.Diagnostics.Metrics;
2+
using Fossa.API.Core.Messages.Events;
23
using Fossa.Messaging;
34
using Fossa.Messaging.Messages.Events;
45
using Microsoft.Extensions.Logging;
@@ -7,7 +8,10 @@ namespace Fossa.API.Infrastructure.Messages.Events;
78

89
public class DepartmentCreatedEventBusHandler : CompanyEventBusHandler<DepartmentCreatedEvent, DepartmentChangedProtoEvent>
910
{
10-
public DepartmentCreatedEventBusHandler(IMessagePublisher messagePublisher, ILogger<DepartmentCreatedEventBusHandler> logger) : base(messagePublisher, logger)
11+
public DepartmentCreatedEventBusHandler(
12+
IMessagePublisher messagePublisher,
13+
IMeterFactory meterFactory,
14+
ILogger<DepartmentCreatedEventBusHandler> logger) : base(messagePublisher, meterFactory, logger)
1115
{
1216
}
1317

‎src/API.Infrastructure/Messages/Events/DepartmentUpdatedEventBusHandler.cs‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
1-
using Fossa.API.Core.Messages.Events;
1+
using System.Diagnostics.Metrics;
2+
using Fossa.API.Core.Messages.Events;
23
using Fossa.Messaging;
34
using Fossa.Messaging.Messages.Events;
45
using Microsoft.Extensions.Logging;
@@ -7,7 +8,10 @@ namespace Fossa.API.Infrastructure.Messages.Events;
78

89
public class DepartmentUpdatedEventBusHandler : CompanyEventBusHandler<DepartmentUpdatedEvent, DepartmentChangedProtoEvent>
910
{
10-
public DepartmentUpdatedEventBusHandler(IMessagePublisher messagePublisher, ILogger<DepartmentUpdatedEventBusHandler> logger) : base(messagePublisher, logger)
11+
public DepartmentUpdatedEventBusHandler(
12+
IMessagePublisher messagePublisher,
13+
IMeterFactory meterFactory,
14+
ILogger<DepartmentUpdatedEventBusHandler> logger) : base(messagePublisher, meterFactory, logger)
1115
{
1216
}
1317

‎src/API.Infrastructure/Messages/Events/EmployeeCreatedEventBusHandler.cs‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
1-
using Fossa.API.Core.Messages.Events;
1+
using System.Diagnostics.Metrics;
2+
using Fossa.API.Core.Messages.Events;
23
using Fossa.Messaging;
34
using Fossa.Messaging.Messages.Events;
45
using Microsoft.Extensions.Logging;
@@ -7,7 +8,10 @@ namespace Fossa.API.Infrastructure.Messages.Events;
78

89
public class EmployeeCreatedEventBusHandler : CompanyEventBusHandler<EmployeeCreatedEvent, EmployeeChangedProtoEvent>
910
{
10-
public EmployeeCreatedEventBusHandler(IMessagePublisher messagePublisher, ILogger<EmployeeCreatedEventBusHandler> logger) : base(messagePublisher, logger)
11+
public EmployeeCreatedEventBusHandler(
12+
IMessagePublisher messagePublisher,
13+
IMeterFactory meterFactory,
14+
ILogger<EmployeeCreatedEventBusHandler> logger) : base(messagePublisher, meterFactory, logger)
1115
{
1216
}
1317

‎src/API.Infrastructure/Messages/Events/EmployeeUpdatedEventBusHandler.cs‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
1-
using Fossa.API.Core.Messages.Events;
1+
using System.Diagnostics.Metrics;
2+
using Fossa.API.Core.Messages.Events;
23
using Fossa.Messaging;
34
using Fossa.Messaging.Messages.Events;
45
using Microsoft.Extensions.Logging;
@@ -7,7 +8,10 @@ namespace Fossa.API.Infrastructure.Messages.Events;
78

89
public class EmployeeUpdatedEventBusHandler : CompanyEventBusHandler<EmployeeUpdatedEvent, EmployeeChangedProtoEvent>
910
{
10-
public EmployeeUpdatedEventBusHandler(IMessagePublisher messagePublisher, ILogger<EmployeeUpdatedEventBusHandler> logger) : base(messagePublisher, logger)
11+
public EmployeeUpdatedEventBusHandler(
12+
IMessagePublisher messagePublisher,
13+
IMeterFactory meterFactory,
14+
ILogger<EmployeeUpdatedEventBusHandler> logger) : base(messagePublisher, meterFactory, logger)
1115
{
1216
}
1317

‎tests/API.UnitTests/PublicAPITests.InfrastructureAssemblyHasNoPublicAPIChangesAsync.verified.txt‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -10,21 +10,21 @@ namespace Fossa.API.Infrastructure.Messages.Events
1010
{
1111
public class BranchCreatedEventBusHandler : Fossa.API.Infrastructure.Messages.Events.CompanyEventBusHandler<Fossa.API.Core.Messages.Events.BranchCreatedEvent, Fossa.Messaging.Messages.Events.BranchChangedProtoEvent>
1212
{
13-
public BranchCreatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.BranchCreatedEventBusHandler> logger) { }
13+
public BranchCreatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, System.Diagnostics.Metrics.IMeterFactory meterFactory, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.BranchCreatedEventBusHandler> logger) { }
1414
protected override Fossa.Messaging.Messages.Events.BranchChangedProtoEvent Map(Fossa.API.Core.Messages.Events.BranchCreatedEvent domainEvent) { }
1515
protected override long ResolveEntityId(Fossa.API.Core.Messages.Events.BranchCreatedEvent domainEvent) { }
1616
protected override string ResolveEntityName(Fossa.API.Core.Messages.Events.BranchCreatedEvent domainEvent) { }
1717
}
1818
public class BranchUpdatedEventBusHandler : Fossa.API.Infrastructure.Messages.Events.CompanyEventBusHandler<Fossa.API.Core.Messages.Events.BranchUpdatedEvent, Fossa.Messaging.Messages.Events.BranchChangedProtoEvent>
1919
{
20-
public BranchUpdatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.BranchUpdatedEventBusHandler> logger) { }
20+
public BranchUpdatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, System.Diagnostics.Metrics.IMeterFactory meterFactory, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.BranchUpdatedEventBusHandler> logger) { }
2121
protected override Fossa.Messaging.Messages.Events.BranchChangedProtoEvent Map(Fossa.API.Core.Messages.Events.BranchUpdatedEvent domainEvent) { }
2222
protected override long ResolveEntityId(Fossa.API.Core.Messages.Events.BranchUpdatedEvent domainEvent) { }
2323
protected override string ResolveEntityName(Fossa.API.Core.Messages.Events.BranchUpdatedEvent domainEvent) { }
2424
}
2525
public class CompanyCreatedEventBusHandler : Fossa.API.Infrastructure.Messages.Events.CompanyEventBusHandler<Fossa.API.Core.Messages.Events.CompanyCreatedEvent, Fossa.Messaging.Messages.Events.CompanyChangedProtoEvent>
2626
{
27-
public CompanyCreatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.CompanyCreatedEventBusHandler> logger) { }
27+
public CompanyCreatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, System.Diagnostics.Metrics.IMeterFactory meterFactory, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.CompanyCreatedEventBusHandler> logger) { }
2828
protected override Fossa.Messaging.Messages.Events.CompanyChangedProtoEvent Map(Fossa.API.Core.Messages.Events.CompanyCreatedEvent domainEvent) { }
2929
protected override long ResolveEntityId(Fossa.API.Core.Messages.Events.CompanyCreatedEvent domainEvent) { }
3030
protected override string ResolveEntityName(Fossa.API.Core.Messages.Events.CompanyCreatedEvent domainEvent) { }
@@ -33,7 +33,7 @@ namespace Fossa.API.Infrastructure.Messages.Events
3333
where TEvent : Fossa.API.Core.Messages.Events.ICompanyEvent<System.Guid>
3434
where TProtoEvent : Google.Protobuf.IMessage
3535
{
36-
protected CompanyEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.CompanyEventBusHandler<TEvent, TProtoEvent>> logger) { }
36+
protected CompanyEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, System.Diagnostics.Metrics.IMeterFactory meterFactory, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.CompanyEventBusHandler<TEvent, TProtoEvent>> logger) { }
3737
protected static string BranchEntityName { get; }
3838
protected static string CompanyEntityName { get; }
3939
protected static string DepartmentEntityName { get; }
@@ -45,35 +45,35 @@ namespace Fossa.API.Infrastructure.Messages.Events
4545
}
4646
public class CompanyUpdatedEventBusHandler : Fossa.API.Infrastructure.Messages.Events.CompanyEventBusHandler<Fossa.API.Core.Messages.Events.CompanyUpdatedEvent, Fossa.Messaging.Messages.Events.CompanyChangedProtoEvent>
4747
{
48-
public CompanyUpdatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.CompanyUpdatedEventBusHandler> logger) { }
48+
public CompanyUpdatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, System.Diagnostics.Metrics.IMeterFactory meterFactory, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.CompanyUpdatedEventBusHandler> logger) { }
4949
protected override Fossa.Messaging.Messages.Events.CompanyChangedProtoEvent Map(Fossa.API.Core.Messages.Events.CompanyUpdatedEvent domainEvent) { }
5050
protected override long ResolveEntityId(Fossa.API.Core.Messages.Events.CompanyUpdatedEvent domainEvent) { }
5151
protected override string ResolveEntityName(Fossa.API.Core.Messages.Events.CompanyUpdatedEvent domainEvent) { }
5252
}
5353
public class DepartmentCreatedEventBusHandler : Fossa.API.Infrastructure.Messages.Events.CompanyEventBusHandler<Fossa.API.Core.Messages.Events.DepartmentCreatedEvent, Fossa.Messaging.Messages.Events.DepartmentChangedProtoEvent>
5454
{
55-
public DepartmentCreatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.DepartmentCreatedEventBusHandler> logger) { }
55+
public DepartmentCreatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, System.Diagnostics.Metrics.IMeterFactory meterFactory, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.DepartmentCreatedEventBusHandler> logger) { }
5656
protected override Fossa.Messaging.Messages.Events.DepartmentChangedProtoEvent Map(Fossa.API.Core.Messages.Events.DepartmentCreatedEvent domainEvent) { }
5757
protected override long ResolveEntityId(Fossa.API.Core.Messages.Events.DepartmentCreatedEvent domainEvent) { }
5858
protected override string ResolveEntityName(Fossa.API.Core.Messages.Events.DepartmentCreatedEvent domainEvent) { }
5959
}
6060
public class DepartmentUpdatedEventBusHandler : Fossa.API.Infrastructure.Messages.Events.CompanyEventBusHandler<Fossa.API.Core.Messages.Events.DepartmentUpdatedEvent, Fossa.Messaging.Messages.Events.DepartmentChangedProtoEvent>
6161
{
62-
public DepartmentUpdatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.DepartmentUpdatedEventBusHandler> logger) { }
62+
public DepartmentUpdatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, System.Diagnostics.Metrics.IMeterFactory meterFactory, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.DepartmentUpdatedEventBusHandler> logger) { }
6363
protected override Fossa.Messaging.Messages.Events.DepartmentChangedProtoEvent Map(Fossa.API.Core.Messages.Events.DepartmentUpdatedEvent domainEvent) { }
6464
protected override long ResolveEntityId(Fossa.API.Core.Messages.Events.DepartmentUpdatedEvent domainEvent) { }
6565
protected override string ResolveEntityName(Fossa.API.Core.Messages.Events.DepartmentUpdatedEvent domainEvent) { }
6666
}
6767
public class EmployeeCreatedEventBusHandler : Fossa.API.Infrastructure.Messages.Events.CompanyEventBusHandler<Fossa.API.Core.Messages.Events.EmployeeCreatedEvent, Fossa.Messaging.Messages.Events.EmployeeChangedProtoEvent>
6868
{
69-
public EmployeeCreatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.EmployeeCreatedEventBusHandler> logger) { }
69+
public EmployeeCreatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, System.Diagnostics.Metrics.IMeterFactory meterFactory, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.EmployeeCreatedEventBusHandler> logger) { }
7070
protected override Fossa.Messaging.Messages.Events.EmployeeChangedProtoEvent Map(Fossa.API.Core.Messages.Events.EmployeeCreatedEvent domainEvent) { }
7171
protected override long ResolveEntityId(Fossa.API.Core.Messages.Events.EmployeeCreatedEvent domainEvent) { }
7272
protected override string ResolveEntityName(Fossa.API.Core.Messages.Events.EmployeeCreatedEvent domainEvent) { }
7373
}
7474
public class EmployeeUpdatedEventBusHandler : Fossa.API.Infrastructure.Messages.Events.CompanyEventBusHandler<Fossa.API.Core.Messages.Events.EmployeeUpdatedEvent, Fossa.Messaging.Messages.Events.EmployeeChangedProtoEvent>
7575
{
76-
public EmployeeUpdatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.EmployeeUpdatedEventBusHandler> logger) { }
76+
public EmployeeUpdatedEventBusHandler(Fossa.Messaging.IMessagePublisher messagePublisher, System.Diagnostics.Metrics.IMeterFactory meterFactory, Microsoft.Extensions.Logging.ILogger<Fossa.API.Infrastructure.Messages.Events.EmployeeUpdatedEventBusHandler> logger) { }
7777
protected override Fossa.Messaging.Messages.Events.EmployeeChangedProtoEvent Map(Fossa.API.Core.Messages.Events.EmployeeUpdatedEvent domainEvent) { }
7878
protected override long ResolveEntityId(Fossa.API.Core.Messages.Events.EmployeeUpdatedEvent domainEvent) { }
7979
protected override string ResolveEntityName(Fossa.API.Core.Messages.Events.EmployeeUpdatedEvent domainEvent) { }

0 commit comments

Comments
 (0)