got rid of extra call to flush which was failing for proxies

advantageous · Jul 9, 2015 · 9750f03 · 9750f03
1 parent 8321d34
commit 9750f03
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/qbit/cluster/admin/src/main/java/io/advantageous/qbit/metrics/StatServiceImpl.java b/qbit/cluster/admin/src/main/java/io/advantageous/qbit/metrics/StatServiceImpl.java
@@ -254,8 +254,9 @@ private void heathCheck() {
     }
 
     private void flushReplicas() {
-        ServiceProxyUtils.flushServiceProxy(replica);
-        replica.flush();
+        if (!ServiceProxyUtils.flushServiceProxy(replica)) {
+            replica.flush();
+        }
     }
 
     private void flushMinuteCheck() {

diff --git a/qbit/core/src/main/java/io/advantageous/qbit/service/ServiceProxyUtils.java b/qbit/core/src/main/java/io/advantageous/qbit/service/ServiceProxyUtils.java
@@ -26,9 +26,13 @@
  */
 public class ServiceProxyUtils {
 
-    public static void flushServiceProxy(Object object) {
+    public static boolean flushServiceProxy(Object object) {
         if (object instanceof ClientProxy) {
             ((ClientProxy) object).clientProxyFlush();
+            return true;
+        } else {
+            return false;
         }
+
     }
 }