Merge branch '3.8' of https://github.com/JumpMind/symmetric-ds.git in…

…to 3.8
JumpMind · Sep 20, 2016 · 123a57b · 123a57b
2 parents dc6a58d + 55a3c22
commit 123a57b
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/io/DefaultOfflineClientListener.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/io/DefaultOfflineClientListener.java
@@ -66,5 +66,8 @@ public void syncDisabled(Node remoteNode) {
 
     public void registrationRequired(Node remoteNode) {
     }
-
+
+    public void online(Node remoteNode) {
+    }
+
 }
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/io/IOfflineClientListener.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/io/IOfflineClientListener.java
@@ -59,4 +59,9 @@ public interface IOfflineClientListener extends IExtensionPoint {
 
     public void unknownError(Node remoteNode, Exception ex);
 
+    /**
+     * Called when the remote node is reachable.
+     */
+    public void online(Node remoteNode);
+
 }
diff --git a/...ore/src/main/java/org/jumpmind/symmetric/service/impl/AbstractOfflineDetectorService.java b/...ore/src/main/java/org/jumpmind/symmetric/service/impl/AbstractOfflineDetectorService.java
@@ -62,6 +62,12 @@ public AbstractOfflineDetectorService(IParameterService parameterService,
 
     protected void fireOnline(Node remoteNode, RemoteNodeStatus status) {
         transportErrorTimeByNode.remove(remoteNode.getNodeId());
+        List<IOfflineClientListener> offlineListeners = extensionService.getExtensionPointList(IOfflineClientListener.class);
+        if (offlineListeners != null) {
+            for (IOfflineClientListener listener : offlineListeners) {
+                listener.online(remoteNode);
+            }
+        }
     }
 
     protected void fireOffline(Exception error, Node remoteNode, RemoteNodeStatus status) {