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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
