svn commit: r496802 - in /webservices/sandesha/trunk/java: src/org/apache/sandesha2/msgprocessors/ test/src/org/apache/sandesha2/scenarios/

[chamikara]

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