svn commit: r887101 - /camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/JettyHttpProducerConcurrentTest.java

[davsclaus]

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());
         }