Allow the customization of receiverAddress

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@921584 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 6 insertions, 1 deletions

diff --git a/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java b/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
index a3d33f8235..2e8cf741b6 100644
--- a/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
+++ b/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
@@ -68,6 +68,7 @@ public class ReplicatedEndpointRegistry extends BaseEndpointRegistry implements
     private String address = MULTICAST_ADDRESS;
     private String bind = null;
     private int timeout = 50;
+    private String receiverAddress;
     private int receiverPort = 4000;
     private int receiverAutoBind = 100;
     private List<URI> staticRoutes;
@@ -198,6 +199,7 @@ public class ReplicatedEndpointRegistry extends BaseEndpointRegistry implements
         if (mcast != null) {
             noMultiCast = Boolean.valueOf(mcast);
         }
+        receiverAddress = attributes.get("receiverAddress");
         String recvPort = attributes.get("receiverPort");
         if (recvPort != null) {
             receiverPort = Integer.parseInt(recvPort);
@@ -225,8 +227,11 @@ public class ReplicatedEndpointRegistry extends BaseEndpointRegistry implements
         // Configure the receiver ports
         ChannelReceiver receiver = channel.getChannelReceiver();
         if (receiver instanceof ReceiverBase) {
-            ((ReceiverBase)receiver).setAutoBind(receiverAutoBind);
+            if (receiverAddress != null) {
+                ((ReceiverBase)receiver).setAddress(receiverAddress);
+            }
             ((ReceiverBase)receiver).setPort(receiverPort);
+            ((ReceiverBase)receiver).setAutoBind(receiverAutoBind);
         }
 
         /*