You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2010/04/26 09:46:41 UTC
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...
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> file = (GenericFile<File>) 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> file = (GenericFile<File>) 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> file = (GenericFile<File>) 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> file = (GenericFile<File>) 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<String, Object>());
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<String, Object>());
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<Object> data = new ArrayList<Object>();
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> T evaluate(Exchange exchange, Class<T> 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> T evaluate(Exchange exchange, Class<T> 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> T convertTo(Class<T> 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> T evaluate(Exchange exchange, Class<T> 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<String, Object> map = new HashMap<String, Object>();
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<ObjectName> 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<ObjectName> 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<Processor> 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<String, Object> dataStore = new HashMap<String, Object>();
- @SuppressWarnings("unchecked")
public void testClaimCheck() throws Exception {
String body = "<order custId=\"123\"><lotsOfContent/></order>";
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<String> 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<String> 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<String> 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<Processor> 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<String, Object> headers = new HashMap<String, Object>();
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<String, Object> headers = new HashMap<String, Object>();
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<Processor> 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<String, Object> headers = new HashMap<String, Object>();
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<String, Object> headers = new HashMap<String, Object>();
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<String, Object> headers = new HashMap<String, Object>();
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<String, Object> headers = new HashMap<String, Object>();
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<String, Object> headers2 = new HashMap<String, Object>();
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<String, Object> headers = new HashMap<String, Object>();
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");