|
@@ -133,9 +133,9 @@ namespace PRSServer
|
|
|
)).Rows.Select(x => x.ToObject<Notification>());
|
|
|
}
|
|
|
|
|
|
- private void ConfigureNotifier()
|
|
|
+ private void ConfigurePusher()
|
|
|
{
|
|
|
- Notify.AddPollHandler(PollNotifications);
|
|
|
+ PushManager.AddPollHandler(PollNotifications);
|
|
|
}
|
|
|
|
|
|
public override void Run()
|
|
@@ -218,7 +218,7 @@ namespace PRSServer
|
|
|
_socketserver = new RpcServer<RpcServerSocketTransport>(sockettransport);
|
|
|
_socketserver.OnLog += (type, userid, message, parameters) => Logger.Send(type, userid, $"[S] {message}", parameters);
|
|
|
_socketserver.Start();
|
|
|
- Notify.AddNotifier(sockettransport);
|
|
|
+ PushManager.AddPusher(sockettransport);
|
|
|
|
|
|
Logger.Send(LogType.Information, "", string.Format("Server started listening on port {0}", Properties.Port));
|
|
|
|
|
@@ -230,11 +230,11 @@ namespace PRSServer
|
|
|
_pipeserver = new RpcServer<RpcServerPipeTransport>(pipetransport);
|
|
|
_pipeserver.OnLog += (type, userid, message, parameters) => Logger.Send(type, userid, $"[P] {message}", parameters);
|
|
|
_pipeserver.Start();
|
|
|
- Notify.AddNotifier(pipetransport);
|
|
|
+ PushManager.AddPusher(pipetransport);
|
|
|
|
|
|
Logger.Send(LogType.Information, "", "Pipe Listener started");
|
|
|
|
|
|
- ConfigureNotifier();
|
|
|
+ ConfigurePusher();
|
|
|
|
|
|
}
|
|
|
|