CLOUD-1518 Message.setSrc method compatibility

Author: slaskawi

common/src/main/java/org/openshift/ping/common/OpenshiftPing.java

@@ -30,6 +30,7 @@
 import java.util.List;
 import java.util.concurrent.TimeUnit;
 
+import org.jgroups.Address;
 import org.jgroups.Event;
 import org.jgroups.Message;
 import org.jgroups.annotations.Property;
@@ -67,6 +68,7 @@ public abstract class OpenshiftPing extends PING {
     private String _serverName;
 
     private static Method sendMethod; //handled via reflection due to JGroups 3/4 incompatibility
+    private static Method setSrcMethod;
 
     public OpenshiftPing(String systemEnvPrefix) {
         super();
@@ -80,6 +82,12 @@ public OpenshiftPing(String systemEnvPrefix) {
         } catch (Exception e) {
             throw new CompatibilityException("Could not find suitable 'up' method.", e);
         }
+        try {
+            //the return parameter changed in JGroups 3/4 :D
+            setSrcMethod = Message.class.getMethod("setSrc", Address.class);
+        } catch (Exception e) {
+            throw new CompatibilityException("Could not find suitable 'setSrc' method.", e);
+        }
     }
 
     protected final String getSystemEnvName(String systemEnvSuffix) {
@@ -194,7 +202,7 @@ protected void sendMcastDiscoveryRequest(Message msg) {
             return;
         }
         if (msg.getSrc() == null) {
-            msg.setSrc(local_addr);
+            setSrc(msg);
         }
         for (InetSocketAddress node : nodes) {
             // forward the request to each node
@@ -213,6 +221,16 @@ public void handlePingRequest(InputStream stream) throws Exception {
         }
     }
 
+    private void setSrc(Message msg) {
+        try {
+            setSrcMethod.invoke(msg, local_addr);
+        } catch (IllegalAccessException e) {
+            e.printStackTrace();
+        } catch (Exception e) {
+            throw new CompatibilityException("Could not invoke 'setSrc' method.", e);
+        }
+    }
+
     private void sendUp(Message msg) {
         try {
             if(CompatibilityUtils.isJGroups4()) {