@@ -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