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 2007/01/16 19:05:01 UTC
svn commit: r496802 - in /webservices/sandesha/trunk/java:
src/org/apache/sandesha2/msgprocessors/
test/src/org/apache/sandesha2/scenarios/
Author: chamikara
Date: Tue Jan 16 10:05:00 2007
New Revision: 496802
URL: http://svn.apache.org/viewvc?view=rev&rev=496802
Log:
A correction to set the polling mode to the RMDBean correctly.
Corected some mistakes I hd done in the last commit.
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/CreateSeqResponseMsgProcessor.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AnonymousEchoTest.java
Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/CreateSeqResponseMsgProcessor.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/CreateSeqResponseMsgProcessor.java?view=diff&rev=496802&r1=496801&r2=496802
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/CreateSeqResponseMsgProcessor.java (original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/CreateSeqResponseMsgProcessor.java Tue Jan 16 10:05:00 2007
@@ -190,7 +190,7 @@
if (Sandesha2Constants.SPEC_VERSIONS.v1_1.equals(createSeqResponseRMMsgCtx.getRMSpecVersion())) {
String replyToAddress = rmsBean.getReplyToEPR();
EndpointReference ref = new EndpointReference(replyToAddress);
- if(!rmsBean.isPollingMode() && (replyToAddress == null || ref.hasAnonymousAddress())) {
+ if(rmsBean.isPollingMode() && (replyToAddress == null || ref.hasAnonymousAddress())) {
rMDBean.setPollingMode(true);
SandeshaUtil.startPollingManager(configCtx);
}
Modified: webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java?view=diff&rev=496802&r1=496801&r2=496802
==============================================================================
--- webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java (original)
+++ webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java Tue Jan 16 10:05:00 2007
@@ -35,7 +35,7 @@
public void testAsyncEcho () throws Exception {
- String to = "http://127.0.0.1:" + 8070 + "/axis2/services/RMSampleService";
+ String to = "http://127.0.0.1:" + serverPort + "/axis2/services/RMSampleService";
String repoPath = "target" + File.separator + "repos" + File.separator + "client";
String axis2_xml = "target" + File.separator + "repos" + File.separator + "client" + File.separator + "client_axis2.xml";
Modified: webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AnonymousEchoTest.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AnonymousEchoTest.java?view=diff&rev=496802&r1=496801&r2=496802
==============================================================================
--- webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AnonymousEchoTest.java (original)
+++ webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AnonymousEchoTest.java Tue Jan 16 10:05:00 2007
@@ -51,15 +51,15 @@
startServer(repoPath, axis2_xml);
}
-// public void testSyncEchoWithOffer() throws Exception {
-//
-// Options clientOptions = new Options ();
-// String offeredSequenceID = SandeshaUtil.getUUID();
-// clientOptions.setProperty(SandeshaClientConstants.OFFERED_SEQUENCE_ID,offeredSequenceID);
-//
-// runSyncEchoTest(clientOptions);
-//
-// }
+ public void testSyncEchoWithOffer() throws Exception {
+
+ Options clientOptions = new Options ();
+ String offeredSequenceID = SandeshaUtil.getUUID();
+ clientOptions.setProperty(SandeshaClientConstants.OFFERED_SEQUENCE_ID,offeredSequenceID);
+
+ runSyncEchoTest(clientOptions);
+
+ }
public void testSyncEchoWithRMAnon() throws Exception {
@@ -69,7 +69,7 @@
}
public void runSyncEchoTest(Options clientOptions) throws Exception {
- String to = "http://127.0.0.1:" + 8070 + "/axis2/services/RMSampleService";
+ String to = "http://127.0.0.1:" + serverPort + "/axis2/services/RMSampleService";
String repoPath = "target" + File.separator + "repos" + File.separator + "client";
String axis2_xml = repoPath + File.separator + "client_axis2.xml";
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org