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);
     }
 }