You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/03/10 12:08:34 UTC
[camel] branch main updated: CAMEL-17763: cleaned up unused exceptions in camel-jms
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 7b36782 CAMEL-17763: cleaned up unused exceptions in camel-jms
7b36782 is described below
commit 7b3678253f08ad6906e2423eeb1313e1f02bd72a
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Thu Mar 10 11:40:27 2022 +0100
CAMEL-17763: cleaned up unused exceptions in camel-jms
---
.../jms/ActiveMQOriginalDestinationTest.java | 4 ++--
.../component/jms/AggregratedJmsRouteTest.java | 6 +++---
.../camel/component/jms/BrowsableQueueTest.java | 10 ++++-----
.../component/jms/ConsumeJmsBytesMessageTest.java | 4 ++--
.../component/jms/ConsumeJmsMapMessageTest.java | 4 ++--
.../component/jms/ConsumeJmsObjectMessageTest.java | 4 ++--
.../component/jms/ConsumeMessageConverterTest.java | 4 ++--
.../jms/ConsumerTemplateJmsSelectorTest.java | 2 +-
.../jms/FileRouteJmsKeepLastModifiedTest.java | 4 ++--
.../component/jms/FileRouteJmsPreMoveTest.java | 4 ++--
.../camel/component/jms/FileRouteToJmsTest.java | 4 ++--
.../component/jms/FileRouteToJmsToFileTest.java | 4 ++--
.../component/jms/FromTextToBytesMessageTest.java | 4 ++--
.../jms/JmsAddAndRemoveRouteManagementTest.java | 6 +++---
.../jms/JmsAllowAdditionalHeadersTest.java | 4 ++--
.../camel/component/jms/JmsAllowNullBodyTest.java | 6 +++---
.../component/jms/JmsAsyncStartListenerTest.java | 4 ++--
.../jms/JmsAsyncStartStopListenerTest.java | 4 ++--
.../component/jms/JmsAsyncStopListenerTest.java | 4 ++--
.../camel/component/jms/JmsAutoStartupTest.java | 4 ++--
.../jms/JmsBatchResequencerJMSPriorityTest.java | 4 ++--
.../apache/camel/component/jms/JmsBindingTest.java | 2 +-
.../camel/component/jms/JmsClientAckTest.java | 4 ++--
.../camel/component/jms/JmsComponentTest.java | 6 +++---
.../component/jms/JmsConsumeTemplateTest.java | 2 +-
.../jms/JmsCustomHeaderFilterStrategyTest.java | 4 ++--
.../jms/JmsDeadLetterChannelInOutTest.java | 6 +++---
.../component/jms/JmsDeadLetterQueueTest.java | 4 ++--
...msDeadLetterQueueUsingTransferExchangeTest.java | 4 ++--
.../jms/JmsDefaultTaskExecutorTypeTest.java | 4 ++--
.../component/jms/JmsDestinationResolverTest.java | 4 ++--
.../camel/component/jms/JmsDurableTopicTest.java | 4 ++--
.../jms/JmsEagerLoadingPropertiesTest.java | 4 ++--
.../jms/JmsEndpointConfigurationTest.java | 24 +++++++++++-----------
.../jms/JmsErrorHandlerLogStackTraceTest.java | 6 +++---
.../jms/JmsFormatDateHeadersToIso8601Test.java | 8 ++++----
.../component/jms/JmsHeaderFilteringTest.java | 6 +++---
.../jms/JmsInOnlyDisableTimeToLiveTest.java | 4 ++--
.../jms/JmsInOnlyIncludeSentJMSMessageIDTest.java | 4 ++--
.../jms/JmsInOnlyInvalidDestinationTest.java | 4 ++--
.../component/jms/JmsInOnlyPooledExchangeTest.java | 4 ++--
.../jms/JmsInOnlyWithReplyToAsHeaderTest.java | 4 ++--
...ToDisabledButJMSReplyToHeaderPreservedTest.java | 4 ++--
.../jms/JmsInOnlyWithReplyToDisabledTest.java | 4 ++--
.../jms/JmsInOnlyWithReplyToHeaderTest.java | 4 ++--
.../jms/JmsInOnlyWithReplyToHeaderTopicTest.java | 4 ++--
.../jms/JmsInOnlyWithReplyToNotPreservedTest.java | 4 ++--
.../component/jms/JmsInOnlyWithReplyToTest.java | 4 ++--
.../component/jms/JmsInOutBeanReturnNullTest.java | 12 +++++------
.../jms/JmsInOutDisableTimeToLiveTest.java | 4 ++--
.../jms/JmsInOutFixedReplyQueueTimeoutTest.java | 4 ++--
...ueueTimeoutUseMessageIDAsCorrelationIDTest.java | 4 ++--
.../jms/JmsInOutIndividualRequestTimeoutTest.java | 4 ++--
.../component/jms/JmsInOutNonPersistentTest.java | 4 ++--
.../jms/JmsInOutSynchronousFalseTest.java | 6 +++---
.../component/jms/JmsInOutSynchronousTest.java | 6 +++---
.../component/jms/JmsInOutWithNoOutBodyTest.java | 6 +++---
.../jms/JmsIncludeAllJMSXPropertiesTest.java | 4 ++--
.../component/jms/JmsLoadBalanceFailoverTest.java | 4 ++--
...ailoverWithForceSendOriginalJmsMessageTest.java | 4 ++--
...geAsOriginalMessageInDefaultUnitOfWorkTest.java | 2 +-
.../component/jms/JmsMessageBodySetNullTest.java | 8 ++++----
.../JmsMessageCreatedStrategyComponentTest.java | 4 ++--
.../jms/JmsMessageCreatedStrategyEndpointTest.java | 4 ++--
.../jms/JmsMessageIDNotOverridenAMQTest.java | 4 ++--
.../component/jms/JmsMessageTimestampTest.java | 4 ++--
.../camel/component/jms/JmsMessageTypeTest.java | 4 ++--
.../component/jms/JmsMultipleConsumersTest.java | 4 ++--
.../component/jms/JmsNoRequestTimeoutTest.java | 6 +++---
.../JmsNotInOnlyIncludeSentJMSMessageIDTest.java | 4 ++--
.../jms/JmsNotIncludeAllJMSXPropertiesTest.java | 4 ++--
...OnCompletionAndInterceptAndOnExceptionTest.java | 6 +++---
.../camel/component/jms/JmsOnCompletionTest.java | 6 +++---
.../component/jms/JmsPollingConsumerTest.java | 4 ++--
.../jms/JmsProducerDisableReplyToTest.java | 2 +-
.../jms/JmsProducerWithJMSHeaderTest.java | 10 ++++-----
.../component/jms/JmsProduerConcurrentTest.java | 4 ++--
.../jms/JmsProduerConcurrentWithReplyTest.java | 4 ++--
.../camel/component/jms/JmsQosRouteTest.java | 4 ++--
.../camel/component/jms/JmsRemoveHeaderTest.java | 4 ++--
.../jms/JmsRequestReplyCorrelationTest.java | 4 ++--
...sRequestReplyExclusiveReplyToComponentTest.java | 6 +++---
...RequestReplyExclusiveReplyToConcurrentTest.java | 4 ++--
...estReplyExclusiveReplyToRemoveAddRouteTest.java | 6 +++---
.../jms/JmsRequestReplyExclusiveReplyToTest.java | 8 ++++----
.../JmsRequestReplyFixedReplyToInEndpointTest.java | 10 ++++-----
.../jms/JmsRequestReplyManualReplyTest.java | 2 +-
.../JmsRequestReplyManualWithJMSReplyToTest.java | 4 ++--
...lyProcessRepliesConcurrentUsingThreadsTest.java | 4 ++--
.../jms/JmsRequestReplyReplyToOverrideTest.java | 2 +-
.../jms/JmsRequestReplySharedReplyToTest.java | 6 +++---
...RequestReplyTempQueueMultipleConsumersTest.java | 4 ++--
.../jms/JmsRequestReplyTemporaryCacheNoneTest.java | 2 +-
.../jms/JmsRouteDeliveryModePreserveQoSTest.java | 4 ++--
.../component/jms/JmsRouteRequestReplyTest.java | 22 ++++++++++----------
.../apache/camel/component/jms/JmsRouteTest.java | 4 ++--
.../jms/JmsRouteTimeoutCheckerIntervalTest.java | 8 ++++----
.../camel/component/jms/JmsRouteTimeoutTest.java | 8 ++++----
.../camel/component/jms/JmsRouteToFileTest.java | 4 ++--
.../jms/JmsRouteUsingDifferentHeadersTest.java | 4 ++--
.../component/jms/JmsRouteUsingJMSXGroupTest.java | 4 ++--
.../JmsRouteWithCustomKeyFormatStrategyTest.java | 4 ++--
.../JmsRouteWithCustomListenerContainerTest.java | 4 ++--
.../JmsRouteWithDefaultKeyFormatStrategyTest.java | 6 +++---
.../jms/JmsRouteWithInOnlyAndMultipleAcksTest.java | 4 ++--
.../component/jms/JmsRouteWithInOnlyTest.java | 4 ++--
.../component/jms/JmsRoutingSlipInOutTest.java | 4 ++--
.../camel/component/jms/JmsRoutingSlipTest.java | 4 ++--
.../camel/component/jms/JmsSelectorInTest.java | 4 ++--
.../camel/component/jms/JmsSelectorOptionTest.java | 6 +++---
.../camel/component/jms/JmsSelectorTest.java | 4 ++--
.../apache/camel/component/jms/JmsSessionTest.java | 4 ++--
...BodyNullErrorHandlerUseOriginalMessageTest.java | 4 ++--
.../camel/component/jms/JmsSimpleHeaderTest.java | 4 ++--
.../component/jms/JmsSimpleInOnlyNoMutateTest.java | 4 ++--
.../jms/JmsSimpleRequestCustomReplyToTest.java | 4 ++--
.../jms/JmsSimpleRequestLateReplyTest.java | 4 ++--
.../component/jms/JmsSimpleRequestReply2Test.java | 4 ++--
.../JmsSimpleRequestReplyFixedReplyQueueTest.java | 4 ++--
.../component/jms/JmsSimpleRequestReplyTest.java | 4 ++--
.../jms/JmsSplitterParallelChainedTest.java | 4 ++--
.../component/jms/JmsSplitterParallelTest.java | 4 ++--
.../component/jms/JmsStreamMessageTypeTest.java | 4 ++--
.../camel/component/jms/JmsSuspendResumeTest.java | 4 ++--
.../jms/JmsTestConnectionOnStartupTest.java | 4 ++--
.../jms/JmsThrottlingInflightRoutePolicyTest.java | 4 ++--
.../camel/component/jms/JmsToDSendDynamicTest.java | 6 +++---
.../jms/JmsToDSendDynamicTwoDisabledTest.java | 6 +++---
.../component/jms/JmsToDSendDynamicTwoTest.java | 6 +++---
.../org/apache/camel/component/jms/JmsToDTest.java | 4 ++--
.../org/apache/camel/component/jms/JmsToTest.java | 4 ++--
.../component/jms/JmsTransactedRouteTest.java | 4 ++--
.../component/jms/JmsTransferExceptionTest.java | 6 +++---
.../jms/JmsTransferExchangeFromSplitterTest.java | 4 ++--
.../component/jms/JmsTransferExchangeTest.java | 4 ++--
.../component/jms/JmsUseOriginalBodyTest.java | 6 +++---
.../camel/component/jms/JmsXMLRouteTest.java | 4 ++--
.../camel/component/jms/JmsXPathHeaderTest.java | 4 ++--
.../component/jms/ManagedJmsEndpointTest.java | 6 +++---
.../component/jms/ManagedJmsEndpointTopicTest.java | 6 +++---
.../component/jms/ManagedJmsSelectorTest.java | 6 +++---
.../camel/component/jms/MapJmsMessageTest.java | 4 ++--
.../component/jms/PayloadByteArrayJmsTest.java | 4 ++--
.../component/jms/ProduceMessageConverterTest.java | 4 ++--
.../jms/ReplyToDestinationSelectorNameTest.java | 4 ++--
...RequestReplyCorrelatedWithCustomHeaderTest.java | 11 +++++-----
.../SimpleJmsRequestReplyExclusiveReplyToTest.java | 6 +++---
.../SimpleJmsRequestReplySharedReplyToTest.java | 6 +++---
.../component/jms/SimpleJmsRequestReplyTest.java | 6 +++---
.../component/jms/TwoConsumerOnSameQueueTest.java | 4 ++--
.../component/jms/TwoConsumerOnSameTopicTest.java | 4 ++--
.../ActiveMQConsumeWildcardQueuesTest.java | 4 ++--
.../jms/async/AsyncConsumerFalseTest.java | 4 ++--
.../jms/async/AsyncConsumerInOutTest.java | 4 ++--
.../jms/async/AsyncConsumerInOutTwoTest.java | 6 +++---
.../component/jms/async/AsyncConsumerTest.java | 4 ++--
.../component/jms/async/AsyncJmsInOutTest.java | 4 ++--
.../component/jms/async/AsyncJmsProducerTest.java | 4 ++--
.../camel/component/jms/async/MyAsyncEndpoint.java | 4 ++--
.../component/jms/discovery/JmsDiscoveryTest.java | 6 +++---
.../jms/issues/ActiveMQPropagateHeadersTest.java | 4 ++--
.../ActiveMQPropagateSerializableHeadersTest.java | 4 ++--
.../component/jms/issues/AdviceWithIssueTest.java | 4 ++--
.../jms/issues/BruceHandlingBeanExceptionTest.java | 10 ++++-----
...cRoutersWithJMSMessageLostHeadersIssueTest.java | 4 ++--
.../jms/issues/JmsAnotherCustomJMSReplyToTest.java | 4 ++--
.../jms/issues/JmsBeanMethodHeaderTest.java | 4 ++--
.../issues/JmsBlockedAsyncRoutingEngineTest.java | 4 ++--
.../issues/JmsChainedEndpointDelayTimeoutTest.java | 4 ++--
.../issues/JmsConcurrentConsumerInOnlyTest.java | 4 ++--
.../jms/issues/JmsConcurrentConsumersTest.java | 4 ++--
.../jms/issues/JmsCustomJMSReplyToIssueTest.java | 4 ++--
.../jms/issues/JmsDirectStartupOrderIssueTest.java | 4 ++--
.../jms/issues/JmsFilenameHeaderTest.java | 4 ++--
.../jms/issues/JmsGetHeaderKeyFormatIssueTest.java | 4 ++--
...derKeyFormatIssueWithContentTypeHeaderTest.java | 4 ++--
.../jms/issues/JmsHeaderAsObjectTest.java | 4 ++--
.../component/jms/issues/JmsInOnlyIssueTest.java | 4 ++--
.../jms/issues/JmsInOnlyParameterTest.java | 4 ++--
.../JmsInOutExclusiveTopicRecipientListTest.java | 4 ++--
.../jms/issues/JmsInOutExclusiveTopicTest.java | 4 ++--
.../component/jms/issues/JmsInOutIssueTest.java | 10 ++++-----
.../component/jms/issues/JmsInOutParallelTest.java | 4 ++--
.../issues/JmsInOutPersistentReplyQueueTest.java | 4 ++--
.../jms/issues/JmsInOutPipelineWithBeanTest.java | 10 ++++-----
.../issues/JmsInOutRepeatedInvocationsTest.java | 4 ++--
.../jms/issues/JmsInOutRoutingSlipTest.java | 4 ++--
.../JmsInOutUseMessageIDasCorrelationIDTest.java | 8 ++++----
...msJMSReplyToConsumerEndpointUsingInOutTest.java | 6 +++---
.../JmsJMSReplyToEndpointUsingInOutTest.java | 4 ++--
.../jms/issues/JmsLifecycleIssueTest.java | 4 ++--
.../jms/issues/JmsMQSpecialHeaderTest.java | 4 ++--
.../JmsMessageHeaderContentBasedRouterTest.java | 4 ++--
.../component/jms/issues/JmsMutateMessageTest.java | 4 ++--
.../issues/JmsMutateRemoveHeaderMessageTest.java | 4 ++--
...roughtJmsKeyFormatStrategyEndUserIssueTest.java | 4 ++--
...ssThroughtJmsKeyFormatStrategyEndpointTest.java | 4 ++--
.../JmsPassThroughtJmsKeyFormatStrategyTest.java | 4 ++--
...KeyFormatStrategyUsingJmsConfigurationTest.java | 4 ++--
.../issues/JmsReplyToComponentEndlessLoopTest.java | 2 +-
.../jms/issues/JmsReplyToLoopIssueTest.java | 4 ++--
.../jms/issues/JmsResequencerTestRouteBuilder.java | 2 +-
.../jms/issues/JmsRoutingSlipIssueTest.java | 4 ++--
...endToAlotOfDestinationWithSameEndpointTest.java | 2 +-
.../jms/issues/JmsToFileMessageIdTest.java | 4 ++--
...etterChannelHandlerRollbackOnExceptionTest.java | 8 ++++----
...erChannelNotHandlerRollbackOnExceptionTest.java | 2 +-
...ansactedOnExceptionRollbackOnExceptionTest.java | 8 ++++----
.../jms/issues/JmsTypeConverterIssueTest.java | 8 ++++----
.../camel/component/jms/issues/LarsIssueTest.java | 4 ++--
.../component/jms/issues/MQSeriesHeaderTest.java | 4 ++--
.../component/jms/issues/MyFailureProcessor.java | 2 +-
.../NoClassDefFoundErrorWrapExceptionTest.java | 6 +++---
.../camel/component/jms/issues/ProcessorA.java | 2 +-
.../camel/component/jms/issues/ProcessorB.java | 2 +-
.../camel/component/jms/issues/ProcessorFail.java | 2 +-
.../issues/RequestReplyWithProducerIssueTest.java | 4 ++--
.../component/jms/issues/TempReplyToIssueTest.java | 6 +++---
...TransactionErrorHandlerRedeliveryDelayTest.java | 2 +-
.../camel/component/jms/temp/JmsReconnectTest.java | 2 +-
...tReplyTemporaryRefreshFailureOnStartupTest.java | 4 ++--
.../jms/temp/TemporaryQueueRouteTest.java | 4 ++--
.../component/jms/tuning/PerformanceRouteTest.java | 4 ++--
.../component/jms/tx/AbstractTransactionTest.java | 2 +-
.../component/jms/tx/AsyncEndpointJmsTX2Test.java | 4 ++--
.../jms/tx/AsyncEndpointJmsTXMulticastTest.java | 4 ++--
.../tx/AsyncEndpointJmsTXRecipientListTest.java | 4 ++--
.../jms/tx/AsyncEndpointJmsTXRollback2Test.java | 4 ++--
.../jms/tx/AsyncEndpointJmsTXRollbackTest.java | 4 ++--
.../jms/tx/AsyncEndpointJmsTXRoutingSlipTest.java | 4 ++--
.../component/jms/tx/AsyncEndpointJmsTXTest.java | 4 ++--
.../tx/AsyncEndpointJmsTXTryCatchFinallyTest.java | 4 ++--
.../jms/tx/AsyncEndpointJmsTXWireTapTest.java | 4 ++--
.../jms/tx/JMSTXInOutPersistentQueueTest.java | 4 ++--
.../jms/tx/JMSTransactionErrorHandlerTest.java | 2 +-
.../JMSTransactionIsTransactedRedeliveredTest.java | 4 ++--
.../jms/tx/JMSTransactionRollbackTest.java | 2 +-
.../jms/tx/JMSTransactionalClientTest.java | 2 +-
.../tx/JMSTransactionalClientWithRollbackTest.java | 2 +-
.../component/jms/tx/JMXTXUseOriginalBodyTest.java | 2 +-
...MXTXUseOriginalBodyWithDLCErrorHandlerTest.java | 2 +-
...JMXTXUseOriginalBodyWithTXErrorHandlerTest.java | 2 +-
.../jms/tx/JmsToJmsTransactedSecurityTest.java | 4 ++--
.../component/jms/tx/JmsToJmsTransactedTest.java | 8 ++++----
.../jms/tx/QueueToProcessorTransactionTest.java | 2 +-
.../QueueToQueueRequestReplyTransactionTest.java | 2 +-
.../jms/tx/QueueToQueueTransactionTest.java | 2 +-
...sactionWithoutDefineTransactionManagerTest.java | 2 +-
.../component/jms/tx/RouteIdTransactedTest.java | 4 ++--
.../jms/tx/TransactedAsyncUsingThreadsTest.java | 4 ++--
.../jms/tx/TransactedOnCompletionTest.java | 2 +-
...sactionErrorHandlerBuilderAsSpringBeanTest.java | 2 +-
...actionErrorHandlerCustomerSpringParserTest.java | 2 +-
.../tx/TransactionMinimalConfigurationTest.java | 2 +-
254 files changed, 572 insertions(+), 573 deletions(-)
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ActiveMQOriginalDestinationTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ActiveMQOriginalDestinationTest.java
index 17e742d..c1adac5 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ActiveMQOriginalDestinationTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ActiveMQOriginalDestinationTest.java
@@ -75,10 +75,10 @@ public class ActiveMQOriginalDestinationTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.to("activemq:queue:bar")
.to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/AggregratedJmsRouteTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/AggregratedJmsRouteTest.java
index 989749c..e2e5cb8 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/AggregratedJmsRouteTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/AggregratedJmsRouteTest.java
@@ -82,9 +82,9 @@ public class AggregratedJmsRouteTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(timeOutEndpointUri).to("jms:queue:test.b");
from("jms:queue:test.b").aggregate(header("cheese"), (oldExchange, newExchange) -> {
@@ -110,7 +110,7 @@ public class AggregratedJmsRouteTest extends CamelTestSupport {
private static class MyProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
LOG.info("get the exchange here " + exchange);
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/BrowsableQueueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/BrowsableQueueTest.java
index f103a8b..b86fcf5 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/BrowsableQueueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/BrowsableQueueTest.java
@@ -38,7 +38,7 @@ public class BrowsableQueueTest extends CamelTestSupport {
protected Object[] expectedBodies = { "body1", "body2", "body3", "body4", "body5", "body6", "body7", "body8" };
@Test
- public void testSendMessagesThenBrowseQueue() throws Exception {
+ public void testSendMessagesThenBrowseQueue() {
// send some messages
for (int i = 0; i < expectedBodies.length; i++) {
Object expectedBody = expectedBodies[i];
@@ -63,7 +63,7 @@ public class BrowsableQueueTest extends CamelTestSupport {
}
@Test
- public void testSendMessagesThenBrowseQueueLimitNotHit() throws Exception {
+ public void testSendMessagesThenBrowseQueueLimitNotHit() {
// send some messages
for (int i = 0; i < expectedBodies.length; i++) {
Object expectedBody = expectedBodies[i];
@@ -88,7 +88,7 @@ public class BrowsableQueueTest extends CamelTestSupport {
}
@Test
- public void testSendMessagesThenBrowseQueueNoMax() throws Exception {
+ public void testSendMessagesThenBrowseQueueNoMax() {
// send some messages
for (int i = 0; i < expectedBodies.length; i++) {
Object expectedBody = expectedBodies[i];
@@ -123,9 +123,9 @@ public class BrowsableQueueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:test.a").to("activemq:test.b");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeJmsBytesMessageTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeJmsBytesMessageTest.java
index 623c1d6..8947387 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeJmsBytesMessageTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeJmsBytesMessageTest.java
@@ -110,9 +110,9 @@ public class ConsumeJmsBytesMessageTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:test.bytes").to("mock:result");
from("direct:test").to("activemq:test.bytes");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeJmsMapMessageTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeJmsMapMessageTest.java
index 89c3262..4181045 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeJmsMapMessageTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeJmsMapMessageTest.java
@@ -113,9 +113,9 @@ public class ConsumeJmsMapMessageTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:test.map").to("mock:result");
from("direct:test").to("activemq:test.map");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeJmsObjectMessageTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeJmsObjectMessageTest.java
index b77ab6b..08159bf 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeJmsObjectMessageTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeJmsObjectMessageTest.java
@@ -102,9 +102,9 @@ public class ConsumeJmsObjectMessageTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:test.object").to("mock:result");
from("direct:test").to("activemq:test.object");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeMessageConverterTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeMessageConverterTest.java
index 2aa1d0d..bc34082 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeMessageConverterTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumeMessageConverterTest.java
@@ -72,9 +72,9 @@ public class ConsumeMessageConverterTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello?messageConverter=#myMessageConverter").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumerTemplateJmsSelectorTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumerTemplateJmsSelectorTest.java
index a0567f1..78584b1 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumerTemplateJmsSelectorTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ConsumerTemplateJmsSelectorTest.java
@@ -28,7 +28,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class ConsumerTemplateJmsSelectorTest extends CamelTestSupport {
@Test
- public void testJmsSelector() throws Exception {
+ public void testJmsSelector() {
// must start CamelContext because use route builder is false
context.start();
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteJmsKeepLastModifiedTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteJmsKeepLastModifiedTest.java
index 3eee1ea..a5782f2 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteJmsKeepLastModifiedTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteJmsKeepLastModifiedTest.java
@@ -71,9 +71,9 @@ public class FileRouteJmsKeepLastModifiedTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("file://target/inbox?noop=true").to("activemq:queue:hello");
from("activemq:queue:hello")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteJmsPreMoveTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteJmsPreMoveTest.java
index df9b7ac..df2b08a 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteJmsPreMoveTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteJmsPreMoveTest.java
@@ -64,9 +64,9 @@ public class FileRouteJmsPreMoveTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("file://target/inbox?preMove=transfer").to("activemq:queue:hello");
from("activemq:queue:hello")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteToJmsTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteToJmsTest.java
index 68ee2ba..c815aca 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteToJmsTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteToJmsTest.java
@@ -59,9 +59,9 @@ public class FileRouteToJmsTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("file://target/routefromfile").to("activemq:queue:hello");
from("activemq:queue:hello").to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteToJmsToFileTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteToJmsToFileTest.java
index 06f5411..9feda4b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteToJmsToFileTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/FileRouteToJmsToFileTest.java
@@ -68,9 +68,9 @@ public class FileRouteToJmsToFileTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("file://target/file2file/in").to("activemq:queue:hello");
from("activemq:queue:hello").to("file://target/file2file/out", "mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/FromTextToBytesMessageTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/FromTextToBytesMessageTest.java
index 549be21..6cb75ff 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/FromTextToBytesMessageTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/FromTextToBytesMessageTest.java
@@ -86,10 +86,10 @@ public class FromTextToBytesMessageTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo?jmsMessageType=Text")
.to("activemq:queue:bar?jmsMessageType=Bytes");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAddAndRemoveRouteManagementTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAddAndRemoveRouteManagementTest.java
index 811d71c..d2fb975 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAddAndRemoveRouteManagementTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAddAndRemoveRouteManagementTest.java
@@ -54,7 +54,7 @@ public class JmsAddAndRemoveRouteManagementTest extends CamelTestSupport {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:in").routeId("myNewRoute")
.to("activemq:queue:foo");
}
@@ -85,10 +85,10 @@ public class JmsAddAndRemoveRouteManagementTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAllowAdditionalHeadersTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAllowAdditionalHeadersTest.java
index 7f4cc4b..6e9f7e8 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAllowAdditionalHeadersTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAllowAdditionalHeadersTest.java
@@ -59,10 +59,10 @@ public class JmsAllowAdditionalHeadersTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to("jms:queue:bar");
from("jms:queue:bar").to("mock:bar");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAllowNullBodyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAllowNullBodyTest.java
index 15a9379..ac1b98f6 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAllowNullBodyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAllowNullBodyTest.java
@@ -70,7 +70,7 @@ public class JmsAllowNullBodyTest extends CamelTestSupport {
}
@Test
- public void testNoAllowNullBody() throws Exception {
+ public void testNoAllowNullBody() {
try {
template.sendBodyAndHeader("activemq:queue:foo?allowNullBody=false", null, "bar", 123);
fail("Should have thrown exception");
@@ -89,10 +89,10 @@ public class JmsAllowNullBodyTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAsyncStartListenerTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAsyncStartListenerTest.java
index ae59c9d..476c654 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAsyncStartListenerTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAsyncStartListenerTest.java
@@ -59,9 +59,9 @@ public class JmsAsyncStartListenerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAsyncStartStopListenerTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAsyncStartStopListenerTest.java
index 15d9501..a058b3d 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAsyncStartStopListenerTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAsyncStartStopListenerTest.java
@@ -60,9 +60,9 @@ public class JmsAsyncStartStopListenerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello").process(exchange -> exchange.getIn().setBody("Bye World")).to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAsyncStopListenerTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAsyncStopListenerTest.java
index 94c498f..a529036 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAsyncStopListenerTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAsyncStopListenerTest.java
@@ -57,9 +57,9 @@ public class JmsAsyncStopListenerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello2").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAutoStartupTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAutoStartupTest.java
index bfb0637..94f96bd 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAutoStartupTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAutoStartupTest.java
@@ -59,10 +59,10 @@ public class JmsAutoStartupTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
endpoint = context.getEndpoint("activemq:queue:foo?autoStartup=false", JmsEndpoint.class);
from(endpoint).to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsBatchResequencerJMSPriorityTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsBatchResequencerJMSPriorityTest.java
index a6a923a..e4fb710 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsBatchResequencerJMSPriorityTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsBatchResequencerJMSPriorityTest.java
@@ -60,10 +60,10 @@ public class JmsBatchResequencerJMSPriorityTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// START SNIPPET: e1
from("jms:queue:foo")
// sort by JMSPriority by allowing duplicates (message can have same JMSPriority)
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsBindingTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsBindingTest.java
index 8f57fa4..6d0eb7c 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsBindingTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsBindingTest.java
@@ -71,7 +71,7 @@ public class JmsBindingTest {
}
@Test
- public void testExtractNullBodyFromJmsShouldReturnNull() throws Exception {
+ public void testExtractNullBodyFromJmsShouldReturnNull() {
assertNull(jmsBindingUnderTest.extractBodyFromJms(null, new ActiveMQBlobMessage()));
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsClientAckTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsClientAckTest.java
index 9646e3d..ef3b58cc 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsClientAckTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsClientAckTest.java
@@ -54,10 +54,10 @@ public class JmsClientAckTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.process(exchange -> {
JmsMessage jms = exchange.getIn(JmsMessage.class);
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsComponentTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsComponentTest.java
index 2ebda6c..de8c1b7 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsComponentTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsComponentTest.java
@@ -32,7 +32,7 @@ public class JmsComponentTest extends CamelTestSupport {
protected JmsEndpoint endpoint;
@Test
- public void testComponentOptions() throws Exception {
+ public void testComponentOptions() {
String reply = template.requestBody("activemq123:queue:hello?requestTimeout=5000", "Hello World", String.class);
assertEquals("Bye World", reply);
@@ -94,9 +94,9 @@ public class JmsComponentTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(endpoint).transform(constant("Bye World"));
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsConsumeTemplateTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsConsumeTemplateTest.java
index abfbc98..d9f438d 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsConsumeTemplateTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsConsumeTemplateTest.java
@@ -28,7 +28,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class JmsConsumeTemplateTest extends CamelTestSupport {
@Test
- public void testConsumeTemplate() throws Exception {
+ public void testConsumeTemplate() {
// must start CamelContext because use route builder is false
context.start();
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsCustomHeaderFilterStrategyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsCustomHeaderFilterStrategyTest.java
index 1951c5e..add212c 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsCustomHeaderFilterStrategyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsCustomHeaderFilterStrategyTest.java
@@ -65,10 +65,10 @@ public class JmsCustomHeaderFilterStrategyTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo?eagerLoadingOfProperties=true").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterChannelInOutTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterChannelInOutTest.java
index cf84cf7..d11bf10 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterChannelInOutTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterChannelInOutTest.java
@@ -32,7 +32,7 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
public class JmsDeadLetterChannelInOutTest extends CamelTestSupport {
@Test
- public void testJmsDLCInOut() throws Exception {
+ public void testJmsDLCInOut() {
Exchange out = template.send("direct:start", exchange -> {
// use InOut
exchange.setPattern(ExchangePattern.InOut);
@@ -58,10 +58,10 @@ public class JmsDeadLetterChannelInOutTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
errorHandler(deadLetterChannel("activemq:queue:error"));
from("direct:start").throwException(new IllegalArgumentException("Damn"));
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueTest.java
index acb9fa9..c76f567 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueTest.java
@@ -71,10 +71,10 @@ public class JmsDeadLetterQueueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
errorHandler(deadLetterChannel("seda:dead").disableRedelivery());
from("direct:start").process(exchange -> {
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueUsingTransferExchangeTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueUsingTransferExchangeTest.java
index 95544c6..d7ec4e1 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueUsingTransferExchangeTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueUsingTransferExchangeTest.java
@@ -66,10 +66,10 @@ public class JmsDeadLetterQueueUsingTransferExchangeTest extends CamelTestSuppor
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
errorHandler(deadLetterChannel(getUri()).disableRedelivery());
from("direct:start").process(exchange -> {
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDefaultTaskExecutorTypeTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDefaultTaskExecutorTypeTest.java
index 5a4b5e6..542aa3d 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDefaultTaskExecutorTypeTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDefaultTaskExecutorTypeTest.java
@@ -160,10 +160,10 @@ public class JmsDefaultTaskExecutorTypeTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo.simpleAsync?defaultTaskExecutorType=SimpleAsync").routeId("simpleAsync")
.noAutoStartup()
.to("mock:result.simpleAsync")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDestinationResolverTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDestinationResolverTest.java
index 8237473..8b59c6f 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDestinationResolverTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDestinationResolverTest.java
@@ -55,9 +55,9 @@ public class JmsDestinationResolverTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to("activemq:queue:logicalNameForTestBQueue");
from("activemq:queue:test.b").to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDurableTopicTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDurableTopicTest.java
index 79371a6..d9b6770 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDurableTopicTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDurableTopicTest.java
@@ -53,10 +53,10 @@ public class JmsDurableTopicTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:topic:foo?clientId=123&durableSubscriptionName=bar")
.to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsEagerLoadingPropertiesTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsEagerLoadingPropertiesTest.java
index dd13bcc..fdede2a 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsEagerLoadingPropertiesTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsEagerLoadingPropertiesTest.java
@@ -51,10 +51,10 @@ public class JmsEagerLoadingPropertiesTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo?eagerLoadingOfProperties=true").process(exchange -> {
String name = exchange.getIn().getHeader("name", String.class);
assertEquals("Claus", name);
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsEndpointConfigurationTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsEndpointConfigurationTest.java
index 3cd63b4..ce5a5cf 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsEndpointConfigurationTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsEndpointConfigurationTest.java
@@ -105,7 +105,7 @@ public class JmsEndpointConfigurationTest extends CamelTestSupport {
}
@Test
- public void testSetUsernameAndPassword() throws Exception {
+ public void testSetUsernameAndPassword() {
JmsEndpoint endpoint = resolveMandatoryEndpoint("jms:topic:Foo.Bar?username=James&password=ABC", JmsEndpoint.class);
ConnectionFactory cf = endpoint.getConfiguration().getConnectionFactory();
assertNotNull(cf, "The connectionFactory should not be null");
@@ -114,7 +114,7 @@ public class JmsEndpointConfigurationTest extends CamelTestSupport {
}
@Test
- public void testSetConnectionFactoryAndUsernameAndPassword() throws Exception {
+ public void testSetConnectionFactoryAndUsernameAndPassword() {
JmsEndpoint endpoint = resolveMandatoryEndpoint(
"jms:topic:Foo.Bar?connectionFactory=#myConnectionFactory&username=James&password=ABC", JmsEndpoint.class);
ConnectionFactory cf = endpoint.getConfiguration().getConnectionFactory();
@@ -204,13 +204,13 @@ public class JmsEndpointConfigurationTest extends CamelTestSupport {
}
@Test
- public void testMaxConcurrentConsumers() throws Exception {
+ public void testMaxConcurrentConsumers() {
JmsEndpoint endpoint = resolveMandatoryEndpoint("jms:queue:Foo?maxConcurrentConsumers=5", JmsEndpoint.class);
assertEquals(5, endpoint.getMaxConcurrentConsumers());
}
@Test
- public void testMaxConcurrentConsumersForSimpleConsumer() throws Exception {
+ public void testMaxConcurrentConsumersForSimpleConsumer() {
JmsEndpoint endpoint
= resolveMandatoryEndpoint("jms:queue:Foo?maxConcurrentConsumers=5&consumerType=Simple", JmsEndpoint.class);
assertEquals(5, endpoint.getMaxConcurrentConsumers());
@@ -258,34 +258,34 @@ public class JmsEndpointConfigurationTest extends CamelTestSupport {
}
@Test
- public void testConcurrentConsumers() throws Exception {
+ public void testConcurrentConsumers() {
JmsEndpoint endpoint = resolveMandatoryEndpoint("jms:queue:Foo?concurrentConsumers=4", JmsEndpoint.class);
assertEquals(4, endpoint.getConcurrentConsumers());
}
@Test
- public void testConcurrentConsumersForSimpleConsumer() throws Exception {
+ public void testConcurrentConsumersForSimpleConsumer() {
JmsEndpoint endpoint
= resolveMandatoryEndpoint("jms:queue:Foo?concurrentConsumers=4&consumerType=Simple", JmsEndpoint.class);
assertEquals(4, endpoint.getConcurrentConsumers());
}
@Test
- public void testPubSubNoLocalForSimpleConsumer() throws Exception {
+ public void testPubSubNoLocalForSimpleConsumer() {
JmsEndpoint endpoint
= resolveMandatoryEndpoint("jms:queue:Foo?pubSubNoLocal=true&consumerType=Simple", JmsEndpoint.class);
assertTrue(endpoint.isPubSubNoLocal(), "PubSubNoLocal should be true");
}
@Test
- public void testIdleTaskExecutionLimit() throws Exception {
+ public void testIdleTaskExecutionLimit() {
JmsEndpoint endpoint = resolveMandatoryEndpoint("jms:queue:Foo?idleTaskExecutionLimit=50", JmsEndpoint.class);
assertEquals(50, endpoint.getIdleTaskExecutionLimit());
assertTrue(endpoint.isAutoStartup());
}
@Test
- public void testIdleConsumerLimit() throws Exception {
+ public void testIdleConsumerLimit() {
JmsEndpoint endpoint = resolveMandatoryEndpoint("jms:queue:Foo?idleConsumerLimit=51", JmsEndpoint.class);
assertEquals(51, endpoint.getIdleConsumerLimit());
assertTrue(endpoint.isAutoStartup());
@@ -293,13 +293,13 @@ public class JmsEndpointConfigurationTest extends CamelTestSupport {
}
@Test
- public void testLazyCreateTransactionManager() throws Exception {
+ public void testLazyCreateTransactionManager() {
JmsEndpoint endpoint = resolveMandatoryEndpoint("jms:queue:Foo?lazyCreateTransactionManager=true", JmsEndpoint.class);
assertTrue(endpoint.getConfiguration().isLazyCreateTransactionManager());
}
@Test
- public void testDefaultEndpointOptions() throws Exception {
+ public void testDefaultEndpointOptions() {
JmsEndpoint endpoint = resolveMandatoryEndpoint("jms:queue:Foo", JmsEndpoint.class);
assertNotNull(endpoint.getBinding());
@@ -396,7 +396,7 @@ public class JmsEndpointConfigurationTest extends CamelTestSupport {
}
@Test
- public void testSettingEndpointOptions() throws Exception {
+ public void testSettingEndpointOptions() {
JmsEndpoint endpoint = resolveMandatoryEndpoint("jms:queue:Foo", JmsEndpoint.class);
endpoint.setAcceptMessagesWhileStopping(true);
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsErrorHandlerLogStackTraceTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsErrorHandlerLogStackTraceTest.java
index 59625b2..80b6cd0 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsErrorHandlerLogStackTraceTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsErrorHandlerLogStackTraceTest.java
@@ -34,7 +34,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class JmsErrorHandlerLogStackTraceTest extends CamelTestSupport {
@Test
- public void testErrorHandlerLogStackTrace() throws Exception {
+ public void testErrorHandlerLogStackTrace() {
JmsComponent jms = context.getComponent("jms", JmsComponent.class);
assertFalse(jms.getConfiguration().isErrorHandlerLogStackTrace());
@@ -47,10 +47,10 @@ public class JmsErrorHandlerLogStackTraceTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// dont log any exhausted errors
errorHandler(defaultErrorHandler().logExhausted(false));
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsFormatDateHeadersToIso8601Test.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsFormatDateHeadersToIso8601Test.java
index b59e706..dd3efd6 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsFormatDateHeadersToIso8601Test.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsFormatDateHeadersToIso8601Test.java
@@ -35,13 +35,13 @@ public class JmsFormatDateHeadersToIso8601Test extends CamelTestSupport {
private static final Date DATE = Date.from(Instant.ofEpochMilli(1519672338000L));
@Test
- public void testComponentFormatDateHeaderToIso8601() throws Exception {
+ public void testComponentFormatDateHeaderToIso8601() {
String outDate = template.requestBodyAndHeader("direct:start-isoformat", "body", "date", DATE, String.class);
assertEquals("2018-02-26T19:12:18Z", outDate);
}
@Test
- public void testBindingFormatDateHeaderToIso8601() throws Exception {
+ public void testBindingFormatDateHeaderToIso8601() {
String outDate = template.requestBodyAndHeader("direct:start-nonisoformat", "body", "date", DATE, String.class);
assertNotEquals("2018-02-26T19:12:18Z", outDate);
}
@@ -57,10 +57,10 @@ public class JmsFormatDateHeadersToIso8601Test extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start-isoformat").to("activemq:queue:foo");
from("direct:start-nonisoformat").to("activemq:queue:foo?formatDateHeadersToIso8601=false");
from("activemq:queue:foo").setBody(simple("${in.header.date}"));
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsHeaderFilteringTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsHeaderFilteringTest.java
index e2e51dc..31932b7 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsHeaderFilteringTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsHeaderFilteringTest.java
@@ -84,9 +84,9 @@ public class JmsHeaderFilteringTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
onException(AssertionError.class).to(assertionReceiver);
@@ -125,7 +125,7 @@ public class JmsHeaderFilteringTest extends CamelTestSupport {
class InHeaderChecker implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
// filtered out by "in" filter
assertNull(exchange.getIn().getHeader("testheader"));
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyDisableTimeToLiveTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyDisableTimeToLiveTest.java
index d1da36b..a357bb7 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyDisableTimeToLiveTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyDisableTimeToLiveTest.java
@@ -93,9 +93,9 @@ public class JmsInOnlyDisableTimeToLiveTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:timeout")
.to(urlTimeout)
.to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyIncludeSentJMSMessageIDTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyIncludeSentJMSMessageIDTest.java
index 0a73ab7..ad05280 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyIncludeSentJMSMessageIDTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyIncludeSentJMSMessageIDTest.java
@@ -62,10 +62,10 @@ public class JmsInOnlyIncludeSentJMSMessageIDTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("activemq:queue:foo?includeSentJMSMessageID=true")
.to("mock:done");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyInvalidDestinationTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyInvalidDestinationTest.java
index 8764320..4843b95 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyInvalidDestinationTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyInvalidDestinationTest.java
@@ -57,10 +57,10 @@ public class JmsInOnlyInvalidDestinationTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
errorHandler(deadLetterChannel("mock:dead").maximumRedeliveries(1));
from("direct:foo").recipientList(header("foo"));
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyPooledExchangeTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyPooledExchangeTest.java
index 6d19057..e05dadd 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyPooledExchangeTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyPooledExchangeTest.java
@@ -67,10 +67,10 @@ public class JmsInOnlyPooledExchangeTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(JMS_QUEUE_NAME)
.to(MOCK_RESULT);
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToAsHeaderTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToAsHeaderTest.java
index f89ca37..b70b2ab 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToAsHeaderTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToAsHeaderTest.java
@@ -47,10 +47,10 @@ public class JmsInOnlyWithReplyToAsHeaderTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
// must enable preserveMessageQos to force Camel to use the JMSReplyTo header
.to("activemq:queue:foo?preserveMessageQos=true")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToDisabledButJMSReplyToHeaderPreservedTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToDisabledButJMSReplyToHeaderPreservedTest.java
index 6f4a0a9..bb09fda 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToDisabledButJMSReplyToHeaderPreservedTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToDisabledButJMSReplyToHeaderPreservedTest.java
@@ -47,10 +47,10 @@ public class JmsInOnlyWithReplyToDisabledButJMSReplyToHeaderPreservedTest extend
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
// must use preserveMessageQos to include JMSReplyTo
.to("activemq:queue:foo?replyTo=queue:bar&preserveMessageQos=true")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToDisabledTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToDisabledTest.java
index b499a03..155bcf5 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToDisabledTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToDisabledTest.java
@@ -47,10 +47,10 @@ public class JmsInOnlyWithReplyToDisabledTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("activemq:queue:foo?replyTo=queue:bar&disableReplyTo=true")
.to("mock:done");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToHeaderTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToHeaderTest.java
index cccaa2e..ded1c3c 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToHeaderTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToHeaderTest.java
@@ -56,10 +56,10 @@ public class JmsInOnlyWithReplyToHeaderTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.transform(body().prepend("Hello "))
.to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToHeaderTopicTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToHeaderTopicTest.java
index ab7dd30..dcaf1a1 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToHeaderTopicTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToHeaderTopicTest.java
@@ -53,10 +53,10 @@ public class JmsInOnlyWithReplyToHeaderTopicTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.transform(body().prepend("Hello "))
.to("log:result")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToNotPreservedTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToNotPreservedTest.java
index 2214f46..8dd49a9 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToNotPreservedTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToNotPreservedTest.java
@@ -51,10 +51,10 @@ public class JmsInOnlyWithReplyToNotPreservedTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("activemq:queue:foo?replyTo=queue:bar")
.to("mock:done");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToTest.java
index b4217b7..c5c5c99 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToTest.java
@@ -47,10 +47,10 @@ public class JmsInOnlyWithReplyToTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("activemq:queue:foo?replyTo=queue:bar&preserveMessageQos=true")
.to("mock:done");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutBeanReturnNullTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutBeanReturnNullTest.java
index 7e8d340..0cde1d4 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutBeanReturnNullTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutBeanReturnNullTest.java
@@ -39,26 +39,26 @@ import static org.junit.jupiter.api.Assertions.assertNull;
public class JmsInOutBeanReturnNullTest extends CamelTestSupport {
@Test
- public void testReturnBean() throws Exception {
+ public void testReturnBean() {
MyBean out = template.requestBody("activemq:queue:foo", "Camel", MyBean.class);
assertNotNull(out);
assertEquals("Camel", out.getName());
}
@Test
- public void testReturnNull() throws Exception {
+ public void testReturnNull() {
Object out = template.requestBody("activemq:queue:foo", "foo");
assertNull(out);
}
@Test
- public void testReturnNullMyBean() throws Exception {
+ public void testReturnNullMyBean() {
MyBean out = template.requestBody("activemq:queue:foo", "foo", MyBean.class);
assertNull(out);
}
@Test
- public void testReturnNullExchange() throws Exception {
+ public void testReturnNullExchange() {
Exchange reply = template.request("activemq:queue:foo", exchange -> exchange.getIn().setBody("foo"));
assertNotNull(reply);
assertNotEquals("foo", reply.getMessage().getBody(), "There shouldn't be an out message");
@@ -77,10 +77,10 @@ public class JmsInOutBeanReturnNullTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.bean(JmsInOutBeanReturnNullTest.class, "doSomething");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutDisableTimeToLiveTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutDisableTimeToLiveTest.java
index dfaf0d2..c7310b1 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutDisableTimeToLiveTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutDisableTimeToLiveTest.java
@@ -87,9 +87,9 @@ public class JmsInOutDisableTimeToLiveTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:timeout")
.to(urlTimeout)
.to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutFixedReplyQueueTimeoutTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutFixedReplyQueueTimeoutTest.java
index c9d0860..3a36be3 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutFixedReplyQueueTimeoutTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutFixedReplyQueueTimeoutTest.java
@@ -73,9 +73,9 @@ public class JmsInOutFixedReplyQueueTimeoutTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to(ExchangePattern.InOut, "activemq:queue:foo?replyTo=queue:bar&requestTimeout=2000")
.to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutFixedReplyQueueTimeoutUseMessageIDAsCorrelationIDTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutFixedReplyQueueTimeoutUseMessageIDAsCorrelationIDTest.java
index 690e460..7a7df65 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutFixedReplyQueueTimeoutUseMessageIDAsCorrelationIDTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutFixedReplyQueueTimeoutUseMessageIDAsCorrelationIDTest.java
@@ -25,9 +25,9 @@ import org.apache.camel.builder.RouteBuilder;
public class JmsInOutFixedReplyQueueTimeoutUseMessageIDAsCorrelationIDTest extends JmsInOutFixedReplyQueueTimeoutTest {
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to(ExchangePattern.InOut,
"activemq:queue:foo?replyTo=queue:bar&useMessageIDAsCorrelationID=true&requestTimeout=2000")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutIndividualRequestTimeoutTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutIndividualRequestTimeoutTest.java
index 49868c4..c8f9488 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutIndividualRequestTimeoutTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutIndividualRequestTimeoutTest.java
@@ -85,9 +85,9 @@ public class JmsInOutIndividualRequestTimeoutTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to(ExchangePattern.InOut, "activemq:queue:foo?replyTo=queue:bar&requestTimeout=2000")
.to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutNonPersistentTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutNonPersistentTest.java
index 843bd8b..88d1255 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutNonPersistentTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutNonPersistentTest.java
@@ -51,10 +51,10 @@ public class JmsInOutNonPersistentTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("activemq:queue:foo?replyTo=queue:bar&deliveryPersistent=false")
.to("log:done?showAll=true", "mock:done");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutSynchronousFalseTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutSynchronousFalseTest.java
index fcd6401..4941064 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutSynchronousFalseTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutSynchronousFalseTest.java
@@ -34,7 +34,7 @@ public class JmsInOutSynchronousFalseTest extends CamelTestSupport {
private String url = "activemq:queue:in?synchronous=false";
@Test
- public void testSynchronous() throws Exception {
+ public void testSynchronous() {
String reply = template.requestBody("direct:start", "Hello World", String.class);
assertEquals("Bye World", reply);
@@ -50,9 +50,9 @@ public class JmsInOutSynchronousFalseTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("log:before")
.process(exchange -> beforeThreadName = Thread.currentThread().getName())
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutSynchronousTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutSynchronousTest.java
index aec90ee..912402f 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutSynchronousTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutSynchronousTest.java
@@ -34,7 +34,7 @@ public class JmsInOutSynchronousTest extends CamelTestSupport {
private String url = "activemq:queue:in?synchronous=true";
@Test
- public void testSynchronous() throws Exception {
+ public void testSynchronous() {
String reply = template.requestBody("direct:start", "Hello World", String.class);
assertEquals("Bye World", reply);
@@ -50,9 +50,9 @@ public class JmsInOutSynchronousTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("log:before")
.process(exchange -> beforeThreadName = Thread.currentThread().getName())
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutWithNoOutBodyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutWithNoOutBodyTest.java
index 21818d7..fb3f97a 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutWithNoOutBodyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutWithNoOutBodyTest.java
@@ -32,7 +32,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class JmsInOutWithNoOutBodyTest extends CamelTestSupport {
@Test
- public void testWithNoOutBodySet() throws Exception {
+ public void testWithNoOutBodySet() {
String reply = template.requestBody("direct:start", "Foo", String.class);
assertEquals("Foo", reply);
}
@@ -46,9 +46,9 @@ public class JmsInOutWithNoOutBodyTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("log:before")
.to("activemq:request")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsIncludeAllJMSXPropertiesTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsIncludeAllJMSXPropertiesTest.java
index 02c1996..a94196b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsIncludeAllJMSXPropertiesTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsIncludeAllJMSXPropertiesTest.java
@@ -58,9 +58,9 @@ public class JmsIncludeAllJMSXPropertiesTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:in")
.to("mock:result");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsLoadBalanceFailoverTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsLoadBalanceFailoverTest.java
index 8ad60f7..28485c7 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsLoadBalanceFailoverTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsLoadBalanceFailoverTest.java
@@ -44,10 +44,10 @@ public class JmsLoadBalanceFailoverTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.loadBalance().failover()
.to("jms:queue:foo?transferException=true")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsLoadBalanceFailoverWithForceSendOriginalJmsMessageTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsLoadBalanceFailoverWithForceSendOriginalJmsMessageTest.java
index e818c42..302da3b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsLoadBalanceFailoverWithForceSendOriginalJmsMessageTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsLoadBalanceFailoverWithForceSendOriginalJmsMessageTest.java
@@ -89,10 +89,10 @@ public class JmsLoadBalanceFailoverWithForceSendOriginalJmsMessageTest extends C
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("jms:queue:start?mapJmsMessage=false")
.loadBalance().failover(-1, false, true)
.to("jms:queue:one?forceSendOriginalMessage=" + forceSendOriginalMessage)
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageAsOriginalMessageInDefaultUnitOfWorkTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageAsOriginalMessageInDefaultUnitOfWorkTest.java
index e2d1c0c..15591e5 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageAsOriginalMessageInDefaultUnitOfWorkTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageAsOriginalMessageInDefaultUnitOfWorkTest.java
@@ -34,7 +34,7 @@ public class JmsMessageAsOriginalMessageInDefaultUnitOfWorkTest extends CamelTes
public void testUseOriginalMessage() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
onException(Exception.class)
.useOriginalMessage()
.to(mockResult);
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageBodySetNullTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageBodySetNullTest.java
index 8ba2654..b2e509c 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageBodySetNullTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageBodySetNullTest.java
@@ -34,7 +34,7 @@ public class JmsMessageBodySetNullTest extends CamelTestSupport {
public void testSetNullBodyUsingProcessor() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("jms:queue:foo")
.to("mock:foo")
.process(exchange -> exchange.getIn().setBody(null))
@@ -56,7 +56,7 @@ public class JmsMessageBodySetNullTest extends CamelTestSupport {
public void testSetNullBodyUsingProcessorPreserveHeaders() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("jms:queue:foo")
.to("mock:foo")
.process(exchange -> exchange.getIn().setBody(null))
@@ -80,7 +80,7 @@ public class JmsMessageBodySetNullTest extends CamelTestSupport {
public void testSetNullBodyUsingSetBody() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("jms:queue:foo")
.to("mock:foo")
.setBody(simple("${null}"))
@@ -102,7 +102,7 @@ public class JmsMessageBodySetNullTest extends CamelTestSupport {
public void testSetNullBodyUsingSetBodyPreserveHeaders() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("jms:queue:foo")
.to("mock:foo")
.setBody(simple("${null}"))
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageCreatedStrategyComponentTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageCreatedStrategyComponentTest.java
index 997a444..85fd012 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageCreatedStrategyComponentTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageCreatedStrategyComponentTest.java
@@ -59,10 +59,10 @@ public class JmsMessageCreatedStrategyComponentTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.to("mock:result");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageCreatedStrategyEndpointTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageCreatedStrategyEndpointTest.java
index 07bb3ba..16b5b32 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageCreatedStrategyEndpointTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageCreatedStrategyEndpointTest.java
@@ -62,10 +62,10 @@ public class JmsMessageCreatedStrategyEndpointTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageIDNotOverridenAMQTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageIDNotOverridenAMQTest.java
index 198e4e7..2e9b527 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageIDNotOverridenAMQTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageIDNotOverridenAMQTest.java
@@ -70,10 +70,10 @@ public class JmsMessageIDNotOverridenAMQTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("activemq:queue:foo?includeSentJMSMessageID=true")
.to("mock:done");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageTimestampTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageTimestampTest.java
index ec90916..098e3d1 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageTimestampTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageTimestampTest.java
@@ -53,9 +53,9 @@ public class JmsMessageTimestampTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageTypeTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageTypeTest.java
index 9043016..77b868d 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageTypeTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMessageTypeTest.java
@@ -202,10 +202,10 @@ public class JmsMessageTypeTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:text").to("jms:queue:foo?jmsMessageType=Text");
from("direct:bytes").to("jms:queue:foo?jmsMessageType=Bytes");
from("direct:map").to("jms:queue:foo?jmsMessageType=Map");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMultipleConsumersTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMultipleConsumersTest.java
index a7a6d5d..8c1fbbf 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMultipleConsumersTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsMultipleConsumersTest.java
@@ -31,7 +31,7 @@ public class JmsMultipleConsumersTest extends CamelTestSupport {
public void testMultipleConsumersTopic() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("jms:topic:foo").to("mock:foo");
from("direct:start").to("mock:result");
@@ -57,7 +57,7 @@ public class JmsMultipleConsumersTest extends CamelTestSupport {
public void testMultipleConsumersQueue() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("jms:queue:foo").to("mock:result");
from("direct:start").to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsNoRequestTimeoutTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsNoRequestTimeoutTest.java
index 0f66119..00b253e 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsNoRequestTimeoutTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsNoRequestTimeoutTest.java
@@ -31,7 +31,7 @@ public class JmsNoRequestTimeoutTest extends CamelTestSupport {
protected String componentName = "activemq";
@Test
- public void testNoRequestTimeout() throws Exception {
+ public void testNoRequestTimeout() {
String reply = template.requestBody("activemq:queue:hello?requestTimeout=0", "Hello World", String.class);
assertEquals("Bye World", reply);
}
@@ -47,9 +47,9 @@ public class JmsNoRequestTimeoutTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello").transform(constant("Bye World"));
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsNotInOnlyIncludeSentJMSMessageIDTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsNotInOnlyIncludeSentJMSMessageIDTest.java
index c77acac..bcbb622 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsNotInOnlyIncludeSentJMSMessageIDTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsNotInOnlyIncludeSentJMSMessageIDTest.java
@@ -63,10 +63,10 @@ public class JmsNotInOnlyIncludeSentJMSMessageIDTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("activemq:queue:foo")
.to("mock:done");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsNotIncludeAllJMSXPropertiesTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsNotIncludeAllJMSXPropertiesTest.java
index c8d7759..f2e870b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsNotIncludeAllJMSXPropertiesTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsNotIncludeAllJMSXPropertiesTest.java
@@ -58,9 +58,9 @@ public class JmsNotIncludeAllJMSXPropertiesTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:in")
.to("mock:result");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionAndInterceptAndOnExceptionTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionAndInterceptAndOnExceptionTest.java
index 873ba36..64f3537 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionAndInterceptAndOnExceptionTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionAndInterceptAndOnExceptionTest.java
@@ -61,10 +61,10 @@ public class JmsOnCompletionAndInterceptAndOnExceptionTest extends CamelTestSupp
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
intercept().to("mock:intercept");
// define a global on completion that is invoked when the exchange is complete
@@ -96,7 +96,7 @@ public class JmsOnCompletionAndInterceptAndOnExceptionTest extends CamelTestSupp
}
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
if ("Kabom".equals(exchange.getIn().getBody())) {
throw new IllegalArgumentException("Kabom");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionTest.java
index b830bfa..66cb361 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionTest.java
@@ -60,10 +60,10 @@ public class JmsOnCompletionTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// START SNIPPET: e1
from("activemq:queue:start")
.onCompletion()
@@ -87,7 +87,7 @@ public class JmsOnCompletionTest extends CamelTestSupport {
}
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
if ("Kabom".equals(exchange.getIn().getBody())) {
throw new IllegalArgumentException("Kabom");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsPollingConsumerTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsPollingConsumerTest.java
index 832afc8..c09a15c 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsPollingConsumerTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsPollingConsumerTest.java
@@ -126,10 +126,10 @@ public class JmsPollingConsumerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to("activemq:queue.start");
from("activemq:queue.foo").to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerDisableReplyToTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerDisableReplyToTest.java
index 94bd53b..b383e3c 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerDisableReplyToTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerDisableReplyToTest.java
@@ -28,7 +28,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class JmsProducerDisableReplyToTest extends CamelTestSupport {
@Test
- public void testProducerDisableReplyTo() throws Exception {
+ public void testProducerDisableReplyTo() {
// must start CamelContext because use route builder is false
context.start();
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java
index f3be600..0d687ed 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java
@@ -250,7 +250,7 @@ public class JmsProducerWithJMSHeaderTest extends CamelTestSupport {
}
@Test
- public void testInOutJMSDestination() throws Exception {
+ public void testInOutJMSDestination() {
Destination queue = new ActiveMQQueue("reply");
String reply = (String) template.requestBodyAndHeader("activemq:queue:bar", "Hello World", JmsConstants.JMS_DESTINATION,
@@ -259,7 +259,7 @@ public class JmsProducerWithJMSHeaderTest extends CamelTestSupport {
}
@Test
- public void testInOutJMSDestinationName() throws Exception {
+ public void testInOutJMSDestinationName() {
String reply = (String) template.requestBodyAndHeader("activemq:queue:bar", "Hello World",
JmsConstants.JMS_DESTINATION_NAME, "reply");
assertEquals("Bye World", reply);
@@ -268,7 +268,7 @@ public class JmsProducerWithJMSHeaderTest extends CamelTestSupport {
@Test
public void testInOnlyRouteJMSDestinationName() throws Exception {
context.addRoutes(new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:a").to("activemq:queue:b");
from("activemq:queue:b").to("mock:result");
}
@@ -298,10 +298,10 @@ public class JmsProducerWithJMSHeaderTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo").to("mock:result");
from("activemq:queue:reply").transform(constant("Bye World"));
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProduerConcurrentTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProduerConcurrentTest.java
index e37e34f..9cfefed 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProduerConcurrentTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProduerConcurrentTest.java
@@ -69,10 +69,10 @@ public class JmsProduerConcurrentTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to("jms:queue:foo");
from("jms:queue:foo").to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProduerConcurrentWithReplyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProduerConcurrentWithReplyTest.java
index 02ba35b..5a276b5 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProduerConcurrentWithReplyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProduerConcurrentWithReplyTest.java
@@ -77,10 +77,10 @@ public class JmsProduerConcurrentWithReplyTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to("jms:queue:foo");
from("jms:queue:foo?concurrentConsumers=5").transform(simple("Bye ${in.body}")).to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsQosRouteTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsQosRouteTest.java
index b020483..8f8a98c 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsQosRouteTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsQosRouteTest.java
@@ -74,9 +74,9 @@ public class JmsQosRouteTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
// Messages should arrive at mock:preserve with their priorities preserved.
from(componentName + ":queue:p1").to(componentName + ":queue:preserve-1?preserveMessageQos=true");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRemoveHeaderTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRemoveHeaderTest.java
index c4b272d..745dc93 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRemoveHeaderTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRemoveHeaderTest.java
@@ -60,10 +60,10 @@ public class JmsRemoveHeaderTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo").removeHeader("foo").to("activemq:queue:bar");
from("activemq:queue:bar").to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyCorrelationTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyCorrelationTest.java
index fa3d1cc..7b50680 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyCorrelationTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyCorrelationTest.java
@@ -242,9 +242,9 @@ public class JmsRequestReplyCorrelationTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("jms:queue:hello").process(exchange -> {
exchange.getIn().setBody(REPLY_BODY);
assertNotNull(exchange.getIn().getHeader("JMSReplyTo"));
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToComponentTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToComponentTest.java
index 4d56ae6..d19fe98 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToComponentTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToComponentTest.java
@@ -34,7 +34,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class JmsRequestReplyExclusiveReplyToComponentTest extends CamelTestSupport {
@Test
- public void testJmsRequestReplyExclusiveFixedReplyTo() throws Exception {
+ public void testJmsRequestReplyExclusiveFixedReplyTo() {
StopWatch watch = new StopWatch();
assertEquals("Hello A", template.requestBody("activemq:queue:foo?replyTo=bar", "A"));
@@ -59,10 +59,10 @@ public class JmsRequestReplyExclusiveReplyToComponentTest extends CamelTestSuppo
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.transform(body().prepend("Hello "));
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToConcurrentTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToConcurrentTest.java
index 1805b91..3dbba75 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToConcurrentTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToConcurrentTest.java
@@ -81,10 +81,10 @@ public class JmsRequestReplyExclusiveReplyToConcurrentTest extends CamelTestSupp
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("activemq:queue:foo?replyTo=bar&replyToType=Exclusive&concurrentConsumers=5&maxConcurrentConsumers=10&maxMessagesPerTask=100")
.to("log:reply")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToRemoveAddRouteTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToRemoveAddRouteTest.java
index 5025bf3..b128f21 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToRemoveAddRouteTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToRemoveAddRouteTest.java
@@ -39,7 +39,7 @@ public class JmsRequestReplyExclusiveReplyToRemoveAddRouteTest extends CamelTest
// add new route using same jms endpoint uri
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start2").routeId("start2")
.to("activemq:queue:foo?replyTo=bar&replyToType=Exclusive")
.to("log:start2");
@@ -62,10 +62,10 @@ public class JmsRequestReplyExclusiveReplyToRemoveAddRouteTest extends CamelTest
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").routeId("start")
.to("activemq:queue:foo?replyTo=bar&replyToType=Exclusive")
.to("log:start");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToTest.java
index 48e55fc..6ef4460 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyExclusiveReplyToTest.java
@@ -38,7 +38,7 @@ import static org.junit.jupiter.api.Assertions.fail;
public class JmsRequestReplyExclusiveReplyToTest extends CamelTestSupport {
@Test
- public void testJmsRequestReplyExclusiveFixedReplyTo() throws Exception {
+ public void testJmsRequestReplyExclusiveFixedReplyTo() {
StopWatch watch = new StopWatch();
assertEquals("Hello A", template.requestBody("activemq:queue:foo?replyTo=bar&replyToType=Exclusive", "A"));
@@ -52,7 +52,7 @@ public class JmsRequestReplyExclusiveReplyToTest extends CamelTestSupport {
}
@Test
- public void testInvalidConfiguration() throws Exception {
+ public void testInvalidConfiguration() {
try {
template.requestBody("activemq:queue:foo?replyTo=bar&replyToType=Temporary", "Hello World");
fail("Should have thrown exception");
@@ -73,10 +73,10 @@ public class JmsRequestReplyExclusiveReplyToTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.transform(body().prepend("Hello "));
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyFixedReplyToInEndpointTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyFixedReplyToInEndpointTest.java
index d87cedb..ad1ecaf 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyFixedReplyToInEndpointTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyFixedReplyToInEndpointTest.java
@@ -31,7 +31,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class JmsRequestReplyFixedReplyToInEndpointTest extends CamelTestSupport {
@Test
- public void testJmsRequestReplyTempReplyTo() throws Exception {
+ public void testJmsRequestReplyTempReplyTo() {
Exchange reply = template.request("activemq:queue:foo", exchange -> exchange.getIn().setBody("World"));
assertEquals("Hello World", reply.getMessage().getBody());
assertTrue(reply.getMessage().hasHeaders(), "Should have headers");
@@ -40,7 +40,7 @@ public class JmsRequestReplyFixedReplyToInEndpointTest extends CamelTestSupport
}
@Test
- public void testJmsRequestReplyFixedReplyToInEndpoint() throws Exception {
+ public void testJmsRequestReplyFixedReplyToInEndpoint() {
Exchange reply = template.request("activemq:queue:foo?replyTo=bar", exchange -> exchange.getIn().setBody("World"));
assertEquals("Hello World", reply.getMessage().getBody());
assertTrue(reply.getMessage().hasHeaders(), "Should have headers");
@@ -48,7 +48,7 @@ public class JmsRequestReplyFixedReplyToInEndpointTest extends CamelTestSupport
}
@Test
- public void testJmsRequestReplyFixedReplyToInEndpointTwoMessages() throws Exception {
+ public void testJmsRequestReplyFixedReplyToInEndpointTwoMessages() {
Exchange reply = template.request("activemq:queue:foo?replyTo=bar", exchange -> exchange.getIn().setBody("World"));
assertEquals("Hello World", reply.getMessage().getBody());
assertTrue(reply.getMessage().hasHeaders(), "Should have headers");
@@ -69,10 +69,10 @@ public class JmsRequestReplyFixedReplyToInEndpointTest extends CamelTestSupport
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.transform(body().prepend("Hello "));
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualReplyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualReplyTest.java
index 0a7f789..7e9faa1 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualReplyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualReplyTest.java
@@ -48,7 +48,7 @@ public class JmsRequestReplyManualReplyTest extends CamelTestSupport {
}
@Consume("activemq:queue:foo")
- public void doSomething(@Header("JMSReplyTo") Destination jmsReplyTo, @Body String body) throws Exception {
+ public void doSomething(@Header("JMSReplyTo") Destination jmsReplyTo, @Body String body) {
assertEquals("Hello World", body);
String endpointName = "activemq:" + jmsReplyTo.toString();
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualWithJMSReplyToTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualWithJMSReplyToTest.java
index fd651e9..39a89e9 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualWithJMSReplyToTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualWithJMSReplyToTest.java
@@ -37,7 +37,7 @@ public class JmsRequestReplyManualWithJMSReplyToTest extends CamelTestSupport {
}
@Consume("activemq:queue:foo")
- public void doSomething(@Header("JMSReplyTo") Destination jmsReplyTo, @Body String body) throws Exception {
+ public void doSomething(@Header("JMSReplyTo") Destination jmsReplyTo, @Body String body) {
assertEquals("Hello World", body);
String endpointName = "activemq:" + jmsReplyTo.toString();
@@ -45,7 +45,7 @@ public class JmsRequestReplyManualWithJMSReplyToTest extends CamelTestSupport {
}
@Test
- public void testManualRequestReply() throws Exception {
+ public void testManualRequestReply() {
context.start();
// send an InOnly but force Camel to pass JMSReplyTo
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyProcessRepliesConcurrentUsingThreadsTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyProcessRepliesConcurrentUsingThreadsTest.java
index d3116f4..e095881 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyProcessRepliesConcurrentUsingThreadsTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyProcessRepliesConcurrentUsingThreadsTest.java
@@ -62,10 +62,10 @@ public class JmsRequestReplyProcessRepliesConcurrentUsingThreadsTest extends Cam
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.log("request - ${body}")
.transform(body().prepend("Bye "));
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyReplyToOverrideTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyReplyToOverrideTest.java
index 31bd198..87d0ae0 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyReplyToOverrideTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyReplyToOverrideTest.java
@@ -45,7 +45,7 @@ public class JmsRequestReplyReplyToOverrideTest extends CamelTestSupport {
}
@Test
- public void testJmsRequestReplyReplyToAndReplyToHeader() throws Exception {
+ public void testJmsRequestReplyReplyToAndReplyToHeader() {
// must start CamelContext because use route builder is false
context.start();
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplySharedReplyToTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplySharedReplyToTest.java
index 4bbfa52..642e1a5 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplySharedReplyToTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplySharedReplyToTest.java
@@ -31,7 +31,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class JmsRequestReplySharedReplyToTest extends CamelTestSupport {
@Test
- public void testJmsRequestReplySharedReplyTo() throws Exception {
+ public void testJmsRequestReplySharedReplyTo() {
StopWatch watch = new StopWatch();
// shared is more slower than exclusive, due it need to use a JMS Message Selector
@@ -56,10 +56,10 @@ public class JmsRequestReplySharedReplyToTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.transform(body().prepend("Hello "));
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTempQueueMultipleConsumersTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTempQueueMultipleConsumersTest.java
index facb500..c6ff06b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTempQueueMultipleConsumersTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTempQueueMultipleConsumersTest.java
@@ -98,10 +98,10 @@ public class JmsRequestReplyTempQueueMultipleConsumersTest extends CamelTestSupp
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to(ExchangePattern.InOut,
"jms:queue:foo?replyToConcurrentConsumers=10&replyToMaxConcurrentConsumers=20&recoveryInterval=10")
.process(exchange -> {
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTemporaryCacheNoneTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTemporaryCacheNoneTest.java
index 723feec..fcef37a 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTemporaryCacheNoneTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTemporaryCacheNoneTest.java
@@ -56,7 +56,7 @@ public class JmsRequestReplyTemporaryCacheNoneTest extends CamelTestSupport {
public void testNotAllowed() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to("activemq:queue:hello?replyToCacheLevelName=CACHE_NONE");
from("activemq:queue:hello").process(exchange -> {
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteDeliveryModePreserveQoSTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteDeliveryModePreserveQoSTest.java
index ffec99e..9134c15 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteDeliveryModePreserveQoSTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteDeliveryModePreserveQoSTest.java
@@ -179,10 +179,10 @@ public class JmsRouteDeliveryModePreserveQoSTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.to("activemq:queue:bar?preserveMessageQos=true");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteRequestReplyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteRequestReplyTest.java
index d8cdbdb..1cc7ec1 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteRequestReplyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteRequestReplyTest.java
@@ -73,12 +73,12 @@ public class JmsRouteRequestReplyTest extends CamelTestSupport {
protected TestInfo testInfo;
private interface ContextBuilder {
- CamelContext buildContext(CamelContext context) throws Exception;
+ CamelContext buildContext(CamelContext context);
}
public static class SingleNodeDeadEndRouteBuilder extends RouteBuilder {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(endpointUriA)
// We are not expect the response here
.setExchangePattern(ExchangePattern.InOnly).process(e -> {
@@ -89,7 +89,7 @@ public class JmsRouteRequestReplyTest extends CamelTestSupport {
public static class SingleNodeRouteBuilder extends RouteBuilder {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(endpointUriA).process(e -> {
String request = e.getIn().getBody(String.class);
e.getMessage().setBody(expectedReply + request.substring(request.indexOf('-')));
@@ -99,7 +99,7 @@ public class JmsRouteRequestReplyTest extends CamelTestSupport {
public static class MultiNodeRouteBuilder extends RouteBuilder {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(endpointUriA).to(endpointUriB);
from(endpointUriB).process(e -> {
String request = e.getIn().getBody(String.class);
@@ -110,7 +110,7 @@ public class JmsRouteRequestReplyTest extends CamelTestSupport {
public static class MultiNodeReplyToRouteBuilder extends RouteBuilder {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(endpointUriA).to(endpointReplyToUriB);
from(endpointUriB).process(e -> {
Message in = e.getIn();
@@ -125,7 +125,7 @@ public class JmsRouteRequestReplyTest extends CamelTestSupport {
public static class MultiNodeDiffCompRouteBuilder extends RouteBuilder {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(endpointUriA).to(endpointUriB1);
from(endpointUriB1).process(e -> {
String request = e.getIn().getBody(String.class);
@@ -136,7 +136,7 @@ public class JmsRouteRequestReplyTest extends CamelTestSupport {
public static class ContextBuilderMessageID implements ContextBuilder {
@Override
- public CamelContext buildContext(CamelContext context) throws Exception {
+ public CamelContext buildContext(CamelContext context) {
ConnectionFactory connectionFactory = CamelJmsTestHelper.createConnectionFactory();
JmsComponent jmsComponent = jmsComponentAutoAcknowledge(connectionFactory);
jmsComponent.getConfiguration().setUseMessageIDAsCorrelationID(true);
@@ -270,7 +270,7 @@ public class JmsRouteRequestReplyTest extends CamelTestSupport {
}
@Override
- public Task call() throws Exception {
+ public Task call() {
for (int i = 0; i < maxCalls; i++) {
int callId = counter.incrementAndGet();
Object reply = "";
@@ -389,7 +389,7 @@ public class JmsRouteRequestReplyTest extends CamelTestSupport {
}
@Test
- public void testUseCorrelationIDTimeout() throws Exception {
+ public void testUseCorrelationIDTimeout() {
Object reply = "";
try {
// set the timeout for the request, specifically. At this point it is too late to re-configure
@@ -402,7 +402,7 @@ public class JmsRouteRequestReplyTest extends CamelTestSupport {
}
@Test
- public void testUseMessageIDAsCorrelationIDTimeout() throws Exception {
+ public void testUseMessageIDAsCorrelationIDTimeout() {
Object reply = "";
try {
// set the timeout for the request, specifically. At this point it is too late to re-configure
@@ -463,7 +463,7 @@ public class JmsRouteRequestReplyTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return routeBuilders.get(getTestMethodName());
}
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteTest.java
index 925a567..e99dd77 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteTest.java
@@ -81,9 +81,9 @@ public class JmsRouteTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(startEndpointUri).to(componentName + ":queue:test.b");
from(componentName + ":queue:test.b").to("mock:result");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteTimeoutCheckerIntervalTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteTimeoutCheckerIntervalTest.java
index 36eb852..ed577a5 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteTimeoutCheckerIntervalTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteTimeoutCheckerIntervalTest.java
@@ -36,7 +36,7 @@ import static org.junit.jupiter.api.Assertions.fail;
public class JmsRouteTimeoutCheckerIntervalTest extends CamelTestSupport {
@Test
- public void testTimeout() throws Exception {
+ public void testTimeout() {
try {
// send a in-out with a timeout for 1 sec
template.requestBody("activemq:queue:slow?requestTimeout=1000", "Hello World");
@@ -47,7 +47,7 @@ public class JmsRouteTimeoutCheckerIntervalTest extends CamelTestSupport {
}
@Test
- public void testNoTimeout() throws Exception {
+ public void testNoTimeout() {
// START SNIPPET: e1
// send a in-out with a timeout for 5 sec
Object out = template.requestBody("activemq:queue:slow?requestTimeout=5000", "Hello World");
@@ -69,9 +69,9 @@ public class JmsRouteTimeoutCheckerIntervalTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:slow").delay(3000).transform(constant("Bye World"));
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteTimeoutTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteTimeoutTest.java
index b3b8cd0..349f70d 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteTimeoutTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteTimeoutTest.java
@@ -36,7 +36,7 @@ import static org.junit.jupiter.api.Assertions.fail;
public class JmsRouteTimeoutTest extends CamelTestSupport {
@Test
- public void testTimeout() throws Exception {
+ public void testTimeout() {
try {
// send a in-out with a timeout for 1 sec
template.requestBody("activemq:queue:slow?requestTimeout=1000", "Hello World");
@@ -47,7 +47,7 @@ public class JmsRouteTimeoutTest extends CamelTestSupport {
}
@Test
- public void testNoTimeout() throws Exception {
+ public void testNoTimeout() {
// START SNIPPET: e1
// send a in-out with a timeout for 5 sec
Object out = template.requestBody("activemq:queue:slow?requestTimeout=5000", "Hello World");
@@ -66,9 +66,9 @@ public class JmsRouteTimeoutTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:slow").delay(3000).transform(constant("Bye World"));
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteToFileTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteToFileTest.java
index 67636ea..2cc4005 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteToFileTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteToFileTest.java
@@ -71,9 +71,9 @@ public class JmsRouteToFileTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
// using mock endpoint here purely for testing. You would normally write this route as
// from("activemq:queue:hello").to("file://target/routetofile");
from("activemq:queue:hello").to("file://target/routetofile").to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteUsingDifferentHeadersTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteUsingDifferentHeadersTest.java
index 5ce2b67..03d0124 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteUsingDifferentHeadersTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteUsingDifferentHeadersTest.java
@@ -70,10 +70,10 @@ public class JmsRouteUsingDifferentHeadersTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteUsingJMSXGroupTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteUsingJMSXGroupTest.java
index eb91e16..60b0e79 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteUsingJMSXGroupTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteUsingJMSXGroupTest.java
@@ -72,10 +72,10 @@ public class JmsRouteUsingJMSXGroupTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to("jms:queue:foo");
from("jms:queue:foo?concurrentConsumers=2").to("log:foo?showHeaders=false").to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithCustomKeyFormatStrategyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithCustomKeyFormatStrategyTest.java
index bbd71ec..24bfa0a 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithCustomKeyFormatStrategyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithCustomKeyFormatStrategyTest.java
@@ -34,10 +34,10 @@ public class JmsRouteWithCustomKeyFormatStrategyTest extends JmsRouteWithDefault
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to(getUri());
from(getUri()).to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithCustomListenerContainerTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithCustomListenerContainerTest.java
index f447ceb..af1b769 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithCustomListenerContainerTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithCustomListenerContainerTest.java
@@ -80,10 +80,10 @@ public class JmsRouteWithCustomListenerContainerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:inbox?messageListenerContainerFactory=#myListenerContainerFactory").to("mock:inbox")
.to(ExchangePattern.InOnly, "activemq:topic:order").bean("orderService",
"handleOrder");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithDefaultKeyFormatStrategyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithDefaultKeyFormatStrategyTest.java
index 4978fbb..eac65df 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithDefaultKeyFormatStrategyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithDefaultKeyFormatStrategyTest.java
@@ -38,7 +38,7 @@ public class JmsRouteWithDefaultKeyFormatStrategyTest extends CamelTestSupport {
}
@Test
- public void testIllegalOption() throws Exception {
+ public void testIllegalOption() {
try {
context.getEndpoint("activemq:queue:bar?jmsHeaderStrategy=xxx");
fail("Should have thrown a ResolveEndpointFailedException");
@@ -97,10 +97,10 @@ public class JmsRouteWithDefaultKeyFormatStrategyTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to(getUri());
from(getUri()).to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithInOnlyAndMultipleAcksTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithInOnlyAndMultipleAcksTest.java
index d7ab7fa..03a8e1e 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithInOnlyAndMultipleAcksTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithInOnlyAndMultipleAcksTest.java
@@ -70,10 +70,10 @@ public class JmsRouteWithInOnlyAndMultipleAcksTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// this route picks up an order request
// send out a one way notification to multiple
// topic subscribers, lets a bean handle
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithInOnlyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithInOnlyTest.java
index ff07436..039e386 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithInOnlyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteWithInOnlyTest.java
@@ -68,10 +68,10 @@ public class JmsRouteWithInOnlyTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:inbox").to("mock:inbox").to(ExchangePattern.InOnly, "activemq:topic:order").bean(
"orderService",
"handleOrder");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRoutingSlipInOutTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRoutingSlipInOutTest.java
index eb048f0..2457cb9 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRoutingSlipInOutTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRoutingSlipInOutTest.java
@@ -58,10 +58,10 @@ public class JmsRoutingSlipInOutTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:start").to("direct:start").to("bean:myBean?method=doResult").to("mock:result");
from("direct:start").to("bean:myBean?method=createSlip").setExchangePattern(ExchangePattern.InOut)
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRoutingSlipTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRoutingSlipTest.java
index b2d15ac..b67603b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRoutingSlipTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRoutingSlipTest.java
@@ -53,9 +53,9 @@ public class JmsRoutingSlipTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello").routingSlip(header("myslip"), "#");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorInTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorInTest.java
index 56b30a6..1150fc6 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorInTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorInTest.java
@@ -56,9 +56,9 @@ public class JmsSelectorInTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
JmsEndpoint endpoint = context.getEndpoint("activemq:queue:foo", JmsEndpoint.class);
endpoint.setSelector("drink IN ('beer', 'wine')");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorOptionTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorOptionTest.java
index e400743..5c4f332 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorOptionTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorOptionTest.java
@@ -58,7 +58,7 @@ public class JmsSelectorOptionTest extends CamelTestSupport {
}
@Test
- public void testConsumerTemplate() throws Exception {
+ public void testConsumerTemplate() {
template.sendBodyAndHeader("activemq:queue:consumer", "Message1", "SIZE_NUMBER", 1505);
template.sendBodyAndHeader("activemq:queue:consumer", "Message3", "SIZE_NUMBER", 1300);
template.sendBodyAndHeader("activemq:queue:consumer", "Message2", "SIZE_NUMBER", 1600);
@@ -90,9 +90,9 @@ public class JmsSelectorOptionTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello?selector=color='blue'").to("mock:a");
from("activemq:queue:hello?selector=color='red'").to("mock:b");
from("activemq:queue:hello?selector=SIZE_NUMBER>1500").to("mock:c");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorTest.java
index a6ace75..c2995e7 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorTest.java
@@ -54,9 +54,9 @@ public class JmsSelectorTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:test.a").to("activemq:test.b");
from("activemq:test.b?selector=cheese='y'").to("mock:result");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSessionTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSessionTest.java
index 655e84b..126836b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSessionTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSessionTest.java
@@ -53,10 +53,10 @@ public class JmsSessionTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.process(exchange -> {
JmsMessage jms = exchange.getIn(JmsMessage.class);
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSetBodyNullErrorHandlerUseOriginalMessageTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSetBodyNullErrorHandlerUseOriginalMessageTest.java
index 56f8eb7..2969310 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSetBodyNullErrorHandlerUseOriginalMessageTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSetBodyNullErrorHandlerUseOriginalMessageTest.java
@@ -51,10 +51,10 @@ public class JmsSetBodyNullErrorHandlerUseOriginalMessageTest extends CamelTestS
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
errorHandler(deadLetterChannel("activemq:queue:dead").useOriginalMessage());
from("activemq:queue:foo")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleHeaderTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleHeaderTest.java
index 061d03a..30cc5bf 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleHeaderTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleHeaderTest.java
@@ -76,10 +76,10 @@ public class JmsSimpleHeaderTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleInOnlyNoMutateTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleInOnlyNoMutateTest.java
index ac07107..4c99bbe 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleInOnlyNoMutateTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleInOnlyNoMutateTest.java
@@ -59,9 +59,9 @@ public class JmsSimpleInOnlyNoMutateTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello").to("log:foo").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestCustomReplyToTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestCustomReplyToTest.java
index eadc654..d98d172 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestCustomReplyToTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestCustomReplyToTest.java
@@ -121,9 +121,9 @@ public class JmsSimpleRequestCustomReplyToTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(componentName + ":queue:hello").process(exchange -> {
assertEquals("Hello World", exchange.getIn().getBody());
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestLateReplyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestLateReplyTest.java
index 28a6f863..b986344 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestLateReplyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestLateReplyTest.java
@@ -104,9 +104,9 @@ public class JmsSimpleRequestLateReplyTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(getQueueEndpointName())
.process(exchange -> {
// set the MEP to InOnly as we are not able to send a reply right now but will do it later
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReply2Test.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReply2Test.java
index 7f40fff..57c1fb3 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReply2Test.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReply2Test.java
@@ -66,9 +66,9 @@ public class JmsSimpleRequestReply2Test extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to(ExchangePattern.InOut, "activemq:queue:foo")
.to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReplyFixedReplyQueueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReplyFixedReplyQueueTest.java
index 29ecd73..c8c6528 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReplyFixedReplyQueueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReplyFixedReplyQueueTest.java
@@ -66,9 +66,9 @@ public class JmsSimpleRequestReplyFixedReplyQueueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to(ExchangePattern.InOut, "activemq:queue:foo?replyTo=queue:bar")
.to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReplyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReplyTest.java
index d82f432..2aa0a6a 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReplyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReplyTest.java
@@ -77,9 +77,9 @@ public class JmsSimpleRequestReplyTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello").process(exchange -> {
exchange.getIn().setBody("Bye World");
assertNotNull(exchange.getIn().getHeader("JMSReplyTo"));
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSplitterParallelChainedTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSplitterParallelChainedTest.java
index 239d5c5..9b84d27 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSplitterParallelChainedTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSplitterParallelChainedTest.java
@@ -64,10 +64,10 @@ public class JmsSplitterParallelChainedTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.split(body().tokenize(",")).parallelProcessing()
.to("log:before")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSplitterParallelTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSplitterParallelTest.java
index 88309a9..6f56ea9 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSplitterParallelTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSplitterParallelTest.java
@@ -54,10 +54,10 @@ public class JmsSplitterParallelTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.split(body().tokenize(",")).parallelProcessing()
.to("log:before")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsStreamMessageTypeTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsStreamMessageTypeTest.java
index 7426780..212ef6c 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsStreamMessageTypeTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsStreamMessageTypeTest.java
@@ -97,10 +97,10 @@ public class JmsStreamMessageTypeTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("file:target/stream/in").to("jms:queue:foo");
from("jms:queue:foo").to("file:target/stream/out").to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSuspendResumeTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSuspendResumeTest.java
index ebc2857..3a27af0 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSuspendResumeTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSuspendResumeTest.java
@@ -71,9 +71,9 @@ public class JmsSuspendResumeTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo").routeId("foo").to("mock:foo");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTestConnectionOnStartupTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTestConnectionOnStartupTest.java
index d5d63a5..4e5dd73 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTestConnectionOnStartupTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTestConnectionOnStartupTest.java
@@ -37,7 +37,7 @@ public class JmsTestConnectionOnStartupTest extends CamelTestSupport {
public void testConnectionOnStartupConsumerTest() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo?testConnectionOnStartup=true").to("mock:foo");
}
});
@@ -56,7 +56,7 @@ public class JmsTestConnectionOnStartupTest extends CamelTestSupport {
public void testConnectionOnStartupProducerTest() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to("activemq:queue:foo?testConnectionOnStartup=true");
}
});
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingInflightRoutePolicyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingInflightRoutePolicyTest.java
index c5bbfe8..93c0898 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingInflightRoutePolicyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsThrottlingInflightRoutePolicyTest.java
@@ -44,10 +44,10 @@ public class JmsThrottlingInflightRoutePolicyTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
ThrottlingInflightRoutePolicy policy = new ThrottlingInflightRoutePolicy();
policy.setMaxInflightExchanges(10);
policy.setResumePercentOfMax(50);
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTest.java
index fb75eed..d2d972b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTest.java
@@ -29,7 +29,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class JmsToDSendDynamicTest extends CamelTestSupport {
@Test
- public void testToD() throws Exception {
+ public void testToD() {
template.sendBodyAndHeader("direct:start", "Hello bar", "where", "bar");
template.sendBodyAndHeader("direct:start", "Hello beer", "where", "beer");
@@ -55,10 +55,10 @@ public class JmsToDSendDynamicTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// route message dynamic using toD
from("direct:start").toD("activemq:queue:${header.where}");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTwoDisabledTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTwoDisabledTest.java
index b125115..3081d5d 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTwoDisabledTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTwoDisabledTest.java
@@ -29,7 +29,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class JmsToDSendDynamicTwoDisabledTest extends CamelTestSupport {
@Test
- public void testToD() throws Exception {
+ public void testToD() {
template.sendBodyAndHeader("direct:start", "Hello bar", "where", "bar");
template.sendBodyAndHeader("direct:start", "Hello beer", "where", "beer");
template.sendBodyAndHeader("direct:start", "Hello gin", "where", "gin");
@@ -53,10 +53,10 @@ public class JmsToDSendDynamicTwoDisabledTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// route message dynamic using toD but turn off send dynamic aware
from("direct:start").toD().allowOptimisedComponents(false).uri("activemq:queue:${header.where}");
from("direct:start2").toD().allowOptimisedComponents(false).uri("activemq:queue:${header.where2}");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTwoTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTwoTest.java
index 83f92ce..bc0bf0c 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTwoTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTwoTest.java
@@ -29,7 +29,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class JmsToDSendDynamicTwoTest extends CamelTestSupport {
@Test
- public void testToD() throws Exception {
+ public void testToD() {
template.sendBodyAndHeader("direct:start", "Hello bar", "where", "bar");
template.sendBodyAndHeader("direct:start", "Hello beer", "where", "beer");
template.sendBodyAndHeader("direct:start", "Hello gin", "where", "gin");
@@ -53,10 +53,10 @@ public class JmsToDSendDynamicTwoTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// route message dynamic using toD
from("direct:start").toD("activemq:queue:${header.where}");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDTest.java
index 15dcf82..0eaca34 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDTest.java
@@ -49,10 +49,10 @@ public class JmsToDTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// route message dynamic using toD
from("direct:start").toD("activemq:queue:${header.where}");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToTest.java
index 6b26aeb..af4c422 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToTest.java
@@ -50,10 +50,10 @@ public class JmsToTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// wrongly using to instead of toD
from("direct:start").to("activemq:queue:${header.where}");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransactedRouteTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransactedRouteTest.java
index bab755f..aa30ae0 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransactedRouteTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransactedRouteTest.java
@@ -54,9 +54,9 @@ public class JmsTransactedRouteTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:test.a").to("activemq:test.b");
from("activemq:test.b").to("log:result", "mock:result");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExceptionTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExceptionTest.java
index e34e993..62a4b37 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExceptionTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExceptionTest.java
@@ -46,7 +46,7 @@ public class JmsTransferExceptionTest extends CamelTestSupport {
}
@Test
- public void testOk() throws Exception {
+ public void testOk() {
Object out = template.requestBody(getUri(), "Hello World");
assertEquals("Bye World", out);
@@ -80,10 +80,10 @@ public class JmsTransferExceptionTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
errorHandler(defaultErrorHandler().maximumRedeliveries(2));
from(getUri())
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExchangeFromSplitterTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExchangeFromSplitterTest.java
index 402916e..12c3d46 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExchangeFromSplitterTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExchangeFromSplitterTest.java
@@ -58,10 +58,10 @@ public class JmsTransferExchangeFromSplitterTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.split(body().tokenize(","))
.to(getUri());
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExchangeTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExchangeTest.java
index d5e4963..fb4ff351 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExchangeTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExchangeTest.java
@@ -83,10 +83,10 @@ public class JmsTransferExchangeTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to(getUri());
from(getUri()).to("mock:result");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsUseOriginalBodyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsUseOriginalBodyTest.java
index e8acc4b..c21166b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsUseOriginalBodyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsUseOriginalBodyTest.java
@@ -55,10 +55,10 @@ public class JmsUseOriginalBodyTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:a")
.onException(IllegalArgumentException.class)
.handled(true)
@@ -88,7 +88,7 @@ public class JmsUseOriginalBodyTest extends CamelTestSupport {
}
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
assertEquals("Hello World", exchange.getIn().getBody(String.class));
throw new IllegalArgumentException("Forced");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsXMLRouteTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsXMLRouteTest.java
index 02a3b03..9aacbb2 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsXMLRouteTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsXMLRouteTest.java
@@ -196,10 +196,10 @@ public class JmsXMLRouteTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// enable stream caching
context.setStreamCaching(true);
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsXPathHeaderTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsXPathHeaderTest.java
index 495f809..7cf09bc 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsXPathHeaderTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsXPathHeaderTest.java
@@ -71,10 +71,10 @@ public class JmsXPathHeaderTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:in")
.choice()
.when().xpath("$foo = 'true'")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ManagedJmsEndpointTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ManagedJmsEndpointTest.java
index 215285b..4519187 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ManagedJmsEndpointTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ManagedJmsEndpointTest.java
@@ -43,7 +43,7 @@ public class ManagedJmsEndpointTest extends CamelTestSupport {
}
@Override
- protected CamelContext createCamelContext() throws Exception {
+ protected CamelContext createCamelContext() {
CamelContext context = new DefaultCamelContext();
ConnectionFactory connectionFactory = CamelJmsTestHelper.createPersistentConnectionFactory();
@@ -99,10 +99,10 @@ public class ManagedJmsEndpointTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:start").routeId("foo").to("log:foo").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ManagedJmsEndpointTopicTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ManagedJmsEndpointTopicTest.java
index c9fecbe..a6deb35 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ManagedJmsEndpointTopicTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ManagedJmsEndpointTopicTest.java
@@ -43,7 +43,7 @@ public class ManagedJmsEndpointTopicTest extends CamelTestSupport {
}
@Override
- protected CamelContext createCamelContext() throws Exception {
+ protected CamelContext createCamelContext() {
CamelContext context = new DefaultCamelContext();
ConnectionFactory connectionFactory = CamelJmsTestHelper.createConnectionFactory();
@@ -82,10 +82,10 @@ public class ManagedJmsEndpointTopicTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:topic:start").routeId("foo").to("log:foo").to("mock:result");
from("activemq:topic:start").routeId("bar").to("log:bar").to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ManagedJmsSelectorTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ManagedJmsSelectorTest.java
index 30e9780..b9bfe83 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ManagedJmsSelectorTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ManagedJmsSelectorTest.java
@@ -44,7 +44,7 @@ public class ManagedJmsSelectorTest extends CamelTestSupport {
}
@Override
- protected CamelContext createCamelContext() throws Exception {
+ protected CamelContext createCamelContext() {
CamelContext context = new DefaultCamelContext();
ConnectionFactory connectionFactory = CamelJmsTestHelper.createConnectionFactory();
@@ -99,10 +99,10 @@ public class ManagedJmsSelectorTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:start?cacheLevelName=CACHE_NONE&selector=brand='beer'").routeId("foo").to("log:foo")
.to("mock:result");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/MapJmsMessageTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/MapJmsMessageTest.java
index f64424d..58cebe9 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/MapJmsMessageTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/MapJmsMessageTest.java
@@ -63,9 +63,9 @@ public class MapJmsMessageTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello?mapJmsMessage=false").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/PayloadByteArrayJmsTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/PayloadByteArrayJmsTest.java
index 25aed05..d22bffa 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/PayloadByteArrayJmsTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/PayloadByteArrayJmsTest.java
@@ -92,9 +92,9 @@ public class PayloadByteArrayJmsTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ProduceMessageConverterTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ProduceMessageConverterTest.java
index 26bfb8a..7f489d4 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ProduceMessageConverterTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ProduceMessageConverterTest.java
@@ -59,9 +59,9 @@ public class ProduceMessageConverterTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ReplyToDestinationSelectorNameTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ReplyToDestinationSelectorNameTest.java
index ec47b4b..dfd1ca3 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/ReplyToDestinationSelectorNameTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/ReplyToDestinationSelectorNameTest.java
@@ -57,10 +57,10 @@ public class ReplyToDestinationSelectorNameTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("activemq:queue:foo?replyTo=queue:bar&replyToDestinationSelectorName=replyId")
.to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/RequestReplyCorrelatedWithCustomHeaderTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/RequestReplyCorrelatedWithCustomHeaderTest.java
index 22759fd..87d0f23 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/RequestReplyCorrelatedWithCustomHeaderTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/RequestReplyCorrelatedWithCustomHeaderTest.java
@@ -39,15 +39,14 @@ public class RequestReplyCorrelatedWithCustomHeaderTest extends CamelTestSupport
public static void processRequest(
@Body final String body,
@Header("CustomCorrelation") final String customCorrelation,
- @Header("JMSCorrelationId") final String jmsCorrelationId, final Exchange exchange)
- throws Exception {
+ @Header("JMSCorrelationId") final String jmsCorrelationId, final Exchange exchange) {
assertNotNull(customCorrelation);
assertNull(jmsCorrelationId);
exchange.getIn().setBody("Hi, " + body + ", " + customCorrelation);
}
@Test
- public void shouldCorrelateRepliesWithCustomCorrelationProperty() throws Exception {
+ public void shouldCorrelateRepliesWithCustomCorrelationProperty() {
final String reply = template.requestBody("activemq:queue:request",
"Bobby", String.class);
@@ -55,7 +54,7 @@ public class RequestReplyCorrelatedWithCustomHeaderTest extends CamelTestSupport
}
@Test
- public void shouldCorrelateRepliesWithCustomCorrelationPropertyAndValue() throws Exception {
+ public void shouldCorrelateRepliesWithCustomCorrelationPropertyAndValue() {
final String reply = template.requestBodyAndHeader(
"activemq:queue:request", "Bobby", "CustomCorrelation",
"custom-id", String.class);
@@ -78,10 +77,10 @@ public class RequestReplyCorrelatedWithCustomHeaderTest extends CamelTestSupport
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:request").bean(RequestReplyCorrelatedWithCustomHeaderTest.class, "processRequest");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/SimpleJmsRequestReplyExclusiveReplyToTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/SimpleJmsRequestReplyExclusiveReplyToTest.java
index 689a208..0b535d0 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/SimpleJmsRequestReplyExclusiveReplyToTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/SimpleJmsRequestReplyExclusiveReplyToTest.java
@@ -32,7 +32,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class SimpleJmsRequestReplyExclusiveReplyToTest extends CamelTestSupport {
@Test
- public void testJmsRequestReplyExclusiveFixedReplyTo() throws Exception {
+ public void testJmsRequestReplyExclusiveFixedReplyTo() {
assertEquals("Hello A",
template.requestBody("activemq:queue:foo?replyTo=bar&replyToType=Exclusive&replyToConsumerType=Simple", "A"));
assertEquals("Hello B",
@@ -54,10 +54,10 @@ public class SimpleJmsRequestReplyExclusiveReplyToTest extends CamelTestSupport
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.transform(body().prepend("Hello "));
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/SimpleJmsRequestReplySharedReplyToTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/SimpleJmsRequestReplySharedReplyToTest.java
index 56d4bdf..994cd70 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/SimpleJmsRequestReplySharedReplyToTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/SimpleJmsRequestReplySharedReplyToTest.java
@@ -29,7 +29,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class SimpleJmsRequestReplySharedReplyToTest extends CamelTestSupport {
@Test
- public void testJmsRequestReplySharedReplyTo() throws Exception {
+ public void testJmsRequestReplySharedReplyTo() {
assertEquals("Hello A", template.requestBody(
"activemq:queue:foo?replyTo=bar&replyToType=Shared&replyToDestinationSelectorName=mySelector&replyToConsumerType=Simple",
"A"));
@@ -56,10 +56,10 @@ public class SimpleJmsRequestReplySharedReplyToTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.transform(body().prepend("Hello "));
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/SimpleJmsRequestReplyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/SimpleJmsRequestReplyTest.java
index b77aca4..c8032e6 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/SimpleJmsRequestReplyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/SimpleJmsRequestReplyTest.java
@@ -29,7 +29,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class SimpleJmsRequestReplyTest extends CamelTestSupport {
@Test
- public void testJmsRequestReply() throws Exception {
+ public void testJmsRequestReply() {
assertEquals("Hello A", template.requestBody("activemq:queue:foo?replyToConsumerType=Simple", "A"));
assertEquals("Hello B", template.requestBody("activemq:queue:foo?replyToConsumerType=Simple", "B"));
assertEquals("Hello C", template.requestBody("activemq:queue:foo?replyToConsumerType=Simple", "C"));
@@ -46,10 +46,10 @@ public class SimpleJmsRequestReplyTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.transform(body().prepend("Hello "));
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java
index 2b70b2c..6e627ed 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java
@@ -101,10 +101,10 @@ public class TwoConsumerOnSameQueueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo").routeId("a")
.to("log:a", "mock:a");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameTopicTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameTopicTest.java
index e5a63a0..387a079 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameTopicTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameTopicTest.java
@@ -118,10 +118,10 @@ public class TwoConsumerOnSameTopicTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:topic:foo").routeId("a")
.to("log:a", "mock:a");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/activemq/ActiveMQConsumeWildcardQueuesTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/activemq/ActiveMQConsumeWildcardQueuesTest.java
index 425c08a..9a3b055 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/activemq/ActiveMQConsumeWildcardQueuesTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/activemq/ActiveMQConsumeWildcardQueuesTest.java
@@ -56,9 +56,9 @@ public class ActiveMQConsumeWildcardQueuesTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
// use wildcard to consume from all sports
from("activemq:queue:sport.>")
.to("log:received?showHeaders=true")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerFalseTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerFalseTest.java
index dc37ab0..5a6805c 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerFalseTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerFalseTest.java
@@ -55,10 +55,10 @@ public class AsyncConsumerFalseTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// disable async in only mode on the consumer
from("activemq:queue:start?asyncConsumer=false")
.choice()
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerInOutTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerInOutTest.java
index 3c9eb32..dea8585 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerInOutTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerInOutTest.java
@@ -59,10 +59,10 @@ public class AsyncConsumerInOutTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// enable async in only mode on the consumer
from("activemq:queue:start?asyncConsumer=true")
.choice()
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerInOutTwoTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerInOutTwoTest.java
index dd80382..5d83738 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerInOutTwoTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerInOutTwoTest.java
@@ -33,7 +33,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class AsyncConsumerInOutTwoTest extends CamelTestSupport {
@Test
- public void testAsyncJmsConsumer() throws Exception {
+ public void testAsyncJmsConsumer() {
String out = template.requestBody("activemq:queue:start?replyTo=bar", "Hello World", String.class);
assertEquals("Bye World", out);
}
@@ -51,10 +51,10 @@ public class AsyncConsumerInOutTwoTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// enable async in only mode on the consumer
from("activemq:queue:start?asyncConsumer=true")
.to("async:camel?delay=2000")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerTest.java
index 7f84d28..918663a 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncConsumerTest.java
@@ -58,10 +58,10 @@ public class AsyncConsumerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// enable async in only mode on the consumer
from("activemq:queue:start?asyncConsumer=true")
.choice()
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncJmsInOutTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncJmsInOutTest.java
index a3d068e..dadcaac 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncJmsInOutTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncJmsInOutTest.java
@@ -67,10 +67,10 @@ public class AsyncJmsInOutTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// in a fully sync mode it would take at least 5 + 5 sec to process the 100 messages
// (there are delays in both routes)
// however due async routing, we can leverage the fact to let threads non blocked
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncJmsProducerTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncJmsProducerTest.java
index d211082..59bd9c9 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncJmsProducerTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/AsyncJmsProducerTest.java
@@ -58,10 +58,10 @@ public class AsyncJmsProducerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("mock:before")
.to("log:before")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/MyAsyncEndpoint.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/MyAsyncEndpoint.java
index 2429a1a..9088ea4 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/MyAsyncEndpoint.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/MyAsyncEndpoint.java
@@ -38,7 +38,7 @@ public class MyAsyncEndpoint extends DefaultEndpoint {
}
@Override
- public Producer createProducer() throws Exception {
+ public Producer createProducer() {
Producer answer = new MyAsyncProducer(this);
if (isSynchronous()) {
// force it to be synchronously
@@ -49,7 +49,7 @@ public class MyAsyncEndpoint extends DefaultEndpoint {
}
@Override
- public Consumer createConsumer(Processor processor) throws Exception {
+ public Consumer createConsumer(Processor processor) {
throw new UnsupportedOperationException("Consumer not supported");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/discovery/JmsDiscoveryTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/discovery/JmsDiscoveryTest.java
index d7bd046..ce38d98 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/discovery/JmsDiscoveryTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/discovery/JmsDiscoveryTest.java
@@ -62,15 +62,15 @@ public class JmsDiscoveryTest extends CamelTestSupport {
}
@Override
- protected void bindToRegistry(Registry registry) throws Exception {
+ protected void bindToRegistry(Registry registry) {
registry.bind("service1", new MyService("service1"));
registry.bind("registry", myRegistry);
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
// lets setup the heartbeats
from("timer:heartbeats?delay=100")
.to("bean:service1?method=status")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ActiveMQPropagateHeadersTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ActiveMQPropagateHeadersTest.java
index 8d5387d..76597c2 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ActiveMQPropagateHeadersTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ActiveMQPropagateHeadersTest.java
@@ -76,9 +76,9 @@ public class ActiveMQPropagateHeadersTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
// must set option to preserve message QoS as we send an InOnly but put a JMSReplyTo
// that does not work well on the consumer side, as it would assume it should send a reply
// but we do not expect a reply as we are InOnly.
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ActiveMQPropagateSerializableHeadersTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ActiveMQPropagateSerializableHeadersTest.java
index 1921d04..4edc5a0 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ActiveMQPropagateSerializableHeadersTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ActiveMQPropagateSerializableHeadersTest.java
@@ -102,9 +102,9 @@ public class ActiveMQPropagateSerializableHeadersTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:test.a").process(exchange -> {
// set the JMS headers
Message in = exchange.getIn();
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/AdviceWithIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/AdviceWithIssueTest.java
index 4e62ca7..f5f7b96 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/AdviceWithIssueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/AdviceWithIssueTest.java
@@ -66,10 +66,10 @@ public class AdviceWithIssueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").routeId("starter")
.to(pub).to("mock:result");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/BruceHandlingBeanExceptionTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/BruceHandlingBeanExceptionTest.java
index cbe472c..e6df809 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/BruceHandlingBeanExceptionTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/BruceHandlingBeanExceptionTest.java
@@ -34,13 +34,13 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class BruceHandlingBeanExceptionTest extends CamelTestSupport {
@Test
- public void testSendOK() throws Exception {
+ public void testSendOK() {
Object out = template.requestBody("activemq:queue:ok", "Hello World");
assertEquals("Bye World", out);
}
@Test
- public void testSendError() throws Exception {
+ public void testSendError() {
Object out = template.requestBody("activemq:queue:error", "Hello World");
IllegalArgumentException e = assertIsInstanceOf(IllegalArgumentException.class, out);
assertEquals("Forced exception by unit test", e.getMessage());
@@ -57,9 +57,9 @@ public class BruceHandlingBeanExceptionTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:ok").transform(constant("Bye World"));
from("activemq:queue:error?transferException=true").bean(MyExceptionBean.class);
@@ -68,7 +68,7 @@ public class BruceHandlingBeanExceptionTest extends CamelTestSupport {
}
public static class MyExceptionBean {
- public String doSomething(String input) throws Exception {
+ public String doSomething(String input) {
throw new IllegalArgumentException("Forced exception by unit test");
}
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/DynamicRoutersWithJMSMessageLostHeadersIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/DynamicRoutersWithJMSMessageLostHeadersIssueTest.java
index 81bad15..9b44e05 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/DynamicRoutersWithJMSMessageLostHeadersIssueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/DynamicRoutersWithJMSMessageLostHeadersIssueTest.java
@@ -54,10 +54,10 @@ public class DynamicRoutersWithJMSMessageLostHeadersIssueTest extends CamelTestS
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue1")
.setHeader("HEADER1", constant("header1"))
.dynamicRouter(method(DynamicRouter.class, "dynamicRoute"))
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsAnotherCustomJMSReplyToTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsAnotherCustomJMSReplyToTest.java
index 39a0143..20b6bac 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsAnotherCustomJMSReplyToTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsAnotherCustomJMSReplyToTest.java
@@ -63,10 +63,10 @@ public class JmsAnotherCustomJMSReplyToTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello")
.setExchangePattern(ExchangePattern.InOnly)
.process(exchange -> {
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsBeanMethodHeaderTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsBeanMethodHeaderTest.java
index ad03001..c23a2b7 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsBeanMethodHeaderTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsBeanMethodHeaderTest.java
@@ -106,9 +106,9 @@ public class JmsBeanMethodHeaderTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:in").to("activemq:test.a");
from("activemq:test.a").to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsBlockedAsyncRoutingEngineTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsBlockedAsyncRoutingEngineTest.java
index c92a539..c992f65 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsBlockedAsyncRoutingEngineTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsBlockedAsyncRoutingEngineTest.java
@@ -119,9 +119,9 @@ public class JmsBlockedAsyncRoutingEngineTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:test?concurrentConsumers=5&useMessageIDAsCorrelationID=true&transacted=true")
.filter().simple("${in.body} == 'beSlow'")
.delay(constant(2000))
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsChainedEndpointDelayTimeoutTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsChainedEndpointDelayTimeoutTest.java
index ac9b334..92168a2 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsChainedEndpointDelayTimeoutTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsChainedEndpointDelayTimeoutTest.java
@@ -59,10 +59,10 @@ public class JmsChainedEndpointDelayTimeoutTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
onException(ExchangeTimedOutException.class)
.handled(true)
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsConcurrentConsumerInOnlyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsConcurrentConsumerInOnlyTest.java
index 59b32a2..b23c81d 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsConcurrentConsumerInOnlyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsConcurrentConsumerInOnlyTest.java
@@ -59,9 +59,9 @@ public class JmsConcurrentConsumerInOnlyTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:foo?concurrentConsumers=2&maxConcurrentConsumers=5").routeId("foo").noAutoStartup()
.log("${threadName} got ${body}")
.delay(simple("${random(0,10)}"))
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsConcurrentConsumersTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsConcurrentConsumersTest.java
index 041e1d9..2845ce6 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsConcurrentConsumersTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsConcurrentConsumersTest.java
@@ -78,9 +78,9 @@ public class JmsConcurrentConsumersTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:a?concurrentConsumers=3").to("activemq:b?concurrentConsumers=3");
from("activemq:b?concurrentConsumers=3").process(exchange -> {
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsCustomJMSReplyToIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsCustomJMSReplyToIssueTest.java
index 6d3786b..fcc32a6 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsCustomJMSReplyToIssueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsCustomJMSReplyToIssueTest.java
@@ -72,9 +72,9 @@ public class JmsCustomJMSReplyToIssueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
// must preserve QoS so Camel will send JMSReplyTo even if message is inOnly
from("direct:start").process(exchange -> {
exchange.getMessage().setBody("Hello World");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsDirectStartupOrderIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsDirectStartupOrderIssueTest.java
index 90d8fb0..0ed3dac 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsDirectStartupOrderIssueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsDirectStartupOrderIssueTest.java
@@ -70,9 +70,9 @@ public class JmsDirectStartupOrderIssueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo").routeId("amq").startupOrder(100).autoStartup(false)
.to("direct:foo");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsFilenameHeaderTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsFilenameHeaderTest.java
index 95933da..ad76a8d 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsFilenameHeaderTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsFilenameHeaderTest.java
@@ -61,9 +61,9 @@ public class JmsFilenameHeaderTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:in").to("activemq:test.a");
from("activemq:test.a").to("direct:save");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsGetHeaderKeyFormatIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsGetHeaderKeyFormatIssueTest.java
index 8221b90..08104f3 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsGetHeaderKeyFormatIssueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsGetHeaderKeyFormatIssueTest.java
@@ -55,10 +55,10 @@ public class JmsGetHeaderKeyFormatIssueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(uri)
.process(exchange -> {
Map<String, Object> headers = exchange.getIn().getHeaders();
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsGetHeaderKeyFormatIssueWithContentTypeHeaderTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsGetHeaderKeyFormatIssueWithContentTypeHeaderTest.java
index 55aba9b..cff92da 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsGetHeaderKeyFormatIssueWithContentTypeHeaderTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsGetHeaderKeyFormatIssueWithContentTypeHeaderTest.java
@@ -65,10 +65,10 @@ public class JmsGetHeaderKeyFormatIssueWithContentTypeHeaderTest extends CamelTe
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(uri)
.process(exchange -> {
assertEquals("text/plain", exchange.getIn().getHeader("Content-Type"));
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsHeaderAsObjectTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsHeaderAsObjectTest.java
index dd2dfe4..7dd7b8a 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsHeaderAsObjectTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsHeaderAsObjectTest.java
@@ -76,9 +76,9 @@ public class JmsHeaderAsObjectTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:in").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOnlyIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOnlyIssueTest.java
index 9fe6645..961b3e9 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOnlyIssueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOnlyIssueTest.java
@@ -96,9 +96,9 @@ public class JmsInOnlyIssueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:in").process(exchange -> exchange.getIn().setBody("Bye World")).to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOnlyParameterTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOnlyParameterTest.java
index a8d84b1..c705f42 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOnlyParameterTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOnlyParameterTest.java
@@ -71,9 +71,9 @@ public class JmsInOnlyParameterTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("activemq:queue:in?exchangePattern=InOnly")
.transform().constant("Bye World")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutExclusiveTopicRecipientListTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutExclusiveTopicRecipientListTest.java
index 91af7d9..eca892d 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutExclusiveTopicRecipientListTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutExclusiveTopicRecipientListTest.java
@@ -49,9 +49,9 @@ public class JmsInOutExclusiveTopicRecipientListTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.recipientList().header("whereTo")
.to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutExclusiveTopicTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutExclusiveTopicTest.java
index ef3b73f..1f009f9a 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutExclusiveTopicTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutExclusiveTopicTest.java
@@ -48,9 +48,9 @@ public class JmsInOutExclusiveTopicTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("activemq:topic:news?replyToType=Exclusive&replyTo=queue:back")
.to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutIssueTest.java
index 721b977..d4cb8e8 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutIssueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutIssueTest.java
@@ -34,13 +34,13 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class JmsInOutIssueTest extends CamelTestSupport {
@Test
- public void testInOutWithRequestBody() throws Exception {
+ public void testInOutWithRequestBody() {
String reply = template.requestBody("activemq:queue:in", "Hello World", String.class);
assertEquals("Bye World", reply);
}
@Test
- public void testInOutTwoTimes() throws Exception {
+ public void testInOutTwoTimes() {
String reply = template.requestBody("activemq:queue:in", "Hello World", String.class);
assertEquals("Bye World", reply);
@@ -55,7 +55,7 @@ public class JmsInOutIssueTest extends CamelTestSupport {
}
@Test
- public void testInOutWithSendExchange() throws Exception {
+ public void testInOutWithSendExchange() {
Exchange out = template.send("activemq:queue:in", ExchangePattern.InOut,
exchange -> exchange.getIn().setBody("Hello World"));
@@ -81,9 +81,9 @@ public class JmsInOutIssueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:in").process(exchange -> exchange.getMessage().setBody("Bye World"));
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutParallelTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutParallelTest.java
index 7e8f32f..3834459 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutParallelTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutParallelTest.java
@@ -50,9 +50,9 @@ public class JmsInOutParallelTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:test")
.setBody(constant("1,2,3,4,5"))
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutPersistentReplyQueueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutPersistentReplyQueueTest.java
index 5f38afe..bdaaac5 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutPersistentReplyQueueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutPersistentReplyQueueTest.java
@@ -50,9 +50,9 @@ public class JmsInOutPersistentReplyQueueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("seda:start")
.log("Sending ${body}")
.to(ExchangePattern.InOut, "activemq:queue:foo?replyTo=myReplies")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutPipelineWithBeanTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutPipelineWithBeanTest.java
index 7b20d40..4e6d5e9 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutPipelineWithBeanTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutPipelineWithBeanTest.java
@@ -38,19 +38,19 @@ public class JmsInOutPipelineWithBeanTest extends CamelTestSupport {
private MyDummyBean bean = new MyDummyBean();
@Test
- public void testA() throws Exception {
+ public void testA() {
Object response = template.requestBody("activemq:testA", "Hello World");
assertEquals("Hello World,From Bean,From A,From B", response, "Reply");
}
@Test
- public void testB() throws Exception {
+ public void testB() {
Object response = template.requestBody("activemq:testB", "Hello World");
assertEquals("Hello World,From A,From Bean,From B", response, "Reply");
}
@Test
- public void testC() throws Exception {
+ public void testC() {
Object response = template.requestBody("activemq:testC", "Hello World");
assertEquals("Hello World,From A,From B,From Bean", response, "Reply");
}
@@ -64,9 +64,9 @@ public class JmsInOutPipelineWithBeanTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:testA").to("bean:dummyBean").to("activemq:a").to("activemq:b");
from("activemq:testB").to("activemq:a").to("bean:dummyBean").to("activemq:b");
from("activemq:testC").to("activemq:a").to("activemq:b").to("bean:dummyBean");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutRepeatedInvocationsTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutRepeatedInvocationsTest.java
index f9421f7..94dd423 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutRepeatedInvocationsTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutRepeatedInvocationsTest.java
@@ -50,9 +50,9 @@ public class JmsInOutRepeatedInvocationsTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:test")
.to(ExchangePattern.InOut, "activemq:queue:test1?requestTimeout=200")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutRoutingSlipTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutRoutingSlipTest.java
index d67791f..9464f5d 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutRoutingSlipTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutRoutingSlipTest.java
@@ -49,10 +49,10 @@ public class JmsInOutRoutingSlipTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:start")
.setExchangePattern(ExchangePattern.InOut)
.routingSlip(header("slip"))
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutUseMessageIDasCorrelationIDTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutUseMessageIDasCorrelationIDTest.java
index f6fbc5e..4d547f4 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutUseMessageIDasCorrelationIDTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutUseMessageIDasCorrelationIDTest.java
@@ -31,13 +31,13 @@ import static org.junit.jupiter.api.Assertions.assertNull;
public class JmsInOutUseMessageIDasCorrelationIDTest extends CamelTestSupport {
@Test
- public void testInOutWithMsgIdAsCorrId() throws Exception {
+ public void testInOutWithMsgIdAsCorrId() {
String reply = template.requestBody("activemq:queue:in?useMessageIDAsCorrelationID=true", "Hello World", String.class);
assertEquals("Bye World", reply);
}
@Test
- public void testInOutFixedReplyToAndWithMsgIdAsCorrId() throws Exception {
+ public void testInOutFixedReplyToAndWithMsgIdAsCorrId() {
String reply = template.requestBody("activemq:queue:in?replyTo=bar&useMessageIDAsCorrelationID=true", "Hello World",
String.class);
assertEquals("Bye World", reply);
@@ -52,9 +52,9 @@ public class JmsInOutUseMessageIDasCorrelationIDTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:in?useMessageIDAsCorrelationID=true").process(exchange -> {
String id = exchange.getIn().getHeader("JMSCorrelationID", String.class);
assertNull(id, "JMSCorrelationID should be null");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsJMSReplyToConsumerEndpointUsingInOutTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsJMSReplyToConsumerEndpointUsingInOutTest.java
index 29f8f6a..effd372 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsJMSReplyToConsumerEndpointUsingInOutTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsJMSReplyToConsumerEndpointUsingInOutTest.java
@@ -33,7 +33,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class JmsJMSReplyToConsumerEndpointUsingInOutTest extends CamelTestSupport {
@Test
- public void testCustomJMSReplyToInOut() throws Exception {
+ public void testCustomJMSReplyToInOut() {
template.sendBody("activemq:queue:hello", "What is your name?");
String reply = consumer.receiveBody("activemq:queue:namedReplyQueue", 5000, String.class);
@@ -41,9 +41,9 @@ public class JmsJMSReplyToConsumerEndpointUsingInOutTest extends CamelTestSuppor
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello?replyTo=queue:namedReplyQueue")
.to("log:hello")
.transform(constant("My name is Camel"));
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsJMSReplyToEndpointUsingInOutTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsJMSReplyToEndpointUsingInOutTest.java
index ea8b7b7..f5dd920 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsJMSReplyToEndpointUsingInOutTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsJMSReplyToEndpointUsingInOutTest.java
@@ -86,10 +86,10 @@ public class JmsJMSReplyToEndpointUsingInOutTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:hello")
.process(exchange -> exchange.getMessage().setBody("What's your name"))
// use in out to get a reply as well
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsLifecycleIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsLifecycleIssueTest.java
index 42bb27d..29bca94 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsLifecycleIssueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsLifecycleIssueTest.java
@@ -77,13 +77,13 @@ public class JmsLifecycleIssueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(ENDPOINT_URI).routeId(ROUTE_ID).autoStartup(false)
.to("log:input")
.to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMQSpecialHeaderTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMQSpecialHeaderTest.java
index 9431803..beab093 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMQSpecialHeaderTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMQSpecialHeaderTest.java
@@ -69,9 +69,9 @@ public class JmsMQSpecialHeaderTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:ibm").to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMessageHeaderContentBasedRouterTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMessageHeaderContentBasedRouterTest.java
index f418508..3e8f7cf 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMessageHeaderContentBasedRouterTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMessageHeaderContentBasedRouterTest.java
@@ -52,10 +52,10 @@ public class JmsMessageHeaderContentBasedRouterTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
Predicate isA = header("route").isEqualTo("a");
Predicate isB = header("route").isEqualTo("b");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMutateMessageTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMutateMessageTest.java
index 0db24ea..7ca6bd1 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMutateMessageTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMutateMessageTest.java
@@ -56,10 +56,10 @@ public class JmsMutateMessageTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(uri)
.process(exchange -> {
// do not mutate it
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMutateRemoveHeaderMessageTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMutateRemoveHeaderMessageTest.java
index 821545e..6af3edd 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMutateRemoveHeaderMessageTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMutateRemoveHeaderMessageTest.java
@@ -57,10 +57,10 @@ public class JmsMutateRemoveHeaderMessageTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(uri)
.process(exchange -> {
// do not mutate it
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyEndUserIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyEndUserIssueTest.java
index 2f8dbcd..1f827ab 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyEndUserIssueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyEndUserIssueTest.java
@@ -55,10 +55,10 @@ public class JmsPassThroughtJmsKeyFormatStrategyEndUserIssueTest extends CamelTe
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(uri)
.process(exchange -> {
Map<String, Object> headers = exchange.getIn().getHeaders();
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyEndpointTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyEndpointTest.java
index cff3159..b7e41d9 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyEndpointTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyEndpointTest.java
@@ -62,10 +62,10 @@ public class JmsPassThroughtJmsKeyFormatStrategyEndpointTest extends CamelTestSu
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(uri)
.process(exchange -> {
Map<String, Object> headers = exchange.getIn().getHeaders();
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyTest.java
index 62a47c4..2dd332b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyTest.java
@@ -70,10 +70,10 @@ public class JmsPassThroughtJmsKeyFormatStrategyTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(uri)
.process(exchange -> {
Map<String, Object> headers = exchange.getIn().getHeaders();
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyUsingJmsConfigurationTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyUsingJmsConfigurationTest.java
index 0dd2d35..bf2240a 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyUsingJmsConfigurationTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsPassThroughtJmsKeyFormatStrategyUsingJmsConfigurationTest.java
@@ -71,10 +71,10 @@ public class JmsPassThroughtJmsKeyFormatStrategyUsingJmsConfigurationTest extend
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(uri)
.process(exchange -> {
Map<String, Object> headers = exchange.getIn().getHeaders();
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsReplyToComponentEndlessLoopTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsReplyToComponentEndlessLoopTest.java
index 0bbe092..ed5f396 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsReplyToComponentEndlessLoopTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsReplyToComponentEndlessLoopTest.java
@@ -48,7 +48,7 @@ public class JmsReplyToComponentEndlessLoopTest extends CamelTestSupport {
public void testReplyToInvalid() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo?replyTo=foo").to("mock:result");
}
});
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsReplyToLoopIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsReplyToLoopIssueTest.java
index 386232c..bb86cfd 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsReplyToLoopIssueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsReplyToLoopIssueTest.java
@@ -51,10 +51,10 @@ public class JmsReplyToLoopIssueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
// must enable preserveMessageQos to force Camel to use the JMSReplyTo header
.to("activemq:queue:foo?preserveMessageQos=true")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsResequencerTestRouteBuilder.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsResequencerTestRouteBuilder.java
index a38e4f4..3630ff7 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsResequencerTestRouteBuilder.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsResequencerTestRouteBuilder.java
@@ -24,7 +24,7 @@ import org.apache.camel.builder.RouteBuilder;
public class JmsResequencerTestRouteBuilder extends RouteBuilder {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:in1").resequence().body().batch().size(100).timeout(10000L).to("mock:result");
from("activemq:queue:in2").resequence().header("num").stream().timeout(2000L).to("mock:result");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsRoutingSlipIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsRoutingSlipIssueTest.java
index 699c222..6ee6ddb 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsRoutingSlipIssueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsRoutingSlipIssueTest.java
@@ -51,10 +51,10 @@ public class JmsRoutingSlipIssueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
// need to use InOut as we do request/reply over JMS
.setExchangePattern(ExchangePattern.InOut)
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsSendToAlotOfDestinationWithSameEndpointTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsSendToAlotOfDestinationWithSameEndpointTest.java
index f87b6c8..99b760e 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsSendToAlotOfDestinationWithSameEndpointTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsSendToAlotOfDestinationWithSameEndpointTest.java
@@ -31,7 +31,7 @@ public class JmsSendToAlotOfDestinationWithSameEndpointTest extends CamelSpringT
private static final String URI = "activemq:queue:foo?autoStartup=false";
@Test
- public void testSendToAlotOfMessageToQueues() throws Exception {
+ public void testSendToAlotOfMessageToQueues() {
int size = 100;
LOG.info("About to send " + size + " messages");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsToFileMessageIdTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsToFileMessageIdTest.java
index 15ff49c..8fa97fd 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsToFileMessageIdTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsToFileMessageIdTest.java
@@ -57,10 +57,10 @@ public class JmsToFileMessageIdTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// Make a route from an activemq queue to a file endpoint, then try to call getMessageId()
from("activemq:foo")
.process(exchange -> {
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedDeadLetterChannelHandlerRollbackOnExceptionTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedDeadLetterChannelHandlerRollbackOnExceptionTest.java
index c174930..0d0803b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedDeadLetterChannelHandlerRollbackOnExceptionTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedDeadLetterChannelHandlerRollbackOnExceptionTest.java
@@ -35,7 +35,7 @@ public class JmsTransactedDeadLetterChannelHandlerRollbackOnExceptionTest extend
public static class BadErrorHandler {
@Handler
- public void onException(Exchange exchange, Exception exception) throws Exception {
+ public void onException(Exchange exchange, Exception exception) {
throw new RuntimeCamelException("error in errorhandler");
}
}
@@ -47,10 +47,10 @@ public class JmsTransactedDeadLetterChannelHandlerRollbackOnExceptionTest extend
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// we use DLC to handle the exception but if it throw a new exception
// then the DLC handles that too (the transaction will always commit)
errorHandler(deadLetterChannel("bean:" + BadErrorHandler.class.getName())
@@ -65,7 +65,7 @@ public class JmsTransactedDeadLetterChannelHandlerRollbackOnExceptionTest extend
}
@Test
- public void shouldNotLoseMessagesOnExceptionInErrorHandler() throws Exception {
+ public void shouldNotLoseMessagesOnExceptionInErrorHandler() {
template.sendBody(testingEndpoint, "Hello World");
// as we handle new exception, then the exception is ignored
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedDeadLetterChannelNotHandlerRollbackOnExceptionTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedDeadLetterChannelNotHandlerRollbackOnExceptionTest.java
index b07c704..f6ff87e 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedDeadLetterChannelNotHandlerRollbackOnExceptionTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedDeadLetterChannelNotHandlerRollbackOnExceptionTest.java
@@ -30,7 +30,7 @@ public class JmsTransactedDeadLetterChannelNotHandlerRollbackOnExceptionTest
@Override
@Test
- public void shouldNotLoseMessagesOnExceptionInErrorHandler() throws Exception {
+ public void shouldNotLoseMessagesOnExceptionInErrorHandler() {
template.sendBody(testingEndpoint, "Hello World");
// as we do not handle new exception, then the exception propagates back
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedOnExceptionRollbackOnExceptionTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedOnExceptionRollbackOnExceptionTest.java
index 591f345..ab1ff01 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedOnExceptionRollbackOnExceptionTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedOnExceptionRollbackOnExceptionTest.java
@@ -37,7 +37,7 @@ public class JmsTransactedOnExceptionRollbackOnExceptionTest extends CamelTestSu
@SuppressWarnings("unused")
@Handler
- public void onException(Exchange exchange, Exception exception) throws Exception {
+ public void onException(Exchange exchange, Exception exception) {
throw new RuntimeCamelException("error in errorhandler");
}
}
@@ -45,10 +45,10 @@ public class JmsTransactedOnExceptionRollbackOnExceptionTest extends CamelTestSu
protected final String testingEndpoint = "activemq:test." + getClass().getName();
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// we attempt to handle the exception but if it throw a new exception
// then it causes the JMS transaction to rollback
onException(Exception.class).handled(true).bean(BadErrorHandler.class);
@@ -61,7 +61,7 @@ public class JmsTransactedOnExceptionRollbackOnExceptionTest extends CamelTestSu
}
@Test
- public void shouldNotLoseMessagesOnExceptionInErrorHandler() throws Exception {
+ public void shouldNotLoseMessagesOnExceptionInErrorHandler() {
template.sendBody(testingEndpoint, "Hello World");
Object dlqBody = consumer.receiveBody("activemq:ActiveMQ.DLQ", 2000);
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTypeConverterIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTypeConverterIssueTest.java
index 2e51526..9e4779d 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTypeConverterIssueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTypeConverterIssueTest.java
@@ -76,10 +76,10 @@ public class JmsTypeConverterIssueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:inbox")
.setProperty(Exchange.CHARSET_NAME, constant("UTF-8"))
.setHeader("agentId", xpath("/agent/@id"))
@@ -104,7 +104,7 @@ public class JmsTypeConverterIssueTest extends CamelTestSupport {
private static class FixateHeaderValuesProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
String id = exchange.getIn().getHeader("agentId", String.class);
exchange.getIn().setHeader("agentId", id);
}
@@ -112,7 +112,7 @@ public class JmsTypeConverterIssueTest extends CamelTestSupport {
private static class ReadLocalFile implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
String filename = exchange.getIn().getHeader(Exchange.FILE_NAME, String.class);
exchange.getIn().setBody(new File(filename));
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/LarsIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/LarsIssueTest.java
index cdbad3e..8266101 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/LarsIssueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/LarsIssueTest.java
@@ -61,9 +61,9 @@ public class LarsIssueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
Processor myProcessor = e -> LOG.info(">>>> Received exchange: " + e);
// lets enable CACHE_CONSUMER so that the consumer stays around in JMX
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/MQSeriesHeaderTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/MQSeriesHeaderTest.java
index 1f71860..1c3de87 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/MQSeriesHeaderTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/MQSeriesHeaderTest.java
@@ -73,9 +73,9 @@ public class MQSeriesHeaderTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:test.a").to("activemq:test.b");
from("activemq:test.b").to("mock:result");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/MyFailureProcessor.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/MyFailureProcessor.java
index dd01882..8832ea9 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/MyFailureProcessor.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/MyFailureProcessor.java
@@ -25,7 +25,7 @@ import org.apache.camel.Processor;
public class MyFailureProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
throw new IllegalArgumentException("Unit test - this is thrown by intention");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/NoClassDefFoundErrorWrapExceptionTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/NoClassDefFoundErrorWrapExceptionTest.java
index faf95d8..d7b6788 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/NoClassDefFoundErrorWrapExceptionTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/NoClassDefFoundErrorWrapExceptionTest.java
@@ -34,7 +34,7 @@ import static org.junit.jupiter.api.Assertions.fail;
public class NoClassDefFoundErrorWrapExceptionTest extends CamelTestSupport {
@Test
- public void testNoClassDef() throws Exception {
+ public void testNoClassDef() {
try {
template.requestBody("activemq:start?transferException=true", "Hello World");
fail("Should throw exception");
@@ -51,10 +51,10 @@ public class NoClassDefFoundErrorWrapExceptionTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:start?transferException=true")
.process(new ProcessorA())
.process(new ProcessorB())
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ProcessorA.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ProcessorA.java
index f64f470..3993ae4 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ProcessorA.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ProcessorA.java
@@ -22,7 +22,7 @@ import org.apache.camel.Processor;
public class ProcessorA implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader("a", "a");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ProcessorB.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ProcessorB.java
index ac3528b..c5efc6b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ProcessorB.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ProcessorB.java
@@ -22,7 +22,7 @@ import org.apache.camel.Processor;
public class ProcessorB implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader("b", "b");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ProcessorFail.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ProcessorFail.java
index dc6db65..6e76235 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ProcessorFail.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/ProcessorFail.java
@@ -22,7 +22,7 @@ import org.apache.camel.Processor;
public class ProcessorFail implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
throw new LinkageError("Cannot do this");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/RequestReplyWithProducerIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/RequestReplyWithProducerIssueTest.java
index 1d619b9..d24ca5a 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/RequestReplyWithProducerIssueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/RequestReplyWithProducerIssueTest.java
@@ -58,10 +58,10 @@ public class RequestReplyWithProducerIssueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.process(exchange -> exchange.getMessage().setBody("Bye World"));
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/TempReplyToIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/TempReplyToIssueTest.java
index 179f56b..0720efa 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/TempReplyToIssueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/TempReplyToIssueTest.java
@@ -38,7 +38,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class TempReplyToIssueTest extends CamelTestSupport {
@Test
- public void testReplyToIssue() throws Exception {
+ public void testReplyToIssue() {
String out = template.requestBody("activemq:queue:test.queue", "World", String.class);
// we should receive that fixed reply
assertEquals("Hello Moon", out);
@@ -81,10 +81,10 @@ public class TempReplyToIssueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:test.queue").bean(TempReplyToIssueTest.class, "handleMessage");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/TransactionErrorHandlerRedeliveryDelayTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/TransactionErrorHandlerRedeliveryDelayTest.java
index 1d3b6d3..35860ce 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/TransactionErrorHandlerRedeliveryDelayTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/TransactionErrorHandlerRedeliveryDelayTest.java
@@ -53,7 +53,7 @@ public class TransactionErrorHandlerRedeliveryDelayTest extends CamelSpringTestS
}
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
if (counter++ < 3) {
throw new IllegalArgumentException("Forced exception as counter is " + counter);
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/JmsReconnectTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/JmsReconnectTest.java
index 79ccd00..ee533a1 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/JmsReconnectTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/JmsReconnectTest.java
@@ -91,7 +91,7 @@ public class JmsReconnectTest {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("jms:testqueue").bean(new EchoServiceImpl());
from("direct:test").to("jms:testqueue");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/JmsRequestReplyTemporaryRefreshFailureOnStartupTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/JmsRequestReplyTemporaryRefreshFailureOnStartupTest.java
index c5a5c5d..2dda288 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/JmsRequestReplyTemporaryRefreshFailureOnStartupTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/JmsRequestReplyTemporaryRefreshFailureOnStartupTest.java
@@ -49,10 +49,10 @@ public class JmsRequestReplyTemporaryRefreshFailureOnStartupTest extends CamelTe
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to(ExchangePattern.InOut, "jms:queue:foo?recoveryInterval=" + recoveryInterval)
.to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/TemporaryQueueRouteTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/TemporaryQueueRouteTest.java
index 891aafd..17dad45 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/TemporaryQueueRouteTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/TemporaryQueueRouteTest.java
@@ -51,9 +51,9 @@ public class TemporaryQueueRouteTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(endpointUri).to("mock:result");
}
};
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tuning/PerformanceRouteTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tuning/PerformanceRouteTest.java
index 0d75999..30cc6b5 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tuning/PerformanceRouteTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tuning/PerformanceRouteTest.java
@@ -85,10 +85,10 @@ public class PerformanceRouteTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:inbox?concurrentConsumers=10")
.to("activemq:topic:audit")
.choice()
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AbstractTransactionTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AbstractTransactionTest.java
index 11d09c4..b6a5a0b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AbstractTransactionTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AbstractTransactionTest.java
@@ -55,7 +55,7 @@ public abstract class AbstractTransactionTest extends CamelSpringTestSupport {
return new ClassPathXmlApplicationContext("org/apache/camel/component/jms/tx/JavaDSLTransactionTest.xml");
}
- protected void assertResult() throws InterruptedException {
+ protected void assertResult() {
// should be 1 completed and 1 failed
NotifyBuilder notify = new NotifyBuilder(context).whenDone(2).create();
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTX2Test.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTX2Test.java
index 75c6cfe..73040d7 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTX2Test.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTX2Test.java
@@ -49,10 +49,10 @@ public class AsyncEndpointJmsTX2Test extends CamelSpringTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
context.addComponent("async", new MyAsyncComponent());
from("activemq:queue:inbox")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXMulticastTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXMulticastTest.java
index eb6b2ff..6ff72da 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXMulticastTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXMulticastTest.java
@@ -49,10 +49,10 @@ public class AsyncEndpointJmsTXMulticastTest extends CamelSpringTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
context.addComponent("async", new MyAsyncComponent());
from("activemq:queue:inbox")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRecipientListTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRecipientListTest.java
index 8c64f00..651fabc 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRecipientListTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRecipientListTest.java
@@ -49,10 +49,10 @@ public class AsyncEndpointJmsTXRecipientListTest extends CamelSpringTestSupport
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
context.addComponent("async", new MyAsyncComponent());
from("activemq:queue:inbox")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollback2Test.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollback2Test.java
index a30c9bf..b8e8dfa 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollback2Test.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollback2Test.java
@@ -54,10 +54,10 @@ public class AsyncEndpointJmsTXRollback2Test extends CamelSpringTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
context.addComponent("async", new MyAsyncComponent());
from("activemq:queue:inbox")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollbackTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollbackTest.java
index a87e625..7a37def 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollbackTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollbackTest.java
@@ -53,10 +53,10 @@ public class AsyncEndpointJmsTXRollbackTest extends CamelSpringTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
context.addComponent("async", new MyAsyncComponent());
from("activemq:queue:inbox")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRoutingSlipTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRoutingSlipTest.java
index bcc0a19..d2da209 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRoutingSlipTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRoutingSlipTest.java
@@ -50,10 +50,10 @@ public class AsyncEndpointJmsTXRoutingSlipTest extends CamelSpringTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
context.addComponent("async", new MyAsyncComponent());
from("activemq:queue:inbox")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTest.java
index 276bdbb..f4d3a98 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTest.java
@@ -49,10 +49,10 @@ public class AsyncEndpointJmsTXTest extends CamelSpringTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
context.addComponent("async", new MyAsyncComponent());
from("activemq:queue:inbox")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTryCatchFinallyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTryCatchFinallyTest.java
index bf8905d..fbbf6d0 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTryCatchFinallyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTryCatchFinallyTest.java
@@ -52,10 +52,10 @@ public class AsyncEndpointJmsTXTryCatchFinallyTest extends CamelSpringTestSuppor
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
context.addComponent("async", new MyAsyncComponent());
from("activemq:queue:inbox")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXWireTapTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXWireTapTest.java
index ecb00fe..caed1a9 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXWireTapTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXWireTapTest.java
@@ -49,10 +49,10 @@ public class AsyncEndpointJmsTXWireTapTest extends CamelSpringTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
context.addComponent("async", new MyAsyncComponent());
from("activemq:queue:inbox")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTXInOutPersistentQueueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTXInOutPersistentQueueTest.java
index db712ee..a4e8cfd 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTXInOutPersistentQueueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTXInOutPersistentQueueTest.java
@@ -61,10 +61,10 @@ public class JMSTXInOutPersistentQueueTest extends CamelSpringTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to(ExchangePattern.InOut, "activemq:queue:foo?replyTo=myReplies")
.to("mock:reply")
.process(exchange -> {
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionErrorHandlerTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionErrorHandlerTest.java
index ae8625c..b798092 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionErrorHandlerTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionErrorHandlerTest.java
@@ -56,7 +56,7 @@ public class JMSTransactionErrorHandlerTest extends CamelSpringTestSupport {
private int count;
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
if (++count <= 2) {
throw new IllegalArgumentException("Forced Exception number " + count + ", please retry");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionIsTransactedRedeliveredTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionIsTransactedRedeliveredTest.java
index f2a463a..f1d9bd5 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionIsTransactedRedeliveredTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionIsTransactedRedeliveredTest.java
@@ -58,7 +58,7 @@ public class JMSTransactionIsTransactedRedeliveredTest extends CamelSpringTestSu
public void testTransactionSuccess() throws Exception {
AdviceWith.adviceWith(context.getRouteDefinitions().get(0), context, new AdviceWithRouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
onException(AssertionError.class).to("log:error", "mock:error");
}
});
@@ -111,7 +111,7 @@ public class JMSTransactionIsTransactedRedeliveredTest extends CamelSpringTestSu
private int count;
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
++count;
// the first is not redelivered
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionRollbackTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionRollbackTest.java
index 39fac89..05e372f 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionRollbackTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionRollbackTest.java
@@ -45,7 +45,7 @@ public class JMSTransactionRollbackTest extends CamelSpringTestSupport {
public static class MyProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
throw new IllegalArgumentException("Forced Exception");
}
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionalClientTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionalClientTest.java
index 42e40e1..adaa126 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionalClientTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionalClientTest.java
@@ -54,7 +54,7 @@ public class JMSTransactionalClientTest extends CamelSpringTestSupport {
private int count;
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
if (++count <= 2) {
throw new IllegalArgumentException("Forced Exception number " + count + ", please retry");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionalClientWithRollbackTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionalClientWithRollbackTest.java
index ff5c911..74fe107 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionalClientWithRollbackTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionalClientWithRollbackTest.java
@@ -51,7 +51,7 @@ public class JMSTransactionalClientWithRollbackTest extends CamelSpringTestSuppo
private int count;
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setBody("Bye World");
exchange.getIn().setHeader("count", ++count);
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMXTXUseOriginalBodyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMXTXUseOriginalBodyTest.java
index 872234b..6da1f99 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMXTXUseOriginalBodyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMXTXUseOriginalBodyTest.java
@@ -87,7 +87,7 @@ public class JMXTXUseOriginalBodyTest extends CamelSpringTestSupport {
public static class TestRoutes extends RouteBuilder {
@Override
- public void configure() throws Exception {
+ public void configure() {
onException(Exception.class)
.handled(true)
.useOriginalMessage()
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMXTXUseOriginalBodyWithDLCErrorHandlerTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMXTXUseOriginalBodyWithDLCErrorHandlerTest.java
index ce9809c..617b75d 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMXTXUseOriginalBodyWithDLCErrorHandlerTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMXTXUseOriginalBodyWithDLCErrorHandlerTest.java
@@ -110,7 +110,7 @@ public class JMXTXUseOriginalBodyWithDLCErrorHandlerTest extends JMXTXUseOrigina
public static class TestRoutes extends RouteBuilder {
@Override
- public void configure() throws Exception {
+ public void configure() {
errorHandler(deadLetterChannel("mock:dead").maximumRedeliveries(5));
onException(Exception.class)
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMXTXUseOriginalBodyWithTXErrorHandlerTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMXTXUseOriginalBodyWithTXErrorHandlerTest.java
index d79ece4..b57f95d 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMXTXUseOriginalBodyWithTXErrorHandlerTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMXTXUseOriginalBodyWithTXErrorHandlerTest.java
@@ -90,7 +90,7 @@ public class JMXTXUseOriginalBodyWithTXErrorHandlerTest extends JMXTXUseOriginal
public static class TestRoutes extends RouteBuilder {
@Override
- public void configure() throws Exception {
+ public void configure() {
errorHandler(new TransactionErrorHandlerBuilder());
onException(Exception.class)
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JmsToJmsTransactedSecurityTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JmsToJmsTransactedSecurityTest.java
index 5b3e0ee..f6afe25 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JmsToJmsTransactedSecurityTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JmsToJmsTransactedSecurityTest.java
@@ -38,7 +38,7 @@ public class JmsToJmsTransactedSecurityTest extends CamelSpringTestSupport {
public void testJmsSecurityFailure() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.transacted()
.to("log:foo")
@@ -65,7 +65,7 @@ public class JmsToJmsTransactedSecurityTest extends CamelSpringTestSupport {
public void testJmsSecurityOK() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("log:start")
.to("activemq:queue:foo");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JmsToJmsTransactedTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JmsToJmsTransactedTest.java
index 1d65e37..a8e7e47 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JmsToJmsTransactedTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JmsToJmsTransactedTest.java
@@ -35,7 +35,7 @@ public class JmsToJmsTransactedTest extends CamelSpringTestSupport {
public void testJmsToJmsTestOK() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.transacted()
.to("activemq:queue:bar");
@@ -53,7 +53,7 @@ public class JmsToJmsTransactedTest extends CamelSpringTestSupport {
public void testJmsToJmsTestRollbackDueToException() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.transacted()
.to("mock:start")
@@ -80,7 +80,7 @@ public class JmsToJmsTransactedTest extends CamelSpringTestSupport {
public void testJmsToJmsTestRollbackDueToRollback() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.transacted()
.to("mock:start")
@@ -111,7 +111,7 @@ public class JmsToJmsTransactedTest extends CamelSpringTestSupport {
public void testJmsToJmsTestRollbackDueToMarkRollbackOnly() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.transacted()
.to("mock:start")
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToProcessorTransactionTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToProcessorTransactionTest.java
index 47b6080..1ed94e7 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToProcessorTransactionTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToProcessorTransactionTest.java
@@ -37,7 +37,7 @@ public class QueueToProcessorTransactionTest extends AbstractTransactionTest {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
Policy required = context().getRegistry().lookupByNameAndType("PROPAGATION_REQUIRED_POLICY",
SpringTransactionPolicy.class);
from("activemq:queue:foo").policy(required).process(new ConditionalExceptionProcessor());
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToQueueRequestReplyTransactionTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToQueueRequestReplyTransactionTest.java
index b9397ab..d5c687c 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToQueueRequestReplyTransactionTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToQueueRequestReplyTransactionTest.java
@@ -39,7 +39,7 @@ public class QueueToQueueRequestReplyTransactionTest extends AbstractTransaction
final ConditionalExceptionProcessor cp = new ConditionalExceptionProcessor(5);
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
Policy required = context().getRegistry().lookupByNameAndType("PROPAGATION_REQUIRED_POLICY",
SpringTransactionPolicy.class);
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToQueueTransactionTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToQueueTransactionTest.java
index 5529f10..0d140d4 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToQueueTransactionTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToQueueTransactionTest.java
@@ -36,7 +36,7 @@ public class QueueToQueueTransactionTest extends AbstractTransactionTest {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
Policy required = context().getRegistry().lookupByNameAndType("PROPAGATION_REQUIRED_POLICY",
SpringTransactionPolicy.class);
from("activemq:queue:foo?transacted=true").policy(required).process(new ConditionalExceptionProcessor())
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToQueueTransactionWithoutDefineTransactionManagerTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToQueueTransactionWithoutDefineTransactionManagerTest.java
index 83130ca..5d97571 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToQueueTransactionWithoutDefineTransactionManagerTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/QueueToQueueTransactionWithoutDefineTransactionManagerTest.java
@@ -38,7 +38,7 @@ public class QueueToQueueTransactionWithoutDefineTransactionManagerTest extends
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
errorHandler(noErrorHandler());
from("activemq:queue:foo?transacted=false").process(new ConditionalExceptionProcessor())
.to("activemq:queue:bar?transacted=false");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/RouteIdTransactedTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/RouteIdTransactedTest.java
index 3641898..b1c098b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/RouteIdTransactedTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/RouteIdTransactedTest.java
@@ -58,10 +58,10 @@ public class RouteIdTransactedTest extends CamelSpringTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo?transacted=true").id("myCoolRoute")
.onException(IllegalArgumentException.class).handled(true).to("log:bar").to("mock:error").end()
.transacted()
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactedAsyncUsingThreadsTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactedAsyncUsingThreadsTest.java
index e4da509..e41b4a8 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactedAsyncUsingThreadsTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactedAsyncUsingThreadsTest.java
@@ -81,10 +81,10 @@ public class TransactedAsyncUsingThreadsTest extends CamelSpringTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo")
.process(exchange -> thread1 = Thread.currentThread().getName())
// use transacted routing
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactedOnCompletionTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactedOnCompletionTest.java
index fec6b55..4702810 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactedOnCompletionTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactedOnCompletionTest.java
@@ -52,7 +52,7 @@ public class TransactedOnCompletionTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactionErrorHandlerBuilderAsSpringBeanTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactionErrorHandlerBuilderAsSpringBeanTest.java
index c360068..69d3516 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactionErrorHandlerBuilderAsSpringBeanTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactionErrorHandlerBuilderAsSpringBeanTest.java
@@ -51,7 +51,7 @@ public class TransactionErrorHandlerBuilderAsSpringBeanTest extends CamelSpringT
private int count;
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
if (++count <= 2) {
throw new IllegalArgumentException("Forced Exception number " + count + ", please retry");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactionErrorHandlerCustomerSpringParserTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactionErrorHandlerCustomerSpringParserTest.java
index 4035bc7..e5d2c05 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactionErrorHandlerCustomerSpringParserTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactionErrorHandlerCustomerSpringParserTest.java
@@ -51,7 +51,7 @@ public class TransactionErrorHandlerCustomerSpringParserTest extends CamelSpring
private int count;
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
if (++count <= 2) {
throw new IllegalArgumentException("Forced Exception number " + count + ", please retry");
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactionMinimalConfigurationTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactionMinimalConfigurationTest.java
index 49e626a..81c6538 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactionMinimalConfigurationTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/TransactionMinimalConfigurationTest.java
@@ -56,7 +56,7 @@ public class TransactionMinimalConfigurationTest extends CamelSpringTestSupport
private int count;
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
if (++count <= 2) {
throw new IllegalArgumentException("Forced Exception number " + count + ", please retry");
}