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/18 21:14:55 UTC
svn commit: r1410978 -
/cxf/trunk/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/AbstractJAXRSContinuationsTest.java
Author: sergeyb
Date: Sun Nov 18 20:14:53 2012
New Revision: 1410978
URL: http://svn.apache.org/viewvc?rev=1410978&view=rev
Log:
Restoring the test
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=1410978&r1=1410977&r2=1410978&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 Sun Nov 18 20:14:53 2012
@@ -97,24 +97,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();