Skip to content
This repository was archived by the owner on Nov 17, 2023. It is now read-only.

Commit f8bcced

Browse files
authored
Merge pull request #1104 from dvlsg/patch-1
fix: typo in EventBusServiceBus.cs for "suffix"
2 parents 827504f + f92d695 commit f8bcced

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

src/BuildingBlocks/EventBus/EventBusServiceBus/EventBusServiceBus.cs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ public class EventBusServiceBus : IEventBus
2020
private readonly SubscriptionClient _subscriptionClient;
2121
private readonly ILifetimeScope _autofac;
2222
private readonly string AUTOFAC_SCOPE_NAME = "eshop_event_bus";
23-
private const string INTEGRATION_EVENT_SUFIX = "IntegrationEvent";
23+
private const string INTEGRATION_EVENT_SUFFIX = "IntegrationEvent";
2424

2525
public EventBusServiceBus(IServiceBusPersisterConnection serviceBusPersisterConnection,
2626
ILogger<EventBusServiceBus> logger, IEventBusSubscriptionsManager subsManager, string subscriptionClientName,
@@ -40,7 +40,7 @@ public EventBusServiceBus(IServiceBusPersisterConnection serviceBusPersisterConn
4040

4141
public void Publish(IntegrationEvent @event)
4242
{
43-
var eventName = @event.GetType().Name.Replace(INTEGRATION_EVENT_SUFIX, "");
43+
var eventName = @event.GetType().Name.Replace(INTEGRATION_EVENT_SUFFIX, "");
4444
var jsonMessage = JsonConvert.SerializeObject(@event);
4545
var body = Encoding.UTF8.GetBytes(jsonMessage);
4646

@@ -70,7 +70,7 @@ public void Subscribe<T, TH>()
7070
where T : IntegrationEvent
7171
where TH : IIntegrationEventHandler<T>
7272
{
73-
var eventName = typeof(T).Name.Replace(INTEGRATION_EVENT_SUFIX, "");
73+
var eventName = typeof(T).Name.Replace(INTEGRATION_EVENT_SUFFIX, "");
7474

7575
var containsKey = _subsManager.HasSubscriptionsForEvent<T>();
7676
if (!containsKey)
@@ -98,7 +98,7 @@ public void Unsubscribe<T, TH>()
9898
where T : IntegrationEvent
9999
where TH : IIntegrationEventHandler<T>
100100
{
101-
var eventName = typeof(T).Name.Replace(INTEGRATION_EVENT_SUFIX, "");
101+
var eventName = typeof(T).Name.Replace(INTEGRATION_EVENT_SUFFIX, "");
102102

103103
try
104104
{
@@ -135,7 +135,7 @@ private void RegisterSubscriptionClientMessageHandler()
135135
_subscriptionClient.RegisterMessageHandler(
136136
async (message, token) =>
137137
{
138-
var eventName = $"{message.Label}{INTEGRATION_EVENT_SUFIX}";
138+
var eventName = $"{message.Label}{INTEGRATION_EVENT_SUFFIX}";
139139
var messageData = Encoding.UTF8.GetString(message.Body);
140140

141141
// Complete the message so that it is not received again.
@@ -205,4 +205,4 @@ private void RemoveDefaultRule()
205205
}
206206
}
207207
}
208-
}
208+
}

0 commit comments

Comments
 (0)