You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ch...@apache.org on 2006/05/20 22:16:06 UTC
svn commit: r408089 - in /webservices/sandesha/trunk: config/
samples/conf/userguide/ samples/src/sandesha2/samples/userguide/
src/org/apache/sandesha2/handlers/ src/org/apache/sandesha2/msgprocessors/
src/org/apache/sandesha2/msgreceivers/ src/org/apa...
Author: chamikara
Date: Sat May 20 13:16:05 2006
New Revision: 408089
URL: http://svn.apache.org/viewvc?rev=408089&view=rev
Log:
Corrected logging info->debug
Corrected the clients and test cases to get the acksTo value correctly.
Modified:
webservices/sandesha/trunk/config/module.xml
webservices/sandesha/trunk/samples/conf/userguide/services.xml
webservices/sandesha/trunk/samples/src/sandesha2/samples/userguide/AsyncPingClient.java
webservices/sandesha/trunk/samples/src/sandesha2/samples/userguide/SyncPingClient.java
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java
webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/TerminateSeqMsgProcessor.java
webservices/sandesha/trunk/src/org/apache/sandesha2/msgreceivers/RMMessageReceiver.java
webservices/sandesha/trunk/src/org/apache/sandesha2/util/TerminateManager.java
webservices/sandesha/trunk/src/org/apache/sandesha2/workers/InOrderInvoker.java
webservices/sandesha/trunk/src/org/apache/sandesha2/workers/Sender.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaClientTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaReportsTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaTestCase.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SquenceOfferTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressablePingTest.java
Modified: webservices/sandesha/trunk/config/module.xml
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/config/module.xml?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/config/module.xml (original)
+++ webservices/sandesha/trunk/config/module.xml Sat May 20 13:16:05 2006
@@ -92,7 +92,7 @@
<wsrm:InactivityTimeout>60</wsrm:InactivityTimeout>
- <wsrm:InactivityTimeoutMeasure>minutes</wsrm:InactivityTimeoutMeasure>
+ <wsrm:InactivityTimeoutMeasure>seconds</wsrm:InactivityTimeoutMeasure>
<wsrm:InvokeInOrder>true</wsrm:InvokeInOrder>
Modified: webservices/sandesha/trunk/samples/conf/userguide/services.xml
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/samples/conf/userguide/services.xml?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/conf/userguide/services.xml (original)
+++ webservices/sandesha/trunk/samples/conf/userguide/services.xml Sat May 20 13:16:05 2006
@@ -1,12 +1,14 @@
<service name="RMSampleService">
<parameter name="ServiceClass" locked="xsd:false">sandesha2.samples.userguide.RMSampleService</parameter>
- <module ref="sandesha2" />
- <description>
+
+ <description>
The userguide Sample service.
- </description>
+ </description>
+ <module ref="sandesha2" />
+
<operation name="ping" mep="http://www.w3.org/2004/08/wsdl/in-only">
<messageReceiver class="org.apache.axis2.receivers.RawXMLINOnlyMessageReceiver" />
</operation>
Modified: webservices/sandesha/trunk/samples/src/sandesha2/samples/userguide/AsyncPingClient.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/samples/src/sandesha2/samples/userguide/AsyncPingClient.java?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/src/sandesha2/samples/userguide/AsyncPingClient.java (original)
+++ webservices/sandesha/trunk/samples/src/sandesha2/samples/userguide/AsyncPingClient.java Sat May 20 13:16:05 2006
@@ -46,14 +46,8 @@
private String toPort = "8070";
- private String ackIP = "127.0.0.1";
-
- private String ackPort = "9070";
-
private String toEPR = "http://" + toIP + ":" + toPort + "/axis2/services/RMSampleService";
- private String acksToEPR = "http://" + ackIP + ":" + ackPort + "/axis2/services/" + "__ANONYMOUS_SERVICE__";
-
private static String SANDESHA2_HOME = "<SANDESHA2_HOME>"; //Change this to ur path.
private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME + File.separator + "target" + File.separator +"repos" + File.separator + "client" + File.separator; //this will be available after a maven build
@@ -93,7 +87,10 @@
// clientOptions.setProperty(SandeshaClient.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.v1_1); //uncomment this to send the messages according to the v1_1 spec.
clientOptions.setTo(new EndpointReference (toEPR));
- clientOptions.setProperty(SandeshaClientConstants.AcksTo,acksToEPR);
+
+ EndpointReference endpoint = serviceClient.getMyEPR(Constants.TRANSPORT_HTTP);
+ clientOptions.setProperty(SandeshaClientConstants.AcksTo,endpoint.getAddress());
+
clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP);
clientOptions.setAction("urn:wsrm:Ping");
Modified: webservices/sandesha/trunk/samples/src/sandesha2/samples/userguide/SyncPingClient.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/samples/src/sandesha2/samples/userguide/SyncPingClient.java?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/src/sandesha2/samples/userguide/SyncPingClient.java (original)
+++ webservices/sandesha/trunk/samples/src/sandesha2/samples/userguide/SyncPingClient.java Sat May 20 13:16:05 2006
@@ -51,7 +51,6 @@
private String toEPR = "http://" + toIP + ":" + toPort + "/axis2/services/RMSampleService";
private String transportToEPR = "http://" + toIP + ":" + transportToPort + "/axis2/services/RMSampleService";
-
private static String SANDESHA2_HOME = "<SANDESHA2_HOME>"; //Change this to ur path.
private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME + File.separator + "target" + File.separator +"repos" + File.separator + "client" + File.separator; //this will be available after a maven build
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java Sat May 20 13:16:05 2006
@@ -130,7 +130,7 @@
AxisFault axisFault = getAxisFaultFromFromSOAPFault(faultPart);
// reporting the fault
- log.error(axisFault);
+// log.error(axisFault);
if (faultCallback != null) {
faultCallback.onError(axisFault);
}
@@ -250,7 +250,7 @@
if (emptyBody) {
if (sequence.getLastMessage() != null) {
- log.info("Empty Body LastMessage Received");
+ log.debug ("Empty Body LastMessage Received");
drop = true;
if (receivedMsgsBean == null) {
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/TerminateSeqMsgProcessor.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/TerminateSeqMsgProcessor.java?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/TerminateSeqMsgProcessor.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/TerminateSeqMsgProcessor.java Sat May 20 13:16:05 2006
@@ -305,7 +305,7 @@
if (terminated != null
&& "true".equals(terminated)) {
String message = "Terminate was added previously.";
- log.info(message);
+ log.debug(message);
return;
}
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/msgreceivers/RMMessageReceiver.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/src/org/apache/sandesha2/msgreceivers/RMMessageReceiver.java?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/msgreceivers/RMMessageReceiver.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/msgreceivers/RMMessageReceiver.java Sat May 20 13:16:05 2006
@@ -41,10 +41,10 @@
private static final Log log = LogFactory.getLog(RMMessageReceiver.class.getName());
public final void receive(MessageContext messgeCtx) throws AxisFault {
- log.info("RM MESSSAGE RECEIVER WAS CALLED");
+ log.debug("RM MESSSAGE RECEIVER WAS CALLED");
RMMsgContext rmMsgCtx = MsgInitializer.initializeMessage(messgeCtx);
- log.info("MsgReceiver got type:" + SandeshaUtil.getMessageTypeString(rmMsgCtx.getMessageType()));
+ log.debug("MsgReceiver got type:" + SandeshaUtil.getMessageTypeString(rmMsgCtx.getMessageType()));
}
}
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/util/TerminateManager.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/src/org/apache/sandesha2/util/TerminateManager.java?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/util/TerminateManager.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/util/TerminateManager.java Sat May 20 13:16:05 2006
@@ -347,7 +347,7 @@
if (terminated != null && terminated.getValue() != null
&& "true".equals(terminated.getValue())) {
String message = "Terminate was added previously.";
- log.info(message);
+ log.debug (message);
}
RMMsgContext terminateRMMessage = RMMsgCreator
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/workers/InOrderInvoker.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/src/org/apache/sandesha2/workers/InOrderInvoker.java?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/workers/InOrderInvoker.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/workers/InOrderInvoker.java Sat May 20 13:16:05 2006
@@ -192,7 +192,7 @@
invoked = true;
- } catch (AxisFault e) {
+ } catch (Exception e) {
throw new SandeshaException(e);
} finally {
transaction = storageManager.getTransaction();
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/workers/Sender.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/src/org/apache/sandesha2/workers/Sender.java?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/workers/Sender.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/workers/Sender.java Sat May 20 13:16:05 2006
@@ -186,7 +186,7 @@
//TODO change this to cater for security.
transportSender.invoke(msgCtx);
successfullySent = true;
- } catch (AxisFault e) {
+ } catch (Exception e) {
// TODO Auto-generated catch block
String message = "Sandesha2 got an exception when trying to send the message";
log.debug(message,e);
@@ -349,7 +349,7 @@
} catch (Exception e) {
String message = "No valid Sync response...";
- log.info(message);
+ log.debug(message);
throw new SandeshaException(message, e);
}
}
Modified: webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaClientTest.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaClientTest.java?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaClientTest.java (original)
+++ webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaClientTest.java Sat May 20 13:16:05 2006
@@ -86,7 +86,6 @@
String to = "http://127.0.0.1:" + serverPort + "/axis2/services/RMSampleService";
String transportTo = "http://127.0.0.1:" + serverPort + "/axis2/services/RMSampleService";
- String acksToEPR = "http://127.0.0.1:6060/axis2/services/__ANONYMOUS_SERVICE__";
String repoPath = "target" + File.separator + "repos" + File.separator + "client";
String axis2_xml = "target" + File.separator + "repos" + File.separator + "client" + File.separator + "client_axis2.xml";
@@ -100,13 +99,16 @@
String sequenceKey = SandeshaUtil.getUUID();
clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
- clientOptions.setProperty(SandeshaClientConstants.AcksTo,acksToEPR);
+
+ ServiceClient serviceClient = new ServiceClient (configContext,null);
+
+ String acksTo = serviceClient.getMyEPR(Constants.TRANSPORT_HTTP).getAddress();
+ clientOptions.setProperty(SandeshaClientConstants.AcksTo,acksTo);
clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP);
String offeredSequenceID = SandeshaUtil.getUUID();
clientOptions.setProperty(SandeshaClientConstants.OFFERED_SEQUENCE_ID,offeredSequenceID);
- ServiceClient serviceClient = new ServiceClient (configContext,null);
serviceClient.setOptions(clientOptions);
//serviceClient.
Modified: webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaReportsTest.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaReportsTest.java?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaReportsTest.java (original)
+++ webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaReportsTest.java Sat May 20 13:16:05 2006
@@ -106,7 +106,6 @@
String to = "http://127.0.0.1:" + serverPort + "/axis2/services/RMSampleService";
String transportTo = "http://127.0.0.1:" + serverPort + "/axis2/services/RMSampleService";
- String acksToEPR = "http://127.0.0.1:6060/axis2/services/__ANONYMOUS_SERVICE__";
String repoPath = "target" + File.separator + "repos" + File.separator + "client";
String axis2_xml = "target" + File.separator + "repos" + File.separator + "client" + File.separator + "client_axis2.xml";
@@ -120,10 +119,14 @@
String sequenceKey = SandeshaUtil.getUUID();
clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
- clientOptions.setProperty(SandeshaClientConstants.AcksTo,acksToEPR);
- clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP);
ServiceClient serviceClient = new ServiceClient (configContext,null);
+ String acksTo = serviceClient.getMyEPR(Constants.TRANSPORT_HTTP).getAddress();
+ clientOptions.setProperty(SandeshaClientConstants.AcksTo,acksTo);
+
+ clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP);
+
+
serviceClient.setOptions(clientOptions);
//serviceClient.
Modified: webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaTestCase.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaTestCase.java?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaTestCase.java (original)
+++ webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaTestCase.java Sat May 20 13:16:05 2006
@@ -102,6 +102,10 @@
else
return null;
}
+
+ public void testMethod () {
+
+ }
}
Modified: webservices/sandesha/trunk/test/src/org/apache/sandesha2/SquenceOfferTest.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/test/src/org/apache/sandesha2/SquenceOfferTest.java?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/test/src/org/apache/sandesha2/SquenceOfferTest.java (original)
+++ webservices/sandesha/trunk/test/src/org/apache/sandesha2/SquenceOfferTest.java Sat May 20 13:16:05 2006
@@ -104,7 +104,6 @@
String to = "http://127.0.0.1:" + serverPort + "/axis2/services/RMSampleService";
String transportTo = "http://127.0.0.1:" + serverPort + "/axis2/services/RMSampleService";
- String acksToEPR = "http://127.0.0.1:6060/axis2/services/__ANONYMOUS_SERVICE__";
String repoPath = "target" + File.separator + "repos" + File.separator + "client";
String axis2_xml = "target" + File.separator + "repos" + File.separator + "client" + File.separator + "client_axis2.xml";
@@ -118,13 +117,17 @@
String sequenceKey = SandeshaUtil.getUUID();
clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
- clientOptions.setProperty(SandeshaClientConstants.AcksTo,acksToEPR);
+
+ ServiceClient serviceClient = new ServiceClient (configContext,null);
+
+ String acksTo = serviceClient.getMyEPR(Constants.TRANSPORT_HTTP).getAddress();
+ clientOptions.setProperty(SandeshaClientConstants.AcksTo,acksTo);
+
clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP);
String offeredSequenceID = SandeshaUtil.getUUID();
clientOptions.setProperty(SandeshaClientConstants.OFFERED_SEQUENCE_ID,offeredSequenceID);
- ServiceClient serviceClient = new ServiceClient (configContext,null);
serviceClient.setOptions(clientOptions);
//serviceClient.
Modified: webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java (original)
+++ webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java Sat May 20 13:16:05 2006
@@ -90,7 +90,6 @@
String to = "http://127.0.0.1:" + serverPort + "/axis2/services/RMSampleService";
String transportTo = "http://127.0.0.1:" + serverPort + "/axis2/services/RMSampleService";
- String acksToEPR = "http://127.0.0.1:6060/axis2/services/__ANONYMOUS_SERVICE__";
String repoPath = "target" + File.separator + "repos" + File.separator + "client";
String axis2_xml = "target" + File.separator + "repos" + File.separator + "client" + File.separator + "client_axis2.xml";
@@ -104,10 +103,13 @@
String sequenceKey = SandeshaUtil.getUUID();
clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
- clientOptions.setProperty(SandeshaClientConstants.AcksTo,acksToEPR);
- clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP);
ServiceClient serviceClient = new ServiceClient (configContext,null);
+
+ String acksTo = serviceClient.getMyEPR(Constants.TRANSPORT_HTTP).getAddress();
+ clientOptions.setProperty(SandeshaClientConstants.AcksTo,acksTo);
+ clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP);
+
serviceClient.setOptions(clientOptions);
//serviceClient.
@@ -140,7 +142,6 @@
String to = "http://127.0.0.1:" + serverPort + "/axis2/services/RMSampleService";
String transportTo = "http://127.0.0.1:" + serverPort + "/axis2/services/RMSampleService";
- String acksToEPR = "http://127.0.0.1:6060/axis2/services/__ANONYMOUS_SERVICE__";
String repoPath = "target" + File.separator + "repos" + File.separator + "client";
String axis2_xml = "target" + File.separator + "repos" + File.separator + "client" + File.separator + "client_axis2.xml";
@@ -154,13 +155,16 @@
String sequenceKey = SandeshaUtil.getUUID();
clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
- clientOptions.setProperty(SandeshaClientConstants.AcksTo,acksToEPR);
+
+ ServiceClient serviceClient = new ServiceClient (configContext,null);
+
+ String acksTo = serviceClient.getMyEPR(Constants.TRANSPORT_HTTP).getAddress();
+ clientOptions.setProperty(SandeshaClientConstants.AcksTo,acksTo);
clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP);
String offeredSequeiceId = SandeshaUtil.getUUID();
clientOptions.setProperty(SandeshaClientConstants.OFFERED_SEQUENCE_ID,offeredSequeiceId);
- ServiceClient serviceClient = new ServiceClient (configContext,null);
serviceClient.setOptions(clientOptions);
//serviceClient.
Modified: webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressablePingTest.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressablePingTest.java?rev=408089&r1=408088&r2=408089&view=diff
==============================================================================
--- webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressablePingTest.java (original)
+++ webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressablePingTest.java Sat May 20 13:16:05 2006
@@ -103,7 +103,6 @@
String to = "http://127.0.0.1:" + serverPort + "/axis2/services/RMSampleService";
String transportTo = "http://127.0.0.1:" + serverPort + "/axis2/services/RMSampleService";
- String acksToEPR = "http://127.0.0.1:6060/axis2/services/__ANONYMOUS_SERVICE__";
String repoPath = "target" + File.separator + "repos" + File.separator + "client";
String axis2_xml = "target" + File.separator + "repos" + File.separator + "client" + File.separator + "client_axis2.xml";
@@ -119,12 +118,14 @@
String sequenceKey = "sequence2";
clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
- clientOptions.setProperty(SandeshaClientConstants.AcksTo,acksToEPR);
- clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP);
ServiceClient serviceClient = new ServiceClient (configContext,null);
- //serviceClient.
+ String acksTo = serviceClient.getMyEPR(Constants.TRANSPORT_HTTP).getAddress();
+ clientOptions.setProperty(SandeshaClientConstants.AcksTo,acksTo);
+ clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP);
+
+ //serviceClient.
serviceClient.setOptions(clientOptions);
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org