You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2009/12/04 09:20:18 UTC
svn commit: r887101 -
/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/JettyHttpProducerConcurrentTest.java
Author: davsclaus
Date: Fri Dec 4 08:20:11 2009
New Revision: 887101
URL: http://svn.apache.org/viewvc?rev=887101&view=rev
Log:
Fixed unit test
Modified:
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/JettyHttpProducerConcurrentTest.java
Modified: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/JettyHttpProducerConcurrentTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/JettyHttpProducerConcurrentTest.java?rev=887101&r1=887100&r2=887101&view=diff
==============================================================================
--- camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/JettyHttpProducerConcurrentTest.java (original)
+++ camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/JettyHttpProducerConcurrentTest.java Fri Dec 4 08:20:11 2009
@@ -39,7 +39,7 @@
@Test
public void testNoConcurrentProducers() throws Exception {
// give Jetty time to startup properly
- Thread.sleep(1000);
+ Thread.sleep(2000);
doSendMessages(1, 1);
}
@@ -47,7 +47,7 @@
@Test
public void testConcurrentProducers() throws Exception {
// give Jetty time to startup properly
- Thread.sleep(1000);
+ Thread.sleep(2000);
doSendMessages(10, 5);
}
@@ -57,7 +57,7 @@
getMockEndpoint("mock:result").assertNoDuplicates(body());
ExecutorService executor = Executors.newFixedThreadPool(poolSize);
- Map<Integer, Future> responses = new ConcurrentHashMap();
+ Map<Integer, Future> responses = new ConcurrentHashMap<Integer, Future>();
for (int i = 0; i < files; i++) {
final int index = i;
Future out = executor.submit(new Callable<Object>() {
@@ -73,7 +73,7 @@
assertEquals(files, responses.size());
// get all responses
- Set unique = new HashSet();
+ Set<Object> unique = new HashSet<Object>();
for (Future future : responses.values()) {
unique.add(future.get());
}