svn commit: r1045031 - /cxf/trunk/systests/ws-specs/src/test/java/org/apache/cxf/systest/ws/rm/ServerPersistenceTest.java

[ffang]

Author: ffang
Date: Mon Dec 13 08:47:44 2010
New Revision: 1045031

URL: http://svn.apache.org/viewvc?rev=1045031&view=rev
Log:
[CXF-3179]ServerPersistenceTest fail intermittently

Modified:
    
cxf/trunk/systests/ws-specs/src/test/java/org/apache/cxf/systest/ws/rm/ServerPersistenceTest.java

Modified: 
cxf/trunk/systests/ws-specs/src/test/java/org/apache/cxf/systest/ws/rm/ServerPersistenceTest.java
URL: 
http://svn.apache.org/viewvc/cxf/trunk/systests/ws-specs/src/test/java/org/apache/cxf/systest/ws/rm/ServerPersistenceTest.java?rev=1045031&r1=1045030&r2=1045031&view=diff
==============================================================================
--- 
cxf/trunk/systests/ws-specs/src/test/java/org/apache/cxf/systest/ws/rm/ServerPersistenceTest.java
 (original)
+++ 
cxf/trunk/systests/ws-specs/src/test/java/org/apache/cxf/systest/ws/rm/ServerPersistenceTest.java
 Mon Dec 13 08:47:44 2010
@@ -35,6 +35,8 @@ import org.apache.cxf.greeter_control.Co
 import org.apache.cxf.greeter_control.Greeter;
 import org.apache.cxf.greeter_control.GreeterService;
 import org.apache.cxf.greeter_control.types.GreetMeResponse;
+import org.apache.cxf.interceptor.LoggingInInterceptor;
+import org.apache.cxf.interceptor.LoggingOutInterceptor;
 import org.apache.cxf.systest.ws.util.ConnectionHelper;
 import org.apache.cxf.systest.ws.util.InMessageRecorder;
 import org.apache.cxf.systest.ws.util.MessageFlow;
@@ -156,6 +158,8 @@ public class ServerPersistenceTest exten
         
         out.getOutboundMessages().clear();
         in.getInboundMessages().clear();
+        greeterBus.getOutInterceptors().add(new LoggingOutInterceptor());
+        greeterBus.getInInterceptors().add(new LoggingInInterceptor());
         
         responses[3] = greeter.greetMeAsync("four");
         verifyRetransmissionQueue();
@@ -239,7 +243,7 @@ public class ServerPersistenceTest exten
   
     
     void verifyRetransmissionQueue() throws Exception {
-        awaitMessages(1, 3, 40000);
+        awaitMessages(3, 5, 40000);
         
         boolean empty = 
greeterBus.getExtension(RMManager.class).getRetransmissionQueue().isEmpty();
         assertTrue("Retransmission Queue is not empty", empty);