Return-Path: Delivered-To: apmail-camel-commits-archive@www.apache.org Received: (qmail 91824 invoked from network); 26 Apr 2010 07:47:32 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 26 Apr 2010 07:47:32 -0000 Received: (qmail 30067 invoked by uid 500); 26 Apr 2010 07:47:32 -0000 Delivered-To: apmail-camel-commits-archive@camel.apache.org Received: (qmail 30013 invoked by uid 500); 26 Apr 2010 07:47:31 -0000 Mailing-List: contact commits-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@camel.apache.org Delivered-To: mailing list commits@camel.apache.org Received: (qmail 30006 invoked by uid 99); 26 Apr 2010 07:47:31 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 26 Apr 2010 07:47:31 +0000 X-ASF-Spam-Status: No, hits=-1363.8 required=10.0 tests=ALL_TRUSTED,AWL X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 26 Apr 2010 07:47:26 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id E387E2388978; Mon, 26 Apr 2010 07:46:42 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r937951 [1/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 -0000 To: commits@camel.apache.org From: ningjiang@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20100426074642.E387E2388978@eris.apache.org> Author: ningjiang Date: Mon Apr 26 07:46:39 2010 New Revision: 937951 URL: http://svn.apache.org/viewvc?rev=937951&view=rev Log: Removed useless @SuppressWarnings from camel-core tests Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/model/WireTapDefinition.java camel/trunk/camel-core/src/main/java/org/apache/camel/util/UnsafeUriCharactersEncoder.java camel/trunk/camel-core/src/test/java/org/apache/camel/builder/BuilderWithScopesTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/builder/ExceptionBuilderTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/OrderServiceBean.java camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/issues/BeanRouteToDerivedClassTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginAndCommitExpressionRenameStrategyTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginAndCommitRenameStrategyTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginExpressionRenameStrategyTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginRenameStrategyTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerCommitRenameStrategyTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/NewFileConsumeTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/NewFileProduceTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/XPathToFileTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/component/mock/MockExpectedBodiesAsListTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/component/pojo/PojoRouteTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/converter/ConverterTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/converter/IOConverterTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/impl/CamelPostProcessorHelperTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultConsumerCacheTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultConsumerTemplateTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateAsyncTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/impl/ExpressionAdapterTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/impl/ExpressionSupportTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/impl/RouteWithMistypedComponentNameTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/impl/SimpleRegistryTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/impl/StringDataFormatTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/impl/TypeConverterRegistryTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/issues/CoarseGrainedProcessorDefinitionIssueTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/issues/DavidSiefertTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/issues/GertJBIIssueTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/issues/ProxyReturnNullIssueTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/issues/SplitPropertiesFileIssueTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/language/BeanLanguageInvalidOGNLTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/language/SimpleTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ExceptionWithManagementTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedDelayerTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedErrorHandlerOptionsTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedErrorHandlerRedeliveryTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedErrorHandlerTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRegisterCamelContextTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRegisterRouteTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteContextTracerTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteShutdownAndStartTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopAndStartTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedSendProcessorTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedSuspendedServiceTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedThreadPoolTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedThrottlerTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedTracerOptionsTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedUnregisterCamelContextTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedUnregisterProducerTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/model/XmlParseTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ChoiceWithEndTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ClaimCheckTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/DeadLetterChannelHandledExampleTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/DeadLetterChannelRedeliverWithDelayBlockingTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/FileIdempotentConsumerTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/IdempotentConsumerEagerTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/NavigateRouteTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/RandomLoadBalanceJavaDSLBuilderTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/RemoveHeadersTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SetHeaderTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitWithEndTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionSizeFallbackTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionSizeTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionTimeoutFallbackTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionTimeoutPerGroupTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionTimeoutTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeBatchSizeTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeMultipleCorrelationTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizePredicateTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizeTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AlbertoAggregatorTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteNoWaitWithErrorTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteWithErrorTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/util/CollectionHelperTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/util/DefaultTimeoutMapTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/util/ExchangeHelperTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/util/ExpressionListComparatorTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/util/URISupportTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/util/jndi/JndiTest.java Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/model/WireTapDefinition.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/model/WireTapDefinition.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/main/java/org/apache/camel/model/WireTapDefinition.java (original) +++ camel/trunk/camel-core/src/main/java/org/apache/camel/model/WireTapDefinition.java Mon Apr 26 07:46:39 2010 @@ -100,15 +100,13 @@ public class WireTapDefinition extends S public String getShortName() { return "wireTap"; } - - @SuppressWarnings("unchecked") + public ProcessorDefinition executorService(ExecutorService executorService) { // wiretap has no outputs and therefore we cannot use custom wiretap builder methods in Java DSL // as the Java DSL is stretched so far we can using regular Java throw new UnsupportedOperationException("wireTap does not support these builder methods"); } - - @SuppressWarnings("unchecked") + public ProcessorDefinition executorServiceRef(String executorServiceRef) { // wiretap has no outputs and therefore we cannot use custom wiretap builder methods in Java DSL // as the Java DSL is stretched so far we can using regular Java Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/util/UnsafeUriCharactersEncoder.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/util/UnsafeUriCharactersEncoder.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/main/java/org/apache/camel/util/UnsafeUriCharactersEncoder.java (original) +++ camel/trunk/camel-core/src/main/java/org/apache/camel/util/UnsafeUriCharactersEncoder.java Mon Apr 26 07:46:39 2010 @@ -25,8 +25,7 @@ import org.apache.commons.logging.LogFac * Encoder for unsafe URI characters. */ public final class UnsafeUriCharactersEncoder { - private static BitSet unsafeCharacters; - private static final transient Log LOG = LogFactory.getLog(UnsafeUriCharactersEncoder.class); + private static BitSet unsafeCharacters; private static final char[] HEX_DIGITS = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F'}; Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/builder/BuilderWithScopesTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/builder/BuilderWithScopesTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/builder/BuilderWithScopesTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/builder/BuilderWithScopesTest.java Mon Apr 26 07:46:39 2010 @@ -234,7 +234,6 @@ public class BuilderWithScopesTest exten protected RouteBuilder createTryCatchNoEnd() { return new RouteBuilder() { - @SuppressWarnings("unchecked") public void configure() { from("direct:a") .doTry() @@ -274,7 +273,6 @@ public class BuilderWithScopesTest exten protected RouteBuilder createTryCatchEnd() { return new RouteBuilder() { - @SuppressWarnings("unchecked") public void configure() { from("direct:a").doTry().process(validator).process(toProcessor) .doCatch(ValidationException.class).process(orderProcessor).end().process(orderProcessor3); @@ -309,7 +307,6 @@ public class BuilderWithScopesTest exten protected RouteBuilder createTryCatchFinallyNoEnd() { return new RouteBuilder() { - @SuppressWarnings("unchecked") public void configure() { from("direct:a").doTry().process(validator).process(toProcessor) .doCatch(ValidationException.class).process(orderProcessor).doFinally() @@ -349,7 +346,6 @@ public class BuilderWithScopesTest exten protected RouteBuilder createTryCatchFinallyEnd() { return new RouteBuilder() { - @SuppressWarnings("unchecked") public void configure() { from("direct:a").doTry().process(validator).process(toProcessor) .doCatch(ValidationException.class).process(orderProcessor).doFinally() Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/builder/ExceptionBuilderTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/builder/ExceptionBuilderTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/builder/ExceptionBuilderTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/builder/ExceptionBuilderTest.java Mon Apr 26 07:46:39 2010 @@ -160,7 +160,6 @@ public class ExceptionBuilderTest extend protected RouteBuilder createRouteBuilder() throws Exception { return new RouteBuilder() { - @SuppressWarnings("unchecked") public void configure() throws Exception { errorHandler(deadLetterChannel("mock:error").redeliveryDelay(0).maximumRedeliveries(3)); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/OrderServiceBean.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/OrderServiceBean.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/OrderServiceBean.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/OrderServiceBean.java Mon Apr 26 07:46:39 2010 @@ -50,7 +50,7 @@ public class OrderServiceBean { return null; } - String xml = converter.convertTo(String.class, doc); + converter.convertTo(String.class, doc); Integer orderId = 77889; Integer customerId = 667; Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/issues/BeanRouteToDerivedClassTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/issues/BeanRouteToDerivedClassTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/issues/BeanRouteToDerivedClassTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/issues/BeanRouteToDerivedClassTest.java Mon Apr 26 07:46:39 2010 @@ -47,8 +47,7 @@ public class BeanRouteToDerivedClassTest assertEquals("Derived class should have been invoked", "Hello World", derived.getAndClearBody()); } - - @SuppressWarnings("unchecked") + public void testDerivedClassCalledWithNoCustomProcessor() throws Exception { context.getTypeConverterRegistry().addTypeConverter(Processor.class, MyMessageListener.class, new MyMessageToProcessorConverter()); @@ -72,19 +71,18 @@ public class BeanRouteToDerivedClassTest assertEquals("Derived class should NOT have been invoked", null, derived.getAndClearBody()); assertEquals("Bye World", out.toString()); } - - @SuppressWarnings("unchecked") + public void testDerivedClassCalledWithCustomProcessor() throws Exception { context.getTypeConverterRegistry().addTypeConverter(Processor.class, MyMessageListener.class, new MyMessageToProcessorConverter()); context.addRoutes(new RouteBuilder() { @Override public void configure() throws Exception { - // explict method name given so always call this + // Explicit method name given so always call this from("direct:start") .to("bean:derived?method=process"); - // no explicy method name then a custom processor can kick in + // no explicit method name then a custom processor can kick in from("direct:other") .to("bean:derived"); } Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginAndCommitExpressionRenameStrategyTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginAndCommitExpressionRenameStrategyTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginAndCommitExpressionRenameStrategyTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginAndCommitExpressionRenameStrategyTest.java Mon Apr 26 07:46:39 2010 @@ -65,6 +65,7 @@ public class FileConsumerBeginAndCommitE public void configure() throws Exception { from("file://target/reports?preMove=../inprogress/${file:name.noext}.bak&move=../done/${file:name}&consumer.delay=5000") .process(new Processor() { + @SuppressWarnings("unchecked") public void process(Exchange exchange) throws Exception { GenericFile file = (GenericFile) exchange.getProperty(FileComponent.FILE_EXCHANGE_FILE); assertNotNull(file); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginAndCommitRenameStrategyTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginAndCommitRenameStrategyTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginAndCommitRenameStrategyTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginAndCommitRenameStrategyTest.java Mon Apr 26 07:46:39 2010 @@ -75,6 +75,7 @@ public class FileConsumerBeginAndCommitR public void configure() throws Exception { from("file://target/reports?preMove=../inprogress/${file:name}&move=../done/${file:name}&delay=5000") .process(new Processor() { + @SuppressWarnings("unchecked") public void process(Exchange exchange) throws Exception { GenericFile file = (GenericFile) exchange.getProperty(FileComponent.FILE_EXCHANGE_FILE); assertNotNull(file); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginExpressionRenameStrategyTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginExpressionRenameStrategyTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginExpressionRenameStrategyTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginExpressionRenameStrategyTest.java Mon Apr 26 07:46:39 2010 @@ -74,6 +74,7 @@ public class FileConsumerBeginExpression public void configure() throws Exception { from("file://target/reports?preMove=../inprogress/${file:name.noext}.bak&consumer.delay=5000") .process(new Processor() { + @SuppressWarnings("unchecked") public void process(Exchange exchange) throws Exception { GenericFile file = (GenericFile) exchange.getProperty(FileComponent.FILE_EXCHANGE_FILE); assertNotNull(file); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginRenameStrategyTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginRenameStrategyTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginRenameStrategyTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginRenameStrategyTest.java Mon Apr 26 07:46:39 2010 @@ -72,6 +72,7 @@ public class FileConsumerBeginRenameStra public void configure() throws Exception { from("file://target/reports?preMove=../inprogress/${file:name}&consumer.delay=5000") .process(new Processor() { + @SuppressWarnings("unchecked") public void process(Exchange exchange) throws Exception { GenericFile file = (GenericFile) exchange.getProperty(FileComponent.FILE_EXCHANGE_FILE); assertNotNull(file); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerCommitRenameStrategyTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerCommitRenameStrategyTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerCommitRenameStrategyTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerCommitRenameStrategyTest.java Mon Apr 26 07:46:39 2010 @@ -70,7 +70,7 @@ public class FileConsumerCommitRenameStr Thread.sleep(1000); // content of file should be Hello London - String content = IOConverter.toString(new File("./target/done/london.txt")); + String content = IOConverter.toString(new File("./target/done/london.txt"), null); assertEquals("The file should have been renamed replacing any existing files", "Hello London", content); } Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/NewFileConsumeTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/NewFileConsumeTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/NewFileConsumeTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/NewFileConsumeTest.java Mon Apr 26 07:46:39 2010 @@ -19,6 +19,7 @@ package org.apache.camel.component.file; import java.io.File; import java.io.FileOutputStream; import java.util.HashMap; +import java.util.Map; import java.util.concurrent.CountDownLatch; import org.apache.camel.Consumer; @@ -54,7 +55,7 @@ public class NewFileConsumeTest extends fos.close(); } - Endpoint endpoint = comp.createEndpoint("file://target/consumefile", "target/consumefile", new HashMap()); + Endpoint endpoint = comp.createEndpoint("file://target/consumefile", "target/consumefile", new HashMap()); Consumer consumer = endpoint.createConsumer(new Processor() { public void process(Exchange exchange) throws Exception { assertNotNull(exchange); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/NewFileProduceTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/NewFileProduceTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/NewFileProduceTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/NewFileProduceTest.java Mon Apr 26 07:46:39 2010 @@ -18,6 +18,7 @@ package org.apache.camel.component.file; import java.io.File; import java.util.HashMap; +import java.util.Map; import org.apache.camel.ContextTestSupport; import org.apache.camel.Endpoint; @@ -40,7 +41,7 @@ public class NewFileProduceTest extends FileComponent comp = new FileComponent(); comp.setCamelContext(context); - Endpoint endpoint = comp.createEndpoint("file://target/producefile", "target/producefile", new HashMap()); + Endpoint endpoint = comp.createEndpoint("file://target/producefile", "target/producefile", new HashMap()); template.send(endpoint, new Processor() { public void process(Exchange exchange) throws Exception { exchange.getIn().setHeader(Exchange.FILE_NAME, "bye.txt"); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/XPathToFileTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/XPathToFileTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/XPathToFileTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/XPathToFileTest.java Mon Apr 26 07:46:39 2010 @@ -18,10 +18,12 @@ package org.apache.camel.component.file; import java.io.File; +import org.w3c.dom.Document; + import org.apache.camel.ContextTestSupport; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.mock.MockEndpoint; -import org.w3c.dom.Document; + import static org.apache.camel.builder.xml.XPathBuilder.xpath; Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/mock/MockExpectedBodiesAsListTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/mock/MockExpectedBodiesAsListTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/component/mock/MockExpectedBodiesAsListTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/mock/MockExpectedBodiesAsListTest.java Mon Apr 26 07:46:39 2010 @@ -52,7 +52,7 @@ public class MockExpectedBodiesAsListTes } public void testUsingList() throws Exception { - List data = new ArrayList(); + List data = new ArrayList(); data.add("Hello World"); data.add(123); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/pojo/PojoRouteTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/pojo/PojoRouteTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/component/pojo/PojoRouteTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/pojo/PojoRouteTest.java Mon Apr 26 07:46:39 2010 @@ -30,6 +30,7 @@ import org.apache.camel.util.jndi.JndiCo */ public class PojoRouteTest extends TestCase { + @SuppressWarnings("unchecked") public void testPojoRoutes() throws Exception { // START SNIPPET: register // lets populate the context with the services we need Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/converter/ConverterTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/converter/ConverterTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/converter/ConverterTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/converter/ConverterTest.java Mon Apr 26 07:46:39 2010 @@ -224,7 +224,7 @@ public class ConverterTest extends TestC CamelContext camel = new DefaultCamelContext(); Exchange e = new DefaultExchange(camel); try { - converter.mandatoryConvertTo(InputStream.class, null); + converter.mandatoryConvertTo(InputStream.class, e); fail("Expect exception here"); } catch (Exception ex) { assertTrue("Expect to get a NoTypeConversionAvailableException here", ex instanceof NoTypeConversionAvailableException); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/converter/IOConverterTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/converter/IOConverterTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/converter/IOConverterTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/converter/IOConverterTest.java Mon Apr 26 07:46:39 2010 @@ -58,7 +58,6 @@ public class IOConverterTest extends Con public void testToByteArray() throws Exception { String val = null; - assertNull(IOConverter.toByteArray(val)); assertNull(IOConverter.toByteArray(val, null)); } @@ -134,14 +133,14 @@ public class IOConverterTest extends Con public void testToByteArrayBufferReader() throws Exception { BufferedReader br = new BufferedReader(new StringReader("Hello World")); - byte[] bytes = IOConverter.toByteArray(br); + byte[] bytes = IOConverter.toByteArray(br, null); assertNotNull(bytes); assertEquals(11, bytes.length); } public void testToByteArrayReader() throws Exception { Reader br = new BufferedReader(new StringReader("Hello World")); - byte[] bytes = IOConverter.toByteArray(br); + byte[] bytes = IOConverter.toByteArray(br, null); assertNotNull(bytes); assertEquals(11, bytes.length); } @@ -179,7 +178,7 @@ public class IOConverterTest extends Con public void testStringUrl() throws Exception { URL url = ObjectHelper.loadResourceAsURL("log4j.properties"); - String s = IOConverter.toString(url); + String s = IOConverter.toString(url, null); assertNotNull(s); } @@ -193,7 +192,7 @@ public class IOConverterTest extends Con public void testByteArrayByBufferedReader() throws Exception { Reader reader = new StringReader("Hello World"); - byte[] data = IOConverter.toByteArray(reader); + byte[] data = IOConverter.toByteArray(reader, null); assertNotNull(data); assertEquals("Hello World", context.getTypeConverter().convertTo(String.class, data)); } Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/impl/CamelPostProcessorHelperTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/impl/CamelPostProcessorHelperTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/impl/CamelPostProcessorHelperTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/impl/CamelPostProcessorHelperTest.java Mon Apr 26 07:46:39 2010 @@ -205,7 +205,7 @@ public class CamelPostProcessorHelperTes String propertyName = "producer"; try { - Object value = helper.getInjectionValue(type, endpointInject.uri(), endpointInject.ref(), propertyName, bean, "foo"); + helper.getInjectionValue(type, endpointInject.uri(), endpointInject.ref(), propertyName, bean, "foo"); fail("Should throw exception"); } catch (IllegalArgumentException e) { assertEquals("registry entry called unknown of type org.apache.camel.Endpoint must be specified", e.getMessage()); @@ -223,7 +223,7 @@ public class CamelPostProcessorHelperTes String propertyName = "producer"; try { - Object value = helper.getInjectionValue(type, endpointInject.uri(), endpointInject.ref(), propertyName, bean, "foo"); + helper.getInjectionValue(type, endpointInject.uri(), endpointInject.ref(), propertyName, bean, "foo"); fail("Should throw exception"); } catch (ResolveEndpointFailedException e) { assertEquals("Failed to resolve endpoint: xxx://foo due to: No component found with scheme: xxx", e.getMessage()); @@ -241,7 +241,7 @@ public class CamelPostProcessorHelperTes String propertyName = "producer"; try { - Object value = helper.getInjectionValue(type, endpointInject.uri(), endpointInject.ref(), propertyName, bean, "foo"); + helper.getInjectionValue(type, endpointInject.uri(), endpointInject.ref(), propertyName, bean, "foo"); fail("Should throw exception"); } catch (IllegalArgumentException e) { assertEquals("Both uri and name is provided, only either one is allowed: uri=seda:foo, ref=myEndpoint", e.getMessage()); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultConsumerCacheTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultConsumerCacheTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultConsumerCacheTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultConsumerCacheTest.java Mon Apr 26 07:46:39 2010 @@ -35,6 +35,7 @@ public class DefaultConsumerCacheTest ex for (int i = 0; i < 1003; i++) { Endpoint e = context.getEndpoint("direct:queue:" + i); PollingConsumer p = cache.getConsumer(e); + assertNotNull("the polling consumer should not be null", p); } assertEquals("Size should be 1000", 1000, cache.size()); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultConsumerTemplateTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultConsumerTemplateTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultConsumerTemplateTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultConsumerTemplateTest.java Mon Apr 26 07:46:39 2010 @@ -302,7 +302,7 @@ public class DefaultConsumerTemplateTest // test that we cache at most 500 consumers to avoid it eating to much memory for (int i = 0; i < 503; i++) { Endpoint e = context.getEndpoint("direct:queue:" + i); - Exchange ex = template.receiveNoWait(e); + template.receiveNoWait(e); } assertEquals("Size should be 500", 500, template.getCurrentCacheSize()); @@ -320,7 +320,7 @@ public class DefaultConsumerTemplateTest // test that we cache at most 500 consumers to avoid it eating to much memory for (int i = 0; i < 503; i++) { Endpoint e = context.getEndpoint("direct:queue:" + i); - Exchange ex = template.receiveNoWait(e); + template.receiveNoWait(e); } assertEquals("Size should be 500", 500, template.getCurrentCacheSize()); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateAsyncTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateAsyncTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateAsyncTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateAsyncTest.java Mon Apr 26 07:46:39 2010 @@ -223,7 +223,7 @@ public class DefaultProducerTemplateAsyn assertEquals("HiHi", echo); try { - Exchange result = template.extractFutureBody(future, Exchange.class); + template.extractFutureBody(future, Exchange.class); fail("Should have thrown exception"); } catch (RuntimeCamelException e) { assertEquals("Damn forced by unit test", e.getCause().getMessage()); @@ -242,7 +242,7 @@ public class DefaultProducerTemplateAsyn assertEquals("HiHi", echo); try { - String result = template.extractFutureBody(future, String.class); + template.extractFutureBody(future, String.class); fail("Should have thrown exception"); } catch (RuntimeCamelException e) { assertEquals("Damn forced by unit test", e.getCause().getMessage()); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/impl/ExpressionAdapterTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/impl/ExpressionAdapterTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/impl/ExpressionAdapterTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/impl/ExpressionAdapterTest.java Mon Apr 26 07:46:39 2010 @@ -30,6 +30,7 @@ public class ExpressionAdapterTest exten return "foo"; } + @SuppressWarnings("unchecked") public T evaluate(Exchange exchange, Class type) { String in = exchange.getIn().getBody(String.class); if ("Kabom".equals(in)) { Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/impl/ExpressionSupportTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/impl/ExpressionSupportTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/impl/ExpressionSupportTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/impl/ExpressionSupportTest.java Mon Apr 26 07:46:39 2010 @@ -30,6 +30,7 @@ public class ExpressionSupportTest exten return "foo"; } + @SuppressWarnings("unchecked") public T evaluate(Exchange exchange, Class type) { String in = exchange.getIn().getBody(String.class); if ("Kabom".equals(in)) { Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/impl/RouteWithMistypedComponentNameTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/impl/RouteWithMistypedComponentNameTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/impl/RouteWithMistypedComponentNameTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/impl/RouteWithMistypedComponentNameTest.java Mon Apr 26 07:46:39 2010 @@ -36,7 +36,7 @@ public class RouteWithMistypedComponentN from("direct:hello").to("mock:result"); // unknown component - Endpoint endpoint = endpoint("mistyped:hello"); + endpoint("mistyped:hello"); } }); fail("Should have thrown a ResolveEndpointFailedException"); @@ -55,7 +55,7 @@ public class RouteWithMistypedComponentN from("direct:hello").to("mock:result"); // unknown component - Endpoint endpoint = endpoint("mistyped:hello", Endpoint.class); + endpoint("mistyped:hello", Endpoint.class); } }); fail("Should have thrown a ResolveEndpointFailedException"); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/impl/SimpleRegistryTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/impl/SimpleRegistryTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/impl/SimpleRegistryTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/impl/SimpleRegistryTest.java Mon Apr 26 07:46:39 2010 @@ -50,8 +50,7 @@ public class SimpleRegistryTest extends // expected } } - - @SuppressWarnings("unchecked") + public void testLookupByType() { Map map = registry.lookupByType(String.class); assertEquals(1, map.size()); @@ -61,8 +60,7 @@ public class SimpleRegistryTest extends assertEquals("b", map.get("a")); assertEquals(1, map.get("c")); } - - @SuppressWarnings("unchecked") + public void testLookupByWrongType() { Map map = registry.lookupByType(Float.class); assertEquals(0, map.size()); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/impl/StringDataFormatTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/impl/StringDataFormatTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/impl/StringDataFormatTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/impl/StringDataFormatTest.java Mon Apr 26 07:46:39 2010 @@ -159,10 +159,6 @@ public class StringDataFormatTest extend private class MyBook { private String title; - public String getTitle() { - return title; - } - public void setTitle(String title) { this.title = title; } Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/impl/TypeConverterRegistryTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/impl/TypeConverterRegistryTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/impl/TypeConverterRegistryTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/impl/TypeConverterRegistryTest.java Mon Apr 26 07:46:39 2010 @@ -68,6 +68,7 @@ public class TypeConverterRegistryTest e // START SNIPPET: e2 private class MyOrderTypeConverter implements TypeConverter { + @SuppressWarnings("unchecked") public T convertTo(Class type, Object value) { // converter from value to the MyOrder bean MyOrder order = new MyOrder(); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/issues/CoarseGrainedProcessorDefinitionIssueTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/CoarseGrainedProcessorDefinitionIssueTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/issues/CoarseGrainedProcessorDefinitionIssueTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/issues/CoarseGrainedProcessorDefinitionIssueTest.java Mon Apr 26 07:46:39 2010 @@ -35,6 +35,7 @@ public class CoarseGrainedProcessorDefin assertMockEndpointsSatisfied(); Route route = context.getRoutes().get(0); + assertNotNull("The route should not be null", route); // TODO: drill down the route and check that Channel have // the fine grained processor definition assigned Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/issues/DavidSiefertTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/DavidSiefertTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/issues/DavidSiefertTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/issues/DavidSiefertTest.java Mon Apr 26 07:46:39 2010 @@ -61,7 +61,7 @@ public class DavidSiefertTest extends Co public static class MyProcessor implements Processor { public void process(Exchange exchange) throws Exception { - String input = exchange.getIn().getBody(String.class); + exchange.getIn().getBody(String.class); Message output = exchange.getOut(); output.setHeader("sample.name", "myValue"); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/issues/GertJBIIssueTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/GertJBIIssueTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/issues/GertJBIIssueTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/issues/GertJBIIssueTest.java Mon Apr 26 07:46:39 2010 @@ -70,6 +70,7 @@ public class GertJBIIssueTest extends Co assertMockEndpointsSatisfied(); } + @SuppressWarnings("unchecked") public void testSimulateJBIEndpointNotExist() throws Exception { context.addRoutes(new RouteBuilder() { @Override Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/issues/ProxyReturnNullIssueTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/ProxyReturnNullIssueTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/issues/ProxyReturnNullIssueTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/issues/ProxyReturnNullIssueTest.java Mon Apr 26 07:46:39 2010 @@ -25,11 +25,13 @@ import org.apache.camel.component.bean.P */ public class ProxyReturnNullIssueTest extends ContextTestSupport { + @SuppressWarnings("unchecked") public void testEcho() throws Exception { Echo service = ProxyHelper.createProxy(context.getEndpoint("direct:echo"), Echo.class); assertEquals("Hello World", service.echo("Hello World")); } + @SuppressWarnings("unchecked") public void testEchoNull() throws Exception { Echo service = ProxyHelper.createProxy(context.getEndpoint("direct:echo"), Echo.class); assertEquals(null, service.echo(null)); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/issues/SplitPropertiesFileIssueTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/SplitPropertiesFileIssueTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/issues/SplitPropertiesFileIssueTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/issues/SplitPropertiesFileIssueTest.java Mon Apr 26 07:46:39 2010 @@ -69,6 +69,7 @@ public class SplitPropertiesFileIssueTes private class MyCustomExpression implements Expression { + @SuppressWarnings("unchecked") public T evaluate(Exchange exchange, Class type) { // must copy from the original exchange as Camel holds information about the file in progress Message msg1 = exchange.getIn().copy(); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/language/BeanLanguageInvalidOGNLTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/language/BeanLanguageInvalidOGNLTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/language/BeanLanguageInvalidOGNLTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/language/BeanLanguageInvalidOGNLTest.java Mon Apr 26 07:46:39 2010 @@ -32,7 +32,7 @@ public class BeanLanguageInvalidOGNLTest public void testBeanLanguageInvalidOGNL() throws Exception { try { - String reply = template.requestBody("direct:start", "World", String.class); + template.requestBody("direct:start", "World", String.class); fail("Should have thrown exception"); } catch (CamelExecutionException e) { RuntimeBeanExpressionException rbee = assertIsInstanceOf(RuntimeBeanExpressionException.class, e.getCause()); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/language/SimpleTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/language/SimpleTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/language/SimpleTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/language/SimpleTest.java Mon Apr 26 07:46:39 2010 @@ -225,7 +225,7 @@ public class SimpleTest extends Language } public void testOGNLHeaderMap() throws Exception { - Map map = new HashMap(); + Map map = new HashMap(); map.put("cool", "Camel rocks"); map.put("dude", "Hey dude"); map.put("code", 4321); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ExceptionWithManagementTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ExceptionWithManagementTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ExceptionWithManagementTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ExceptionWithManagementTest.java Mon Apr 26 07:46:39 2010 @@ -42,7 +42,7 @@ public class ExceptionWithManagementTest MockEndpoint out = this.resolveMandatoryEndpoint("mock:out", MockEndpoint.class); out.expectedMessageCount(0); - Exchange exchange = template.send("direct:start", ExchangePattern.InOnly, new Processor() { + template.send("direct:start", ExchangePattern.InOnly, new Processor() { public void process(Exchange exchange) throws Exception { exchange.getIn().setBody("hello"); } Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedDelayerTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedDelayerTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedDelayerTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedDelayerTest.java Mon Apr 26 07:46:39 2010 @@ -41,8 +41,7 @@ public class ManagedDelayerTest extends naming.setDomainName("org.apache.camel"); return context; } - - @SuppressWarnings("unchecked") + public void testManageDelay() throws Exception { getMockEndpoint("mock:result").expectedMessageCount(1); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedErrorHandlerOptionsTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedErrorHandlerOptionsTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedErrorHandlerOptionsTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedErrorHandlerOptionsTest.java Mon Apr 26 07:46:39 2010 @@ -51,6 +51,7 @@ public class ManagedErrorHandlerOptionsT return context; } + @SuppressWarnings("unchecked") public void testManagedErrorHandlerOptions() throws Exception { counter = 0; Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedErrorHandlerRedeliveryTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedErrorHandlerRedeliveryTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedErrorHandlerRedeliveryTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedErrorHandlerRedeliveryTest.java Mon Apr 26 07:46:39 2010 @@ -51,6 +51,7 @@ public class ManagedErrorHandlerRedelive return context; } + @SuppressWarnings("unchecked") public void testManagedErrorHandlerRedelivery() throws Exception { counter = 0; Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedErrorHandlerTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedErrorHandlerTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedErrorHandlerTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedErrorHandlerTest.java Mon Apr 26 07:46:39 2010 @@ -44,6 +44,7 @@ public class ManagedErrorHandlerTest ext return context; } + @SuppressWarnings("unchecked") public void testManagedErrorHandler() throws Exception { MBeanServer mbeanServer = context.getManagementStrategy().getManagementAgent().getMBeanServer(); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRegisterCamelContextTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRegisterCamelContextTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRegisterCamelContextTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRegisterCamelContextTest.java Mon Apr 26 07:46:39 2010 @@ -43,7 +43,6 @@ public class ManagedRegisterCamelContext return context; } - @SuppressWarnings("unchecked") public void testRegisterCamelContext() throws Exception { MBeanServer mbeanServer = context.getManagementStrategy().getManagementAgent().getMBeanServer(); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRegisterRouteTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRegisterRouteTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRegisterRouteTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRegisterRouteTest.java Mon Apr 26 07:46:39 2010 @@ -34,6 +34,7 @@ public class ManagedRegisterRouteTest ex return true; } + @SuppressWarnings("unchecked") public void testRoutes() throws Exception { MBeanServer mbeanServer = context.getManagementStrategy().getManagementAgent().getMBeanServer(); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteContextTracerTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteContextTracerTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteContextTracerTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteContextTracerTest.java Mon Apr 26 07:46:39 2010 @@ -46,7 +46,6 @@ public class ManagedRouteContextTracerTe return context; } - @SuppressWarnings("unchecked") public void testRouteTracing() throws Exception { MBeanServer mbeanServer = context.getManagementStrategy().getManagementAgent().getMBeanServer(); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteShutdownAndStartTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteShutdownAndStartTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteShutdownAndStartTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteShutdownAndStartTest.java Mon Apr 26 07:46:39 2010 @@ -87,6 +87,7 @@ public class ManagedRouteShutdownAndStar mock.assertIsSatisfied(); } + @SuppressWarnings("unchecked") static ObjectName getRouteObjectName(MBeanServer mbeanServer) throws Exception { Set set = mbeanServer.queryNames(new ObjectName("*:type=routes,*"), null); assertEquals(1, set.size()); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopAndStartTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopAndStartTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopAndStartTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopAndStartTest.java Mon Apr 26 07:46:39 2010 @@ -87,6 +87,7 @@ public class ManagedRouteStopAndStartTes mock.assertIsSatisfied(); } + @SuppressWarnings("unchecked") static ObjectName getRouteObjectName(MBeanServer mbeanServer) throws Exception { Set set = mbeanServer.queryNames(new ObjectName("*:type=routes,*"), null); assertEquals(1, set.size()); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopTest.java Mon Apr 26 07:46:39 2010 @@ -34,6 +34,7 @@ public class ManagedRouteStopTest extend return true; } + @SuppressWarnings("unchecked") public void testStopRoute() throws Exception { // fire a message to get it running getMockEndpoint("mock:result").expectedMessageCount(1); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedSendProcessorTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedSendProcessorTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedSendProcessorTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedSendProcessorTest.java Mon Apr 26 07:46:39 2010 @@ -44,7 +44,6 @@ public class ManagedSendProcessorTest ex return context; } - @SuppressWarnings("unchecked") public void testManageSendProcessor() throws Exception { MockEndpoint result = getMockEndpoint("mock:result"); result.expectedMessageCount(1); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedSuspendedServiceTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedSuspendedServiceTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedSuspendedServiceTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedSuspendedServiceTest.java Mon Apr 26 07:46:39 2010 @@ -38,6 +38,7 @@ public class ManagedSuspendedServiceTest return true; } + @SuppressWarnings("unchecked") public void testConsumeSuspendAndResumeFile() throws Exception { deleteDirectory("target/suspended"); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedThreadPoolTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedThreadPoolTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedThreadPoolTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedThreadPoolTest.java Mon Apr 26 07:46:39 2010 @@ -43,6 +43,7 @@ public class ManagedThreadPoolTest exten return context; } + @SuppressWarnings("unchecked") public void testManagedThreadPool() throws Exception { MBeanServer mbeanServer = context.getManagementStrategy().getManagementAgent().getMBeanServer(); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedThrottlerTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedThrottlerTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedThrottlerTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedThrottlerTest.java Mon Apr 26 07:46:39 2010 @@ -43,7 +43,6 @@ public class ManagedThrottlerTest extend return context; } - @SuppressWarnings("unchecked") public void testManageThrottler() throws Exception { getMockEndpoint("mock:result").expectedMessageCount(10); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedTracerOptionsTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedTracerOptionsTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedTracerOptionsTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedTracerOptionsTest.java Mon Apr 26 07:46:39 2010 @@ -45,6 +45,7 @@ public class ManagedTracerOptionsTest ex return context; } + @SuppressWarnings("unchecked") public void testManagedTracerOptions() throws Exception { MBeanServer mbeanServer = context.getManagementStrategy().getManagementAgent().getMBeanServer(); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedUnregisterCamelContextTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedUnregisterCamelContextTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedUnregisterCamelContextTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedUnregisterCamelContextTest.java Mon Apr 26 07:46:39 2010 @@ -38,6 +38,7 @@ public class ManagedUnregisterCamelConte return context; } + @SuppressWarnings("unchecked") public void testUnregisterCamelContext() throws Exception { CamelContext context = createCamelContext(); context.start(); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedUnregisterProducerTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedUnregisterProducerTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedUnregisterProducerTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedUnregisterProducerTest.java Mon Apr 26 07:46:39 2010 @@ -46,10 +46,9 @@ public class ManagedUnregisterProducerTe return context; } - @SuppressWarnings("unchecked") public void testUnregisterProducer() throws Exception { // send a message so the managed producer is started - // do this "manually" to avoid camel manageging the direct:start producer as well + // do this "manually" to avoid camel managing the direct:start producer as well // this makes the unit test easier as we only have 1 managed producer = mock:result Endpoint endpoint = context.getEndpoint("direct:start"); Producer producer = endpoint.createProducer(); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/model/XmlParseTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/model/XmlParseTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/model/XmlParseTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/model/XmlParseTest.java Mon Apr 26 07:46:39 2010 @@ -168,7 +168,6 @@ public class XmlParseTest extends XmlTes assertEquals("#", node.getUriDelimiter()); } - @SuppressWarnings("unchecked") public void testParseRouteWithChoiceXml() throws Exception { RouteDefinition route = assertOneRoute("routeWithChoice.xml"); assertFrom(route, "seda:a"); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ChoiceWithEndTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ChoiceWithEndTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ChoiceWithEndTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ChoiceWithEndTest.java Mon Apr 26 07:46:39 2010 @@ -29,6 +29,7 @@ import org.apache.camel.builder.RouteBui */ public class ChoiceWithEndTest extends ContextTestSupport { + @SuppressWarnings("unchecked") public void testRouteIsCorrectAtRuntime() throws Exception { // use navigate to find that the end works as expected Navigate nav = getRoute("direct://start").navigate(); @@ -90,8 +91,7 @@ public class ChoiceWithEndTest extends C @Override protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @SuppressWarnings("unchecked") + return new RouteBuilder() { @Override public void configure() throws Exception { MyChoiceBean bean = new MyChoiceBean(); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ClaimCheckTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ClaimCheckTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ClaimCheckTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ClaimCheckTest.java Mon Apr 26 07:46:39 2010 @@ -33,7 +33,6 @@ public class ClaimCheckTest extends Cont // in memory data store for testing only! public static Map dataStore = new HashMap(); - @SuppressWarnings("unchecked") public void testClaimCheck() throws Exception { String body = ""; Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/DeadLetterChannelHandledExampleTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/DeadLetterChannelHandledExampleTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/DeadLetterChannelHandledExampleTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/DeadLetterChannelHandledExampleTest.java Mon Apr 26 07:46:39 2010 @@ -103,6 +103,7 @@ public class DeadLetterChannelHandledExa * @return the out payload * @throws OrderFailedException is thrown if the order cannot be processed */ + @SuppressWarnings("unchecked") public Object handleOrder(@Headers Map in, @Body String payload, @OutHeaders Map out) throws OrderFailedException { out.put("customerid", in.get("customerid")); @@ -121,6 +122,7 @@ public class DeadLetterChannelHandledExa * @param out the out headers * @return the out payload */ + @SuppressWarnings("unchecked") public Object orderFailed(@Headers Map in, @Body String payload, @OutHeaders Map out) { out.put("customerid", in.get("customerid")); out.put("orderid", "failed"); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/DeadLetterChannelRedeliverWithDelayBlockingTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/DeadLetterChannelRedeliverWithDelayBlockingTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/DeadLetterChannelRedeliverWithDelayBlockingTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/DeadLetterChannelRedeliverWithDelayBlockingTest.java Mon Apr 26 07:46:39 2010 @@ -36,6 +36,7 @@ public class DeadLetterChannelRedeliverW private static int counter; + @SuppressWarnings("unchecked") public void testRedeliverWithDelay() throws Exception { MockEndpoint mock = getMockEndpoint("mock:result"); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/FileIdempotentConsumerTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/FileIdempotentConsumerTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/FileIdempotentConsumerTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/FileIdempotentConsumerTest.java Mon Apr 26 07:46:39 2010 @@ -35,7 +35,7 @@ public class FileIdempotentConsumerTest protected Endpoint startEndpoint; protected MockEndpoint resultEndpoint; private File store = new File("target/idempotentfilestore.dat"); - private IdempotentRepository repo; + private IdempotentRepository repo; public void testDuplicateMessagesAreFilteredOut() throws Exception { assertFalse(repo.contains("1")); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/IdempotentConsumerEagerTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/IdempotentConsumerEagerTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/IdempotentConsumerEagerTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/IdempotentConsumerEagerTest.java Mon Apr 26 07:46:39 2010 @@ -129,7 +129,7 @@ public class IdempotentConsumerEagerTest context.addRoutes(new RouteBuilder() { @Override public void configure() throws Exception { - final IdempotentRepository repo = MemoryIdempotentRepository.memoryIdempotentRepository(200); + final IdempotentRepository repo = MemoryIdempotentRepository.memoryIdempotentRepository(200); from("direct:start").idempotentConsumer(header("messageId"), repo).eager(false). process(new Processor() { @@ -156,7 +156,7 @@ public class IdempotentConsumerEagerTest context.addRoutes(new RouteBuilder() { @Override public void configure() throws Exception { - final IdempotentRepository repo = MemoryIdempotentRepository.memoryIdempotentRepository(200); + final IdempotentRepository repo = MemoryIdempotentRepository.memoryIdempotentRepository(200); from("direct:start").idempotentConsumer(header("messageId"), repo).eager(true). process(new Processor() { Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/NavigateRouteTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/NavigateRouteTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/NavigateRouteTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/NavigateRouteTest.java Mon Apr 26 07:46:39 2010 @@ -45,6 +45,7 @@ public class NavigateRouteTest extends C assertEquals("There should be 7 processors to navigate", 7, count); } + @SuppressWarnings("unchecked") private void navigateRoute(Navigate nav) { if (!nav.hasNext()) { return; Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/RandomLoadBalanceJavaDSLBuilderTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/RandomLoadBalanceJavaDSLBuilderTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/RandomLoadBalanceJavaDSLBuilderTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/RandomLoadBalanceJavaDSLBuilderTest.java Mon Apr 26 07:46:39 2010 @@ -84,7 +84,7 @@ public class RandomLoadBalanceJavaDSLBui } } - private void navigateDefinition(ProcessorDefinition def, StringBuilder sb) { + private void navigateDefinition(ProcessorDefinition def, StringBuilder sb) { if (def instanceof LoadBalanceDefinition) { sb.append(".loadBalance()"); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/RemoveHeadersTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/RemoveHeadersTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/RemoveHeadersTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/RemoveHeadersTest.java Mon Apr 26 07:46:39 2010 @@ -30,7 +30,7 @@ public class RemoveHeadersTest extends C mock.expectedBodiesReceived("Hello World"); mock.expectedHeaderReceived("duck", "Donald"); - Map headers = new HashMap(); + Map headers = new HashMap(); headers.put("dudeCool", "cool"); headers.put("dudeWicket", "wicket"); headers.put("duck", "Donald"); @@ -49,7 +49,7 @@ public class RemoveHeadersTest extends C mock.expectedHeaderReceived("duck", "Donald"); mock.expectedHeaderReceived("BeerHeineken", "Good"); - Map headers = new HashMap(); + Map headers = new HashMap(); headers.put("dudeCool", "cool"); headers.put("dudeWicket", "wicket"); headers.put("duck", "Donald"); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SetHeaderTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SetHeaderTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SetHeaderTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SetHeaderTest.java Mon Apr 26 07:46:39 2010 @@ -47,8 +47,7 @@ public class SetHeaderTest extends Conte return new RouteBuilder() { public void configure() { // START SNIPPET: example - Namespaces ns = new Namespaces("foo", "urn:cheese"); - + from("direct:start"). unmarshal().string(). setHeader("foo").xpath("/person[@name='James']/@city", String.class). Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitWithEndTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitWithEndTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitWithEndTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitWithEndTest.java Mon Apr 26 07:46:39 2010 @@ -30,6 +30,7 @@ import org.apache.camel.processor.aggreg */ public class SplitWithEndTest extends ContextTestSupport { + @SuppressWarnings("unchecked") public void testRouteIsCorrectAtRuntime() throws Exception { // use navigate to find that the end works as expected Navigate nav = context.getRoutes().get(0).navigate(); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterTest.java Mon Apr 26 07:46:39 2010 @@ -53,6 +53,7 @@ public class SplitterTest extends Contex for (int i = 0; i < 4; i++) { Exchange exchange = list.get(i); Message in = exchange.getIn(); + assertNotNull("The in message should not be null.", in); assertProperty(exchange, Exchange.SPLIT_INDEX, i); assertProperty(exchange, Exchange.SPLIT_SIZE, 4); } Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionSizeFallbackTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionSizeFallbackTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionSizeFallbackTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionSizeFallbackTest.java Mon Apr 26 07:46:39 2010 @@ -31,7 +31,7 @@ public class AggregateExpressionSizeFall public void testAggregateExpressionSizeFallback() throws Exception { getMockEndpoint("mock:aggregated").expectedBodiesReceived("A+B+C"); - Map headers = new HashMap(); + Map headers = new HashMap(); headers.put("id", 123); template.sendBodyAndHeaders("direct:start", "A", headers); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionSizeTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionSizeTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionSizeTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionSizeTest.java Mon Apr 26 07:46:39 2010 @@ -31,7 +31,7 @@ public class AggregateExpressionSizeTest public void testAggregateExpressionSize() throws Exception { getMockEndpoint("mock:aggregated").expectedBodiesReceived("A+B+C"); - Map headers = new HashMap(); + Map headers = new HashMap(); headers.put("id", 123); headers.put("mySize", 3); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionTimeoutFallbackTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionTimeoutFallbackTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionTimeoutFallbackTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionTimeoutFallbackTest.java Mon Apr 26 07:46:39 2010 @@ -31,7 +31,7 @@ public class AggregateExpressionTimeoutF public void testAggregateExpressionTimeoutFallback() throws Exception { getMockEndpoint("mock:aggregated").expectedBodiesReceived("A+B+C"); - Map headers = new HashMap(); + Map headers = new HashMap(); headers.put("id", 123); template.sendBodyAndHeaders("direct:start", "A", headers); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionTimeoutPerGroupTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionTimeoutPerGroupTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionTimeoutPerGroupTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionTimeoutPerGroupTest.java Mon Apr 26 07:46:39 2010 @@ -36,7 +36,7 @@ public class AggregateExpressionTimeoutP template.sendBodyAndHeader("direct:start", "B", "id", 789); template.sendBodyAndHeader("direct:start", "C", "id", 789); - Map headers = new HashMap(); + Map headers = new HashMap(); headers.put("id", 123); headers.put("timeout", 3000); @@ -45,7 +45,7 @@ public class AggregateExpressionTimeoutP template.sendBodyAndHeaders("direct:start", "E", headers); template.sendBodyAndHeaders("direct:start", "F", headers); - Map headers2 = new HashMap(); + Map headers2 = new HashMap(); headers2.put("id", 456); headers2.put("timeout", 1000); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionTimeoutTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionTimeoutTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionTimeoutTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateExpressionTimeoutTest.java Mon Apr 26 07:46:39 2010 @@ -31,7 +31,7 @@ public class AggregateExpressionTimeoutT public void testAggregateExpressionTimeout() throws Exception { getMockEndpoint("mock:aggregated").expectedBodiesReceived("A+B+C"); - Map headers = new HashMap(); + Map headers = new HashMap(); headers.put("id", 123); headers.put("timeout", 2000); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeBatchSizeTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeBatchSizeTest.java?rev=937951&r1=937950&r2=937951&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeBatchSizeTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeBatchSizeTest.java Mon Apr 26 07:46:39 2010 @@ -28,6 +28,7 @@ import org.apache.camel.component.mock.M */ public class AggregateGroupedExchangeBatchSizeTest extends ContextTestSupport { + @SuppressWarnings("unchecked") public void testGrouped() throws Exception { MockEndpoint result = getMockEndpoint("mock:result");