diff --git a/ZeroLevel/Services/Application/BaseWindowsExService.cs b/ZeroLevel/Services/Application/BaseWindowsExService.cs index 612afcf..9285643 100644 --- a/ZeroLevel/Services/Application/BaseWindowsExService.cs +++ b/ZeroLevel/Services/Application/BaseWindowsExService.cs @@ -10,9 +10,10 @@ namespace ZeroLevel.Services.Applications public string Group { get; private set; } public string Type { get; private set; } - protected readonly Exchange _exchange; protected readonly IConfiguration _config; + protected Exchange Exchange { get; } + protected BaseWindowsExService(IConfiguration configuration = null) : base() { @@ -25,7 +26,7 @@ namespace ZeroLevel.Services.Applications var discovery = _config.First("discovery"); - _exchange = new Exchange(new DiscoveryClient(discovery)); + Exchange = new Exchange(new DiscoveryClient(discovery)); } private IExService _self_service = null; @@ -40,7 +41,7 @@ namespace ZeroLevel.Services.Applications { if (_self_service == null) { - _self_service = _exchange.RegisterService(this); + _self_service = Exchange.RegisterService(this); } } } @@ -101,7 +102,7 @@ namespace ZeroLevel.Services.Applications public override void DisposeResources() { - this._exchange.Dispose(); + this.Exchange.Dispose(); } } } \ No newline at end of file diff --git a/ZeroLevel/Services/Network/Contract/IExService.cs b/ZeroLevel/Services/Network/Contract/IExService.cs index 9b5824f..8b47f9a 100644 --- a/ZeroLevel/Services/Network/Contract/IExService.cs +++ b/ZeroLevel/Services/Network/Contract/IExService.cs @@ -7,6 +7,8 @@ namespace ZeroLevel.Network : IDisposable { IPEndPoint Endpoint { get; } + event Action OnConnect; + event Action OnDisconnect; void RegisterInbox(string inbox, Action handler);