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
commit 5b9942947ccdb38d1bc900d68266226f987125c5 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Tue Mar 8 11:55:41 2022 +0100 CAMEL-17763: cleaned up unused exceptions in camel-activemq --- .../test/java/org/apache/camel/component/activemq/AMQ2611Test.java | 4 ++-- .../org/apache/camel/component/activemq/ActiveMQConfigureTest.java | 2 +- .../camel/component/activemq/ActiveMQJmsHeaderRouteForceTest.java | 4 ++-- .../apache/camel/component/activemq/ActiveMQJmsHeaderRouteTest.java | 6 +++--- .../camel/component/activemq/ActiveMQOriginalDestinationTest.java | 4 ++-- .../component/activemq/ActiveMQReplyToHeaderUsingConverterTest.java | 4 ++-- .../java/org/apache/camel/component/activemq/ActiveMQRouteTest.java | 4 ++-- .../camel/component/activemq/ActiveMQToDSendDynamicTwoTest.java | 6 +++--- .../camel/component/activemq/AdvisoryConsumerExampleTest.java | 6 +++--- .../camel/component/activemq/CamelVMTransportRoutingTest.java | 2 +- .../apache/camel/component/activemq/ComplexRequestReplyTest.java | 4 ++-- .../activemq/InvokeRequestReplyUsingJmsReplyToHeaderTest.java | 4 ++-- .../apache/camel/component/activemq/JmsSimpleRequestReplyTest.java | 2 +- .../java/org/apache/camel/component/activemq/SetHeaderTest.java | 2 +- .../org/apache/camel/component/activemq/TransactedConsumeTest.java | 2 +- .../component/activemq/converter/InvokeJmsMessageListenerTest.java | 4 ++-- .../component/activemq/converter/InvokeMessageListenerTest.java | 4 ++-- 17 files changed, 32 insertions(+), 32 deletions(-) diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AMQ2611Test.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AMQ2611Test.java index c791826..f96547a 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AMQ2611Test.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AMQ2611Test.java @@ -62,7 +62,7 @@ public class AMQ2611Test implements ActiveMQSupport { final String queueEndpointName = "activemq:queue" + QUEUE_NAME; camelContext.addRoutes(new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(queueEndpointName).bean(Consumer.class, "consume"); } }); @@ -86,7 +86,7 @@ public class AMQ2611Test implements ActiveMQSupport { producerTemplate.sendBody(queueEndpointName, "message"); } - private void destroyCamelContext() throws Exception { + private void destroyCamelContext() { LOG.info("destroying context"); camelContext.stop(); camelContext = null; diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQConfigureTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQConfigureTest.java index d572909..00d5963 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQConfigureTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQConfigureTest.java @@ -63,7 +63,7 @@ public class ActiveMQConfigureTest extends ActiveMQTestSupport { } @Test - public void testSessionTransactedWithoutTransactionManager() throws Exception { + public void testSessionTransactedWithoutTransactionManager() { JmsEndpoint endpoint = resolveMandatoryEndpoint("activemq:test.foo?transacted=true&lazyCreateTransactionManager=false"); JmsConfiguration configuration = endpoint.getConfiguration(); diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteForceTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteForceTest.java index a606af9..f4061ef 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteForceTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteForceTest.java @@ -29,9 +29,9 @@ import static org.apache.camel.test.junit5.TestSupport.assertIsInstanceOf; public class ActiveMQJmsHeaderRouteForceTest extends ActiveMQJmsHeaderRouteTest { @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { - public void configure() throws Exception { + public void configure() { // do not map jms message as we want to tamper with the JMS // message directly, and not use the Camel API for that from("activemq:test.a?mapJmsMessage=false").process(new Processor() { diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteTest.java index 53ca137..3be327d 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteTest.java @@ -85,11 +85,11 @@ public class ActiveMQJmsHeaderRouteTest extends ActiveMQTestSupport { } @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(new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { // lets set the custom JMS headers using the Camel API exchange.getIn().setHeader("JMSReplyTo", replyQueue); exchange.getIn().setHeader("JMSCorrelationID", correlationID); diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQOriginalDestinationTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQOriginalDestinationTest.java index 8aa2ffc..5f5fe27 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQOriginalDestinationTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQOriginalDestinationTest.java @@ -66,10 +66,10 @@ public class ActiveMQOriginalDestinationTest extends ActiveMQTestSupport { } @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-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQReplyToHeaderUsingConverterTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQReplyToHeaderUsingConverterTest.java index 9c2b9b1..4b3a4f3 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQReplyToHeaderUsingConverterTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQReplyToHeaderUsingConverterTest.java @@ -107,9 +107,9 @@ public class ActiveMQReplyToHeaderUsingConverterTest extends ActiveMQTestSupport } @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?preserveMessageQos=true"); from("activemq:test.b").to("mock:result"); diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQRouteTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQRouteTest.java index de756f7..32c53ab 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQRouteTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQRouteTest.java @@ -70,9 +70,9 @@ public class ActiveMQRouteTest extends ActiveMQTestSupport { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { - public void configure() throws Exception { + public void configure() { from(startEndpointUri).to("activemq:queue:test.b"); from("activemq:queue:test.b").to("mock:result"); diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQToDSendDynamicTwoTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQToDSendDynamicTwoTest.java index 3959d99..7356f15 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQToDSendDynamicTwoTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQToDSendDynamicTwoTest.java @@ -26,7 +26,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals; public class ActiveMQToDSendDynamicTwoTest extends ActiveMQTestSupport { @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"); @@ -40,10 +40,10 @@ public class ActiveMQToDSendDynamicTwoTest extends ActiveMQTestSupport { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { context.addComponent("activemq", activeMQComponent(vmUri("?broker.persistent=false"))); // route message dynamic using toD diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AdvisoryConsumerExampleTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AdvisoryConsumerExampleTest.java index 311cc42..c593311 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AdvisoryConsumerExampleTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AdvisoryConsumerExampleTest.java @@ -39,16 +39,16 @@ public class AdvisoryConsumerExampleTest extends ActiveMQTestSupport { private static final Logger LOG = LoggerFactory.getLogger(AdvisoryConsumerExampleTest.class); @Test - public void testWorks() throws Exception { + public void testWorks() { // lets create a new queue assertDoesNotThrow( () -> template.sendBody("activemq:NewQueue." + System.currentTimeMillis(), "<hello>world!</hello>")); } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { - public void configure() throws Exception { + public void configure() { context.addComponent("activemq", activeMQComponent(vmUri("?broker.persistent=false"))); // lets force the creation of a queue up front diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/CamelVMTransportRoutingTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/CamelVMTransportRoutingTest.java index 01cd50b..98ef5e6 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/CamelVMTransportRoutingTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/CamelVMTransportRoutingTest.java @@ -139,7 +139,7 @@ public class CamelVMTransportRoutingTest implements ActiveMQSupport { ActiveMQComponent.activeMQComponent(vmUri("?create=false&waitForStart=10000"))); camelContext.addRoutes(new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(fromEndpoint).to(toEndpoint); } }); diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ComplexRequestReplyTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ComplexRequestReplyTest.java index 77f42f3..74464c2 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ComplexRequestReplyTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ComplexRequestReplyTest.java @@ -132,7 +132,7 @@ public class ComplexRequestReplyTest implements ActiveMQSupport { camelContext.addComponent("activemq", amqComponent); camelContext.addRoutes(new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(fromEndpoint).to(ExchangePattern.InOut, toEndpoint); } }); @@ -149,7 +149,7 @@ public class ComplexRequestReplyTest implements ActiveMQSupport { ActiveMQComponent.activeMQComponent(vmUri(brokerName + "?create=false&waitForStart=1000"))); camelContext.addRoutes(new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(brokerEndpoint).setBody().simple("Returning ${body}") .log("***Reply sent to ${header.JMSReplyTo} CoorId = ${header.JMSCorrelationID}"); } diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/InvokeRequestReplyUsingJmsReplyToHeaderTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/InvokeRequestReplyUsingJmsReplyToHeaderTest.java index 447ab77..e448ade 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/InvokeRequestReplyUsingJmsReplyToHeaderTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/InvokeRequestReplyUsingJmsReplyToHeaderTest.java @@ -54,7 +54,7 @@ public class InvokeRequestReplyUsingJmsReplyToHeaderTest extends ActiveMQTestSup private MyServer myBean = new MyServer(); @Test - public void testPerformRequestReplyOverJms() throws Exception { + public void testPerformRequestReplyOverJms() { Map<String, Object> headers = new HashMap<>(); headers.put("cheese", 123); headers.put("JMSReplyTo", replyQueueName); @@ -104,7 +104,7 @@ public class InvokeRequestReplyUsingJmsReplyToHeaderTest extends ActiveMQTestSup } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { from("activemq:test.server").bean(myBean); diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsSimpleRequestReplyTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsSimpleRequestReplyTest.java index ee09aaa..4844899 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsSimpleRequestReplyTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsSimpleRequestReplyTest.java @@ -69,7 +69,7 @@ public class JmsSimpleRequestReplyTest extends ActiveMQTestSupport { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { from("activemq:queue:hello").process(exchange -> { diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/SetHeaderTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/SetHeaderTest.java index 105883e..bfa66dd 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/SetHeaderTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/SetHeaderTest.java @@ -66,7 +66,7 @@ public class SetHeaderTest { */ public static class SetGroupIdProcessor implements Processor { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { // lets copy the IN to the OUT message Message out = exchange.getMessage(); out.copyFrom(exchange.getIn()); diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/TransactedConsumeTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/TransactedConsumeTest.java index a3df1eb..d60efb6 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/TransactedConsumeTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/TransactedConsumeTest.java @@ -142,7 +142,7 @@ public class TransactedConsumeTest extends ActiveMQSpringTestSupport { static class ConnectionLog implements Processor { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { if (consumed.getAndIncrement() == 0) { firstConsumed.set(System.currentTimeMillis()); } diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeJmsMessageListenerTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeJmsMessageListenerTest.java index 6da8234..651958b 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeJmsMessageListenerTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeJmsMessageListenerTest.java @@ -46,9 +46,9 @@ public class InvokeJmsMessageListenerTest 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").bean(messageListener); } }; diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeMessageListenerTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeMessageListenerTest.java index 4bbd7ad..fadff8b 100644 --- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeMessageListenerTest.java +++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeMessageListenerTest.java @@ -68,9 +68,9 @@ public class InvokeMessageListenerTest extends ActiveMQTestSupport { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { - public void configure() throws Exception { + public void configure() { from(startEndpointUri).bean(listener); } };
