From a9a1850a75b0da7605851f8fdf653d2eea9165ef Mon Sep 17 00:00:00 2001 From: crusader Date: Thu, 10 May 2018 19:41:20 +0900 Subject: [PATCH] ing --- .../module/noauthprobe/service/CentralNoAuthProbeService.java | 4 ++-- .../central/module/probe/service/CentralProbeService.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/loafle/overflow/central/module/noauthprobe/service/CentralNoAuthProbeService.java b/src/main/java/com/loafle/overflow/central/module/noauthprobe/service/CentralNoAuthProbeService.java index 229703c..d455936 100644 --- a/src/main/java/com/loafle/overflow/central/module/noauthprobe/service/CentralNoAuthProbeService.java +++ b/src/main/java/com/loafle/overflow/central/module/noauthprobe/service/CentralNoAuthProbeService.java @@ -226,7 +226,7 @@ public class CentralNoAuthProbeService implements NoAuthProbeService { noAuthProbe.setConnectAddress(connectAddress); noAuthProbe = this.noAuthProbeDAO.save(noAuthProbe); - messagePublisher.publishToDomainMembers(noAuthProbe.getDomain().getId(), "NoAuthProbeService.onConnect", tempKey, connectAddress); + messagePublisher.publishToDomainMembers(noAuthProbe.getDomain().getId(), "NoAuthProbeService.onConnect", noAuthProbe); } public void onDisconnect(String tempKey) throws OverflowException { @@ -235,7 +235,7 @@ public class CentralNoAuthProbeService implements NoAuthProbeService { noAuthProbe.setConnectAddress(null); noAuthProbe = this.noAuthProbeDAO.save(noAuthProbe); - messagePublisher.publishToDomainMembers(noAuthProbe.getDomain().getId(), "NoAuthProbeService.onDisconnect", tempKey); + messagePublisher.publishToDomainMembers(noAuthProbe.getDomain().getId(), "NoAuthProbeService.onDisconnect", noAuthProbe); } } diff --git a/src/main/java/com/loafle/overflow/central/module/probe/service/CentralProbeService.java b/src/main/java/com/loafle/overflow/central/module/probe/service/CentralProbeService.java index d8c1f60..e4e234e 100644 --- a/src/main/java/com/loafle/overflow/central/module/probe/service/CentralProbeService.java +++ b/src/main/java/com/loafle/overflow/central/module/probe/service/CentralProbeService.java @@ -81,7 +81,7 @@ public class CentralProbeService implements ProbeService { probe.setConnectAddress(connectAddress); probe = this.probeDAO.save(probe); - messagePublisher.publishToDomainMembers(probe.getDomain().getId(), "ProbeService.onConnect", probeKey, connectAddress); + messagePublisher.publishToDomainMembers(probe.getDomain().getId(), "ProbeService.onConnect", probe); } public void onDisconnect(String probeKey) throws OverflowException { @@ -90,6 +90,6 @@ public class CentralProbeService implements ProbeService { probe.setConnectAddress(null); probe = this.probeDAO.save(probe); - messagePublisher.publishToDomainMembers(probe.getDomain().getId(), "ProbeService.onDisconnect", probeKey); + messagePublisher.publishToDomainMembers(probe.getDomain().getId(), "ProbeService.onDisconnect", probe); } }