Author: andreasmyth
Date: Tue Nov 28 09:30:22 2006
New Revision: 480134

URL: http://svn.apache.org/viewvc?view=rev&rev=480134
Log:
Stop retransmission queue if started as part of a test (causing the NPEs on the 
thread in which ResendInitiator executes).
Re-enabled testTwoWayMessageLoss after using synchronous twoways.

Modified:
    
incubator/cxf/trunk/rt/ws/rm/src/test/java/org/apache/cxf/ws/rm/soap/RetransmissionQueueImplTest.java
    
incubator/cxf/trunk/systests/src/test/java/org/apache/cxf/systest/ws/rm/SequenceTest.java

Modified: 
incubator/cxf/trunk/rt/ws/rm/src/test/java/org/apache/cxf/ws/rm/soap/RetransmissionQueueImplTest.java
URL: 
http://svn.apache.org/viewvc/incubator/cxf/trunk/rt/ws/rm/src/test/java/org/apache/cxf/ws/rm/soap/RetransmissionQueueImplTest.java?view=diff&rev=480134&r1=480133&r2=480134
==============================================================================
--- 
incubator/cxf/trunk/rt/ws/rm/src/test/java/org/apache/cxf/ws/rm/soap/RetransmissionQueueImplTest.java
 (original)
+++ 
incubator/cxf/trunk/rt/ws/rm/src/test/java/org/apache/cxf/ws/rm/soap/RetransmissionQueueImplTest.java
 Tue Nov 28 09:30:22 2006
@@ -77,6 +77,7 @@
     
     public void tearDown() {
         control.verify();
+        queue.stop();
         messages.clear();
         properties.clear();
         sequences.clear();

Modified: 
incubator/cxf/trunk/systests/src/test/java/org/apache/cxf/systest/ws/rm/SequenceTest.java
URL: 
http://svn.apache.org/viewvc/incubator/cxf/trunk/systests/src/test/java/org/apache/cxf/systest/ws/rm/SequenceTest.java?view=diff&rev=480134&r1=480133&r2=480134
==============================================================================
--- 
incubator/cxf/trunk/systests/src/test/java/org/apache/cxf/systest/ws/rm/SequenceTest.java
 (original)
+++ 
incubator/cxf/trunk/systests/src/test/java/org/apache/cxf/systest/ws/rm/SequenceTest.java
 Tue Nov 28 09:30:22 2006
@@ -552,7 +552,7 @@
   
     }
     
-    public void xtestTwowayMessageLoss() throws Exception {
+    public void testTwowayMessageLoss() throws Exception {
         if (!doTestTwowayMessageLoss) {
             return;
         }
@@ -562,10 +562,10 @@
         RMManager manager = greeterBus.getExtension(RMManager.class);
         
manager.getRMAssertion().getBaseRetransmissionInterval().setMilliseconds(new 
BigInteger("2000"));
 
-        greeter.greetMeAsync("one");
-        greeter.greetMeAsync("two");
-        greeter.greetMeAsync("three");
-        greeter.greetMeAsync("four");
+        greeter.greetMe("one");
+        greeter.greetMe("two");
+        greeter.greetMe("three");
+        greeter.greetMe("four");
         
         awaitMessages(7, 10, 10000);
         


Reply via email to