Merge pull request #422 from K-Society/experimental

Fix in DefaultRabbitMqPersistentConnection
K-Society · Feb 29, 2024 · f8f907e · f8f907e
2 parents 57832f7 + 0a8f122
commit f8f907e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...SocietyBaseEventBus/KSociety.Base.EventBusRabbitMQ/DefaultRabbitMqPersistentConnection.cs b/...SocietyBaseEventBus/KSociety.Base.EventBusRabbitMQ/DefaultRabbitMqPersistentConnection.cs
@@ -172,7 +172,7 @@ await Task.Run(() =>
                         //_logger.LogTrace("RabbitMQ CreateConnection StackTrace: {0}", System.Environment.StackTrace);
                         this._connection = this._connectionFactory
                             .CreateConnection(); //ToDo
-                    }, this._closeToken);
+                    }, this._closeToken).ConfigureAwait(false);
 
                 }).ConfigureAwait(false);
 

diff --git a/src/01/KSocietyBaseEventBus/KSociety.Base.EventBusRabbitMQ/Helper/Subscriber.cs b/src/01/KSocietyBaseEventBus/KSociety.Base.EventBusRabbitMQ/Helper/Subscriber.cs
@@ -146,7 +146,7 @@ public async ValueTask SubscribeClient<TIntegrationRpcClientHandler, TIntegratio
 
             if (this.EventBus.TryAdd(eventBusName + "_Client", eventBus))
             {
-                ((IEventBusRpcClient<TIntegrationEventReply>)this.EventBus[eventBusName + "_Client"]).Initialize();//.Initialize();
+                ((IEventBusRpcClient<TIntegrationEventReply>)this.EventBus[eventBusName + "_Client"]).Initialize();
 
                 await ((IEventBusRpcClient<TIntegrationEventReply>)this.EventBus[eventBusName + "_Client"])
                     .SubscribeRpcClient<TIntegrationRpcClientHandler>(replyRoutingKey)