Forráskód Böngészése

Merge branch 'Rpc' of http://prssvr:3000/PRSDigital/prs into Rpc

Frank van den Bos 2 éve
szülő
commit
d506e4d434
1 módosított fájl, 3 hozzáadás és 1 törlés
  1. 3 1
      prs.server/Engines/Database/DatabaseEngine.cs

+ 3 - 1
prs.server/Engines/Database/DatabaseEngine.cs

@@ -218,6 +218,7 @@ namespace PRSServer
             _socketserver = new RpcServer<RpcServerSocketTransport>(sockettransport);
             _socketserver = new RpcServer<RpcServerSocketTransport>(sockettransport);
             _socketserver.OnLog += (type, userid, message, parameters) => Logger.Send(type, userid, $"[S] {message}", parameters);
             _socketserver.OnLog += (type, userid, message, parameters) => Logger.Send(type, userid, $"[S] {message}", parameters);
             _socketserver.Start();
             _socketserver.Start();
+            Notify.AddNotifier(sockettransport);
 
 
             Logger.Send(LogType.Information, "", string.Format("Server started listening on port {0}", Properties.Port));
             Logger.Send(LogType.Information, "", string.Format("Server started listening on port {0}", Properties.Port));
 
 
@@ -229,7 +230,8 @@ namespace PRSServer
             _pipeserver = new RpcServer<RpcServerPipeTransport>(pipetransport);
             _pipeserver = new RpcServer<RpcServerPipeTransport>(pipetransport);
             _pipeserver.OnLog += (type, userid, message, parameters) => Logger.Send(type, userid, $"[P] {message}", parameters);
             _pipeserver.OnLog += (type, userid, message, parameters) => Logger.Send(type, userid, $"[P] {message}", parameters);
             _pipeserver.Start();
             _pipeserver.Start();
-            
+            Notify.AddNotifier(pipetransport);
+
             Logger.Send(LogType.Information, "", "Pipe Listener started");
             Logger.Send(LogType.Information, "", "Pipe Listener started");
             
             
             ConfigureNotifier();
             ConfigureNotifier();