You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-commits@axis.apache.org by az...@apache.org on 2012/04/20 14:37:32 UTC
svn commit: r1328354 -
/axis/axis2/java/core/trunk/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusteringAgent.java
Author: azeez
Date: Fri Apr 20 12:37:31 2012
New Revision: 1328354
URL: http://svn.apache.org/viewvc?rev=1328354&view=rev
Log:
Take portOffset into consideration when transmitting member http & https port member properties
Modified:
axis/axis2/java/core/trunk/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusteringAgent.java
Modified: axis/axis2/java/core/trunk/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusteringAgent.java
URL: http://svn.apache.org/viewvc/axis/axis2/java/core/trunk/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusteringAgent.java?rev=1328354&r1=1328353&r2=1328354&view=diff
==============================================================================
--- axis/axis2/java/core/trunk/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusteringAgent.java (original)
+++ axis/axis2/java/core/trunk/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusteringAgent.java Fri Apr 20 12:37:31 2012
@@ -297,24 +297,25 @@ public class TribesClusteringAgent imple
Properties memberInfo = new Properties();
AxisConfiguration axisConfig = configurationContext.getAxisConfiguration();
TransportInDescription httpTransport = axisConfig.getTransportIn("http");
+ int portOffset = 0;
+ if(System.getProperty("portOffset") != null){
+ portOffset = Integer.parseInt(System.getProperty("portOffset"));
+ }
if (httpTransport != null) {
Parameter port = httpTransport.getParameter("port");
if (port != null) {
- memberInfo.put("httpPort", port.getValue());
+ memberInfo.put("httpPort",
+ String.valueOf(Integer.valueOf((String)port.getValue()) + portOffset));
}
}
TransportInDescription httpsTransport = axisConfig.getTransportIn("https");
if (httpsTransport != null) {
Parameter port = httpsTransport.getParameter("port");
if (port != null) {
- memberInfo.put("httpsPort", port.getValue());
+ memberInfo.put("httpsPort",
+ String.valueOf(Integer.valueOf((String)port.getValue()) + portOffset));
}
}
- Parameter isActiveParam = getParameter(ClusteringConstants.Parameters.IS_ACTIVE);
- if (isActiveParam != null) {
- memberInfo.setProperty(ClusteringConstants.Parameters.IS_ACTIVE,
- (String) isActiveParam.getValue());
- }
memberInfo.setProperty("hostName",
TribesUtil.getLocalHost(getParameter(TribesConstants.LOCAL_MEMBER_HOST)));