camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject svn commit: r937951 [2/2] - in /camel/trunk/camel-core/src: main/java/org/apache/camel/model/ main/java/org/apache/camel/util/ test/java/org/apache/camel/builder/ test/java/org/apache/camel/component/bean/ test/java/org/apache/camel/component/bean/issu...
Date Mon, 26 Apr 2010 07:46:41 GMT
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeMultipleCorrelationTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeMultipleCorrelationTest.java?rev=937951&r1=937950&r2=937951&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeMultipleCorrelationTest.java
(original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeMultipleCorrelationTest.java
Mon Apr 26 07:46:39 2010
@@ -28,6 +28,7 @@ import org.apache.camel.component.mock.M
  */
 public class AggregateGroupedExchangeMultipleCorrelationTest extends ContextTestSupport {
 
+    @SuppressWarnings("unchecked")
     public void testGrouped() throws Exception {
         // START SNIPPET: e2
         MockEndpoint result = getMockEndpoint("mock:result");

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizePredicateTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizePredicateTest.java?rev=937951&r1=937950&r2=937951&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizePredicateTest.java
(original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizePredicateTest.java
Mon Apr 26 07:46:39 2010
@@ -28,6 +28,7 @@ import org.apache.camel.component.mock.M
  */
 public class AggregateGroupedExchangeSizePredicateTest extends ContextTestSupport {
 
+    @SuppressWarnings("unchecked")
     public void testGroupedSize() throws Exception {
         MockEndpoint result = getMockEndpoint("mock:result");
 

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizeTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizeTest.java?rev=937951&r1=937950&r2=937951&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizeTest.java
(original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizeTest.java
Mon Apr 26 07:46:39 2010
@@ -28,6 +28,7 @@ import org.apache.camel.component.mock.M
  */
 public class AggregateGroupedExchangeSizeTest extends ContextTestSupport {
 
+    @SuppressWarnings("unchecked")
     public void testGroupedSize() throws Exception {
         MockEndpoint result = getMockEndpoint("mock:result");
 

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeTest.java?rev=937951&r1=937950&r2=937951&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeTest.java
(original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeTest.java
Mon Apr 26 07:46:39 2010
@@ -28,6 +28,7 @@ import org.apache.camel.component.mock.M
  */
 public class AggregateGroupedExchangeTest extends ContextTestSupport {
 
+    @SuppressWarnings("unchecked")
     public void testGrouped() throws Exception {
         // START SNIPPET: e2
         MockEndpoint result = getMockEndpoint("mock:result");

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorTest.java?rev=937951&r1=937950&r2=937951&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorTest.java
(original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorTest.java
Mon Apr 26 07:46:39 2010
@@ -49,7 +49,7 @@ public class AggregatorTest extends Cont
         MockEndpoint resultEndpoint = resolveMandatoryEndpoint("mock:result", MockEndpoint.class);
 
         resultEndpoint.expectedMessageCount(1);
-        Map headers = new HashMap();
+        Map<String, Object> headers = new HashMap<String, Object>();
         headers.put("cheese", 123);
         headers.put("bar", "viper bar");
 

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AlbertoAggregatorTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AlbertoAggregatorTest.java?rev=937951&r1=937950&r2=937951&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AlbertoAggregatorTest.java
(original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AlbertoAggregatorTest.java
Mon Apr 26 07:46:39 2010
@@ -73,6 +73,7 @@ public class AlbertoAggregatorTest exten
 
         return new RouteBuilder() {
             AggregationStrategy surnameAggregator = new AggregationStrategy() {
+                @SuppressWarnings("unchecked")
                 public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
                     debugIn("Surname Aggregator", oldExchange, newExchange);
 

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteNoWaitWithErrorTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteNoWaitWithErrorTest.java?rev=937951&r1=937950&r2=937951&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteNoWaitWithErrorTest.java
(original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteNoWaitWithErrorTest.java
Mon Apr 26 07:46:39 2010
@@ -60,7 +60,7 @@ public class AsyncRouteNoWaitWithErrorTe
 
         // get the response from the future
         try {
-            String response = context.getTypeConverter().convertTo(String.class, future);
+            context.getTypeConverter().convertTo(String.class, future);
             fail("Should have thrown an exception");
         } catch (CamelExecutionException e) {
             // expected an execution exception
@@ -77,7 +77,7 @@ public class AsyncRouteNoWaitWithErrorTe
         // send a request reply to the direct start endpoint, but will use
         // future type converter that will wait for the response
         try {
-            String response = template.requestBody("direct:start", "Hello", String.class);
+            template.requestBody("direct:start", "Hello", String.class);
             fail("Should have thrown an exception");
         } catch (CamelExecutionException e) {
             // expected an execution exception

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteWithErrorTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteWithErrorTest.java?rev=937951&r1=937950&r2=937951&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteWithErrorTest.java
(original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteWithErrorTest.java
Mon Apr 26 07:46:39 2010
@@ -41,7 +41,7 @@ public class AsyncRouteWithErrorTest ext
 
         // send a request reply to the direct start endpoint
         try {
-            Object out = template.requestBody("direct:start", "Hello");
+            template.requestBody("direct:start", "Hello");
         } catch (CamelExecutionException e) {
             // expected an execution exception
             assertEquals("Damn forced by unit test", e.getCause().getMessage());
@@ -62,7 +62,7 @@ public class AsyncRouteWithErrorTest ext
         // send a request reply to the direct start endpoint, but will use
         // future type converter that will wait for the response
         try {
-            String response = template.requestBody("direct:start", "Hello", String.class);
+            template.requestBody("direct:start", "Hello", String.class);
             fail("Should have thrown an exception");
         } catch (CamelExecutionException e) {
             // expected an execution exception

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/util/CollectionHelperTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/util/CollectionHelperTest.java?rev=937951&r1=937950&r2=937951&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/util/CollectionHelperTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/util/CollectionHelperTest.java Mon
Apr 26 07:46:39 2010
@@ -43,7 +43,7 @@ public class CollectionHelperTest extend
     }
 
     public void testSize() {
-        Map map = new HashMap();
+        Map<String, Object> map = new HashMap<String, Object>();
         map.put("foo", 123);
         map.put("bar", 456);
 

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/util/DefaultTimeoutMapTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/util/DefaultTimeoutMapTest.java?rev=937951&r1=937950&r2=937951&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/util/DefaultTimeoutMapTest.java
(original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/util/DefaultTimeoutMapTest.java
Mon Apr 26 07:46:39 2010
@@ -36,7 +36,7 @@ public class DefaultTimeoutMapTest exten
     }
 
     public void testDefaultTimeoutMapPurge() throws Exception {
-        DefaultTimeoutMap map = new DefaultTimeoutMap();
+        DefaultTimeoutMap<String, Integer> map = new DefaultTimeoutMap<String, Integer>();
         assertTrue(map.currentTime() > 0);
 
         assertEquals(0, map.size());
@@ -53,7 +53,7 @@ public class DefaultTimeoutMapTest exten
     }
 
     public void testDefaultTimeoutMapGetPurge() throws Exception {
-        DefaultTimeoutMap map = new DefaultTimeoutMap();
+        DefaultTimeoutMap<String, Integer> map = new DefaultTimeoutMap<String, Integer>();
         assertTrue(map.currentTime() > 0);
 
         assertEquals(0, map.size());
@@ -63,7 +63,7 @@ public class DefaultTimeoutMapTest exten
 
         Thread.sleep(2000);
 
-        assertEquals(123, map.get("A"));
+        assertEquals(123, (int)map.get("A"));
 
         // will purge and remove old entries
         map.purge();
@@ -73,7 +73,7 @@ public class DefaultTimeoutMapTest exten
     }
 
     public void testDefaultTimeoutMapGetRemove() throws Exception {
-        DefaultTimeoutMap map = new DefaultTimeoutMap();
+        DefaultTimeoutMap<String, Integer> map = new DefaultTimeoutMap<String, Integer>();
         assertTrue(map.currentTime() > 0);
 
         assertEquals(0, map.size());
@@ -81,7 +81,7 @@ public class DefaultTimeoutMapTest exten
         map.put("A", 123, 500);
         assertEquals(1, map.size());
 
-        assertEquals(123, map.get("A"));
+        assertEquals(123, (int)map.get("A"));
 
         map.remove("A");
         assertEquals(null, map.get("A"));
@@ -89,7 +89,7 @@ public class DefaultTimeoutMapTest exten
     }
 
     public void testDefaultTimeoutMapGetKeys() throws Exception {
-        DefaultTimeoutMap map = new DefaultTimeoutMap();
+        DefaultTimeoutMap<String, Integer> map = new DefaultTimeoutMap<String, Integer>();
         assertTrue(map.currentTime() > 0);
 
         assertEquals(0, map.size());
@@ -106,7 +106,7 @@ public class DefaultTimeoutMapTest exten
     public void testExecutor() throws Exception {
         ScheduledExecutorService e = ExecutorServiceHelper.newScheduledThreadPool(2, null,
"foo", true);
 
-        DefaultTimeoutMap map = new DefaultTimeoutMap(e, 500);
+        DefaultTimeoutMap<String, Integer> map = new DefaultTimeoutMap<String, Integer>(e,
500);
         assertEquals(500, map.getPurgePollTime());
 
         map.put("A", 123, 1000);

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/util/ExchangeHelperTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/util/ExchangeHelperTest.java?rev=937951&r1=937950&r2=937951&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/util/ExchangeHelperTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/util/ExchangeHelperTest.java Mon
Apr 26 07:46:39 2010
@@ -116,7 +116,7 @@ public class ExchangeHelperTest extends 
         exchange.getOut().setBody("bar");
         exchange.getOut().setHeader("quote", "Camel rocks");
 
-        Map map = new HashMap();
+        Map<String, Object> map = new HashMap<String, Object>();
         ExchangeHelper.populateVariableMap(exchange, map);
 
         assertEquals(8, map.size());

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/util/ExpressionListComparatorTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/util/ExpressionListComparatorTest.java?rev=937951&r1=937950&r2=937951&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/util/ExpressionListComparatorTest.java
(original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/util/ExpressionListComparatorTest.java
Mon Apr 26 07:46:39 2010
@@ -31,6 +31,7 @@ public class ExpressionListComparatorTes
 
     private class MyFooExpression implements Expression {
 
+        @SuppressWarnings("unchecked")
         public <T> T evaluate(Exchange exchange, Class<T> type) {
             return (T) "foo";
         }
@@ -38,6 +39,7 @@ public class ExpressionListComparatorTes
 
     private class MyBarExpression implements Expression {
 
+        @SuppressWarnings("unchecked")
         public <T> T evaluate(Exchange exchange, Class<T> type) {
             return (T) "bar";
         }

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/util/URISupportTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/util/URISupportTest.java?rev=937951&r1=937950&r2=937951&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/util/URISupportTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/util/URISupportTest.java Mon Apr
26 07:46:39 2010
@@ -96,7 +96,7 @@ public class URISupportTest extends Cont
 
     public void testCreateRemaingURI() throws Exception {
         URI original = new URI("http://camel.apache.org");
-        Map param = new HashMap();
+        Map<Object, Object> param = new HashMap<Object, Object>();
         param.put("foo", "123");
         URI newUri = URISupport.createRemainingURI(original, param);
         assertNotNull(newUri);

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/util/jndi/JndiTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/util/jndi/JndiTest.java?rev=937951&r1=937950&r2=937951&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/util/jndi/JndiTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/util/jndi/JndiTest.java Mon Apr
26 07:46:39 2010
@@ -32,6 +32,7 @@ import org.apache.camel.TestSupport;
 public class JndiTest extends TestSupport {
     protected Context context;
 
+    @SuppressWarnings("unchecked")
     public static Context createInitialContext() throws Exception {
         InputStream in = JndiTest.class.getClassLoader().getResourceAsStream("jndi-example.properties");
         assertNotNull("Cannot find jndi-example.properties on the classpath!", in);



Mime
View raw message