Author: rfeng
Date: Wed Mar 10 21:48:39 2010
New Revision: 921584
URL: http://svn.apache.org/viewvc?rev=921584&view=rev
Log:
Allow the customization of receiverAddress
Modified:
tuscany/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
Modified:
tuscany/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
URL:
http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java?rev=921584&r1=921583&r2=921584&view=diff
==============================================================================
---
tuscany/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
(original)
+++
tuscany/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
Wed Mar 10 21:48:39 2010
@@ -68,6 +68,7 @@ public class ReplicatedEndpointRegistry
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
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
// 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);
}
/*
