You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by ch...@apache.org on 2005/08/31 13:06:29 UTC
svn commit: r265013 -
/webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/SandeshaContext.java
Author: chamikara
Date: Wed Aug 31 04:06:01 2005
New Revision: 265013
URL: http://svn.apache.org/viewcvs?rev=265013&view=rev
Log:
bug fix for setting client listner port programatically.
Modified:
webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/SandeshaContext.java
Modified: webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/SandeshaContext.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/SandeshaContext.java?rev=265013&r1=265012&r2=265013&view=diff
==============================================================================
--- webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/SandeshaContext.java (original)
+++ webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/SandeshaContext.java Wed Aug 31 04:06:01 2005
@@ -72,6 +72,10 @@
private boolean sendOffer;
private long messageNumber;
private boolean sync;
+
+ static int clientListnerPort = -1;
+ public final int MIN_PORT = 0;
+ public final int MAX_PORT = 65525;
private RMReport report;
@@ -148,13 +152,17 @@
}
public SandeshaContext() throws AxisFault {
+ initSandeshaAsync();
+ }
+
+ private void initSandeshaAsync () throws AxisFault {
messageNumber = 0;
key = System.currentTimeMillis();
SandeshaContext.insideServer = false;
init(true);
startListener();
seqMap.put(new Long(key), this);
- report = new RMReport();
+ report = new RMReport();
}
public SandeshaContext(int sync) throws AxisFault {
@@ -166,6 +174,14 @@
seqMap.put(new Long(key), this);
report = new RMReport();
}
+
+ public SandeshaContext (Integer port) throws AxisFault {
+ int portVal = port.intValue();
+ if(portVal>MIN_PORT && portVal<MAX_PORT) {
+ this.clientListnerPort = portVal;
+ initSandeshaAsync();
+ }
+ }
public SandeshaContext(boolean insideServer) throws AxisFault {
messageNumber = 0;
@@ -380,7 +396,10 @@
if (!listenerStarted) {
listenerStarted = true;
try {
- clientListner = new ClientListener(PropertyLoader.getClientSideListenerPort());
+ int listnerPort = clientListnerPort;
+ if (listnerPort<0)
+ listnerPort = PropertyLoader.getClientSideListenerPort();
+ clientListner = new ClientListener(listnerPort);
clientListner.start();
} catch (IOException e) {
log.error(e);
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org