You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by se...@apache.org on 2012/11/13 15:14:42 UTC
svn commit: r1408736 - /cxf/trunk/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/AbstractJAXRSContinuationsTest.java

Author: sergeyb
Date: Tue Nov 13 14:14:41 2012
New Revision: 1408736

URL: http://svn.apache.org/viewvc?rev=1408736&view=rev
Log:
Restoring the commented continuations test code

Modified:
    cxf/trunk/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/AbstractJAXRSContinuationsTest.java

Modified: cxf/trunk/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/AbstractJAXRSContinuationsTest.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/AbstractJAXRSContinuationsTest.java?rev=1408736&r1=1408735&r2=1408736&view=diff
==============================================================================
--- cxf/trunk/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/AbstractJAXRSContinuationsTest.java (original)
+++ cxf/trunk/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/AbstractJAXRSContinuationsTest.java Tue Nov 13 14:14:41 2012
@@ -64,24 +64,24 @@ public abstract class AbstractJAXRSConti
         ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 5, 0, TimeUnit.SECONDS,
                                                              new ArrayBlockingQueue<Runnable>(10));
         CountDownLatch startSignal = new CountDownLatch(1);
-        CountDownLatch doneSignal = new CountDownLatch(1);
+        CountDownLatch doneSignal = new CountDownLatch(5);
         
         executor.execute(new BookWorker("http://localhost:" + port + "/bookstore/" + pathSegment + "/1", 
                                         "1", 
                                         "CXF in Action1", startSignal, doneSignal));
-//        executor.execute(new BookWorker("http://localhost:" + port + "/bookstore/" + pathSegment + "/2", 
-//                                        "2", 
-//                                        "CXF in Action2", startSignal, doneSignal));
-//        executor.execute(new BookWorker("http://localhost:" + port + "/bookstore/" + pathSegment + "/3", 
-//                                        "3", 
-//                                        "CXF in Action3", startSignal, doneSignal));
-//        executor.execute(new BookWorker("http://localhost:" + port + "/bookstore/" + pathSegment + "/4", 
-//                                        "4", 
-//                                        "CXF in Action4", startSignal, doneSignal));
-//        executor.execute(new BookWorker("http://localhost:" + port + "/bookstore/" + pathSegment + "/5", 
-//                                        "5", 
-//                                        "CXF in Action5", startSignal, doneSignal));
-//        
+        executor.execute(new BookWorker("http://localhost:" + port + "/bookstore/" + pathSegment + "/2", 
+                                        "2", 
+                                        "CXF in Action2", startSignal, doneSignal));
+        executor.execute(new BookWorker("http://localhost:" + port + "/bookstore/" + pathSegment + "/3", 
+                                        "3", 
+                                        "CXF in Action3", startSignal, doneSignal));
+        executor.execute(new BookWorker("http://localhost:" + port + "/bookstore/" + pathSegment + "/4", 
+                                        "4", 
+                                        "CXF in Action4", startSignal, doneSignal));
+        executor.execute(new BookWorker("http://localhost:" + port + "/bookstore/" + pathSegment + "/5", 
+                                        "5", 
+                                        "CXF in Action5", startSignal, doneSignal));
+        
         startSignal.countDown();
         doneSignal.await(60, TimeUnit.SECONDS);
         executor.shutdownNow();