From 8aea5ddb55898e7506672fd182daaea80f2a1dc0 Mon Sep 17 00:00:00 2001 From: Jan Zenisek Date: Thu, 1 Feb 2024 17:48:24 +0100 Subject: [PATCH] added RoutingTable to configs --- src/Configuration/Configuration.csproj | 1 + .../Configurations/BrokerConfiguration.cs | 14 ++++---------- .../Configurations/SocketConfiguration.cs | 7 ++++--- 3 files changed, 9 insertions(+), 13 deletions(-) diff --git a/src/Configuration/Configuration.csproj b/src/Configuration/Configuration.csproj index 9b5f2c7..4eabd6a 100644 --- a/src/Configuration/Configuration.csproj +++ b/src/Configuration/Configuration.csproj @@ -9,6 +9,7 @@ + diff --git a/src/Configuration/Configurations/BrokerConfiguration.cs b/src/Configuration/Configurations/BrokerConfiguration.cs index 980cea2..82a2b30 100644 --- a/src/Configuration/Configurations/BrokerConfiguration.cs +++ b/src/Configuration/Configurations/BrokerConfiguration.cs @@ -1,11 +1,5 @@ -using Ai.Hgb.Dat.Utils; -using System; -using System.Collections.Generic; -using System.Linq; -using System.Net; -using System.Text; -using System.Threading.Tasks; -using System.Xml.Linq; +using Ai.Hgb.Common.Entities; +using Ai.Hgb.Dat.Utils; namespace Ai.Hgb.Dat.Configuration { public class BrokerConfiguration : IConfiguration { @@ -22,7 +16,7 @@ public class BrokerConfiguration : IConfiguration { public string BaseTopic { get; set; } public string PayloadType { get; set; } - //public RoutingTable Routing { get; set; } + public RoutingTable Routing { get; set; } public BrokerConfiguration() { @@ -53,7 +47,7 @@ public object Clone() { c.BaseTopic = BaseTopic; c.PayloadType = PayloadType; - //c.Routing = (RoutingTable)Routing.Clone(); + c.Routing = (RoutingTable)Routing.Clone(); return c; } diff --git a/src/Configuration/Configurations/SocketConfiguration.cs b/src/Configuration/Configurations/SocketConfiguration.cs index 7c25fe9..86958db 100644 --- a/src/Configuration/Configurations/SocketConfiguration.cs +++ b/src/Configuration/Configurations/SocketConfiguration.cs @@ -1,4 +1,5 @@ -using Ai.Hgb.Dat.Utils; +using Ai.Hgb.Common.Entities; +using Ai.Hgb.Dat.Utils; namespace Ai.Hgb.Dat.Configuration { public class SocketConfiguration : IConfiguration { @@ -28,7 +29,7 @@ public class SocketConfiguration : IConfiguration { public RequestOptions DefaultRequestOptions { get; set; } - //public RoutingTable Routing { get; set; } + public RoutingTable Routing { get; set; } public SocketConfiguration() { DefaultPublicationOptions = new PublicationOptions(); @@ -53,7 +54,7 @@ public object Clone() { c.DefaultSubscriptionOptions = (SubscriptionOptions)DefaultSubscriptionOptions.Clone(); c.DefaultRequestOptions = (RequestOptions)DefaultRequestOptions.Clone(); - //c.Routing = (RoutingTable)Routing.Clone(); + c.Routing = (RoutingTable)Routing.Clone(); return c; }