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 c7918264e1793..f96547a13128f 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 @@ private void createCamelContext() throws Exception { 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 void onContextStopped(CamelContext context) { 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 d5729092c05ae..00d5963fbb144 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 void testJmsTemplateUsesSingleConnectionFactory() throws Exception { } @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 a606af9369ead..f4061efe9fec6 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 @@ 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 53ca137df1c48..3be327d110fac 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 @@ protected CamelContext createCamelContext() throws Exception { } @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 8aa2ffc40ec93..5f5fe271bf877 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 @@ protected CamelContext createCamelContext() throws Exception { } @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 9c2b9b1da15b1..4b3a4f3792789 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 @@ protected CamelContext createCamelContext() throws Exception { } @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 de756f7bc801b..32c53abe3a9d1 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 @@ protected CamelContext createCamelContext() throws Exception { } @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 3959d990daf24..7356f15599361 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 @@ 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 void testToD() throws Exception { } @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 311cc42d9f2e4..c593311ef8f05 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(), "world!")); } @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 01cd50b04ec81..98ef5e6e54575 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 @@ private void createCamelContext() throws Exception { 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 77f42f3b1de07..74464c2c72724 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 @@ private CamelContext createSenderContext() throws Exception { 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 @@ private CamelContext createBrokerCamelContext(String brokerName) throws Exceptio 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 447ab77d1609b..e448adec48e50 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 headers = new HashMap<>(); headers.put("cheese", 123); headers.put("JMSReplyTo", replyQueueName); @@ -104,7 +104,7 @@ protected CamelContext createCamelContext() throws Exception { } @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 ee09aaae0134a..4844899631110 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 ConnectionFactory createConnectionFactory(String options) { } @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 105883e88f5fd..bfa66ddd69303 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 void testMocksAreValid() throws Exception { */ 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 a3df1eb74b42f..d60efb6503629 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 @@ protected Map getTranslationProperties() { 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 6da8234968055..651958b4c34e5 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 void testCamelInvokesMessageListener() throws Exception { } @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 4bbd7ad28569f..fadff8bfe5ae6 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 @@ protected CamelContext createCamelContext() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { - public void configure() throws Exception { + public void configure() { from(startEndpointUri).bean(listener); } }; diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointPathWithSpacesTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointPathWithSpacesTest.java index 8c4123c18072a..43017928837f6 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointPathWithSpacesTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointPathWithSpacesTest.java @@ -31,22 +31,22 @@ public class AhcBridgeEndpointPathWithSpacesTest extends BaseAhcTest { private int port2; @Test - public void testBridgeEndpoint() throws Exception { + public void testBridgeEndpoint() { String response = template.requestBodyAndHeader("http://localhost:" + port1 + "/test bar/hello", new ByteArrayInputStream("This is a test".getBytes()), "Content-Type", "application/xml", String.class); assertEquals("/proxy%20bar/hello", response, "Get a wrong response"); } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { port1 = getPort(); port2 = getNextPort(); Processor serviceProc = new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { // get the request URL and copy it to the request body String uri = exchange.getIn().getHeader(Exchange.HTTP_URI, String.class); exchange.getMessage().setBody(uri); diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointTest.java index 1d36a64d48860..264fbefc2f5f0 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointTest.java @@ -34,7 +34,7 @@ public class AhcBridgeEndpointTest extends BaseAhcTest { private int port2; @Test - public void testBridgeEndpoint() throws Exception { + public void testBridgeEndpoint() { String response = template.requestBodyAndHeader("http://localhost:" + port1 + "/test/hello", new ByteArrayInputStream("This is a test".getBytes()), "Content-Type", "application/xml", String.class); assertEquals("/", response, "Get a wrong response"); @@ -51,15 +51,15 @@ public void testBridgeEndpoint() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { port1 = getPort(); port2 = getNextPort(); Processor serviceProc = new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { // get the request URL and copy it to the request body String uri = exchange.getIn().getHeader(Exchange.HTTP_URI, String.class); exchange.getMessage().setBody(uri); diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigRealmUriTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigRealmUriTest.java index 5c7f7b262d1a4..3bc2979585249 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigRealmUriTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigRealmUriTest.java @@ -24,7 +24,7 @@ public class AhcClientConfigRealmUriTest extends BaseAhcTest { @Test - public void testAhcProduce() throws Exception { + public void testAhcProduce() { Object out = template.requestBody(getAhcEndpointUri() + "?clientConfig.realm.scheme=DIGEST&clientConfig.realm.principal=someUser" + "&clientConfig.realm.password=somePass&clientConfig.realm.usePreemptiveAuth=true", @@ -33,10 +33,10 @@ public void testAhcProduce() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(getTestServerEndpointUri()) .transform(constant("Bye World")); } diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigUriTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigUriTest.java index 9b2966731b19e..42c767968ed8a 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigUriTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigUriTest.java @@ -24,16 +24,16 @@ public class AhcClientConfigUriTest extends BaseAhcTest { @Test - public void testAhcProduce() throws Exception { + public void testAhcProduce() { Object out = template.requestBody(getAhcEndpointUri() + "?clientConfig.maxRedirects=4", null, String.class); assertEquals("Bye World", out); } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(getTestServerEndpointUri()) .transform(constant("Bye World")); } diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentClientConfigTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentClientConfigTest.java index 5274dd6b994e3..819a70df5ee3b 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentClientConfigTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentClientConfigTest.java @@ -49,10 +49,10 @@ public void testAhcComponentClientConfig() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { configureComponent(); from("direct:start") @@ -61,7 +61,7 @@ public void configure() throws Exception { from(getTestServerEndpointUri()) .process(new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { // redirect to test the client config worked as we told it to follow redirects exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, "301"); exchange.getMessage().setHeader("Location", getTestServerEndpointTwoUrl()); diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentCustomClientConfigTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentCustomClientConfigTest.java index 9feeb18e0a7b4..40637a8d6a6ba 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentCustomClientConfigTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentCustomClientConfigTest.java @@ -48,17 +48,17 @@ public void testAhcComponentCustomClientConfig() throws Exception { } @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(getAhcEndpointUri()) .to("mock:result"); from(getTestServerEndpointUri()) .process(new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { // redirect to test the client config worked as we told it to follow redirects exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, "301"); exchange.getMessage().setHeader("Location", getTestServerEndpointTwoUrl()); diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentNettyClientConfigTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentNettyClientConfigTest.java index 0d10d7dfd3d6c..14fcfa809e2b1 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentNettyClientConfigTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentNettyClientConfigTest.java @@ -50,17 +50,17 @@ public void testAhcComponentCustomClientConfig() throws Exception { } @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(getAhcEndpointUri()) .to("mock:result"); from(getTestServerEndpointUri()) .process(new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { // redirect to test the client config worked as we told it to follow redirects exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, "301"); exchange.getMessage().setHeader("Location", getTestServerEndpointTwoUrl()); diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcGoogleTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcGoogleTest.java index 14b338776c390..521c9bd4d48a8 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcGoogleTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcGoogleTest.java @@ -37,10 +37,10 @@ public void testAhcGoogle() throws Exception { } @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("ahc:http://www.google.se") .to("log:result?showAll=true") diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduce500Test.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduce500Test.java index 15c27546eb78f..07f8f1e1571df 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduce500Test.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduce500Test.java @@ -50,17 +50,17 @@ public void testAhcProduce() throws Exception { } @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(getAhcEndpointUri()) .to("mock:result"); from(getTestServerEndpointUri()) .process(new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, 500); exchange.getMessage().setBody("Does not work"); } diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceClientConfigTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceClientConfigTest.java index c5dd59cb08991..58e9d1954b397 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceClientConfigTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceClientConfigTest.java @@ -44,17 +44,17 @@ protected String getAhcEndpointUri() { } @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(getAhcEndpointUri()) .to("mock:result"); from(getTestServerEndpointUri()) .process(new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { // redirect to test the client config worked as we told it to follow redirects exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, "301"); exchange.getMessage().setHeader("Location", getTestServerEndpointTwoUrl()); diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetHeadersTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetHeadersTest.java index f0070a6d0cf71..c77a073507e59 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetHeadersTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetHeadersTest.java @@ -44,10 +44,10 @@ public void testAhcProduce() throws Exception { } @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(getAhcEndpointUri()) .to("mock:result"); diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetNoSlashInUriTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetNoSlashInUriTest.java index 44dadf41c0468..41ea858dd246b 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetNoSlashInUriTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetNoSlashInUriTest.java @@ -36,10 +36,10 @@ protected String getAhcEndpointUri() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:start") // no // slash in uri should still work .to(getAhcEndpointUri()) diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetTest.java index 275ade6184908..d6a48de752c36 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetTest.java @@ -43,7 +43,7 @@ public void testAhcProduceInOut() throws Exception { } @Test - public void testAhcProduceDirectly() throws Exception { + public void testAhcProduceDirectly() { Object out = template.requestBody(getAhcEndpointUri(), null, String.class); assertEquals("Bye World", out); } @@ -58,10 +58,10 @@ public void testAhcProduceGetHeader() throws Exception { } @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(getAhcEndpointUri()) .to("mock:result"); diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceNoThrowExceptionOnFailureTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceNoThrowExceptionOnFailureTest.java index 1b89531d91b46..9212750e781f9 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceNoThrowExceptionOnFailureTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceNoThrowExceptionOnFailureTest.java @@ -40,17 +40,17 @@ protected String getAhcEndpointUri() { } @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(getAhcEndpointUri()) .to("mock:result"); from(getTestServerEndpointUri()) .process(new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, 500); exchange.getMessage().setBody("Does not work"); } diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostDoWhileTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostDoWhileTest.java index 582a518fe55c1..14e0f3ede4df2 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostDoWhileTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostDoWhileTest.java @@ -34,10 +34,10 @@ public void testAhcDoWhile() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:start").streamCaching() .loopDoWhile(body().isNotEqualTo("done")) .to(getAhcEndpointUri()) diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostHeadersTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostHeadersTest.java index 974b7580b3f8e..18d3e28dfd656 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostHeadersTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostHeadersTest.java @@ -43,10 +43,10 @@ public void testAhcProduce() throws Exception { } @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(getAhcEndpointUri()) .to("mock:result"); diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostTest.java index eab677db2144b..a16f44f9c87b1 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostTest.java @@ -71,7 +71,7 @@ public void testAhcProduceInOut() throws Exception { } @Test - public void testAhcProduceDirectly() throws Exception { + public void testAhcProduceDirectly() { Object out = template.requestBody(getAhcEndpointUri(), "World", String.class); assertEquals("Bye World", out); } @@ -86,10 +86,10 @@ public void testAhcProducePostHeader() throws Exception { } @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(getAhcEndpointUri()) .to("mock:result"); diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceTransferExceptionTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceTransferExceptionTest.java index baa4995f2f52e..2b5c70abfc699 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceTransferExceptionTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceTransferExceptionTest.java @@ -54,10 +54,10 @@ protected String getAhcEndpointUri() { } @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(getAhcEndpointUri()) .to("mock:result"); diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceWithClientConfigUriParametersTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceWithClientConfigUriParametersTest.java index a63d1c35d4d13..c95a96f4df843 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceWithClientConfigUriParametersTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceWithClientConfigUriParametersTest.java @@ -37,17 +37,17 @@ protected String getAhcEndpointUri() { } @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(getAhcEndpointUri()) .to("mock:result"); from(getTestServerEndpointUri()) .process(new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { // redirect to test the client config worked as we told it to follow redirects exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, "301"); exchange.getMessage().setHeader("Location", getTestServerEndpointTwoUrl()); diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerConnectionCloseHeadersTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerConnectionCloseHeadersTest.java index ae16345e8d05c..5a6104b9e51b2 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerConnectionCloseHeadersTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerConnectionCloseHeadersTest.java @@ -45,10 +45,10 @@ public void testAhcProduce() throws Exception { } @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(getAhcEndpointUri() + "?connectionClose=true") .to("mock:result"); diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerSessionTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerSessionTest.java index 89e3d02304244..c221ecece6645 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerSessionTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerSessionTest.java @@ -94,10 +94,10 @@ private String getTestServerEndpointSessionUri() { } @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("ahc:" + getTestServerEndpointSessionUrl()) .to("ahc:" + getTestServerEndpointSessionUrl()) @@ -128,7 +128,7 @@ public void configure() throws Exception { from(getTestServerEndpointSessionUri()) .process(new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { HttpMessage message = exchange.getIn(HttpMessage.class); Object cookiesObj = message.getHeader("Cookie"); HttpSession session = message.getRequest().getSession(); diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerTwoParametersWithSameKeyTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerTwoParametersWithSameKeyTest.java index b5eb248ece5d2..f0508d795eb8d 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerTwoParametersWithSameKeyTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerTwoParametersWithSameKeyTest.java @@ -34,7 +34,7 @@ public class AhcProducerTwoParametersWithSameKeyTest extends BaseAhcTest { @Test - public void testTwoParametersWithSameKey() throws Exception { + public void testTwoParametersWithSameKey() { Exchange out = template.request("ahc:http://localhost:{{port}}/myapp?from=me&to=foo&to=bar", null); assertNotNull(out); @@ -44,9 +44,9 @@ public void testTwoParametersWithSameKey() throws Exception { } @Test - public void testTwoHeadersWithSameKeyHeader() throws Exception { + public void testTwoHeadersWithSameKeyHeader() { Exchange out = template.request("ahc:http://localhost:{{port}}/myapp", new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setBody(null); exchange.getIn().setHeader("from", "me"); List list = new ArrayList<>(); @@ -64,12 +64,12 @@ public void process(Exchange exchange) throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("jetty://http://localhost:{{port}}/myapp").process(new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { String from = exchange.getIn().getHeader("from", String.class); assertEquals("me", from); diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/BaseAhcTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/BaseAhcTest.java index 15a4b188031ca..3fc222d4e1ac5 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/BaseAhcTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/BaseAhcTest.java @@ -37,7 +37,7 @@ public abstract class BaseAhcTest extends CamelTestSupport { private static volatile int port; @BeforeAll - public static void initPort() throws Exception { + public static void initPort() { port = AvailablePortFinder.getNextAvailable(); } diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/javabody/AhcProduceJavaBodyTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/javabody/AhcProduceJavaBodyTest.java index 2a71c4dc2315f..0b11655c8e0f3 100644 --- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/javabody/AhcProduceJavaBodyTest.java +++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/javabody/AhcProduceJavaBodyTest.java @@ -52,10 +52,10 @@ public void testHttpSendJavaBodyAndReceiveString() throws Exception { context.addRoutes(new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(getTestServerEndpointUri()) .process(new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { MyCoolBean cool = exchange.getIn().getBody(MyCoolBean.class); assertNotNull(cool); @@ -89,10 +89,10 @@ public void testHttpSendJavaBodyAndReceiveJavaBody() throws Exception { context.addRoutes(new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(getTestServerEndpointUri()) .process(new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { MyCoolBean cool = exchange.getIn().getBody(MyCoolBean.class); assertNotNull(cool); @@ -128,10 +128,10 @@ public void testHttpSendStringAndReceiveJavaBody() throws Exception { context.addRoutes(new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(getTestServerEndpointUri()) .process(new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { String body = exchange.getIn().getBody(String.class); assertNotNull(body); assertEquals("Hello World", body); @@ -162,10 +162,10 @@ public void testNotAllowedReceive() throws Exception { context.addRoutes(new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(getTestServerEndpointUri()) .process(new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { String body = exchange.getIn().getBody(String.class); assertNotNull(body); assertEquals("Hello World", body); @@ -195,10 +195,10 @@ public void testNotAllowed() throws Exception { context.addRoutes(new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(getTestServerEndpointUri()) .process(new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { String body = exchange.getIn().getBody(String.class); assertNotNull(body); assertEquals("Hello World", body); diff --git a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java index 334ec84019304..f67a32b39f5f2 100644 --- a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java +++ b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java @@ -60,7 +60,7 @@ public class AMQPRouteTest extends CamelTestSupport { String expectedBody = "Hello there!"; @BeforeAll - public static void beforeClass() throws Exception { + public static void beforeClass() { System.setProperty(AMQPConnectionDetails.AMQP_PORT, amqpPort + ""); } diff --git a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTraceFrameTest.java b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTraceFrameTest.java index ef8193ad1c053..4fe08c8cc0f63 100644 --- a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTraceFrameTest.java +++ b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTraceFrameTest.java @@ -48,7 +48,7 @@ public class AMQPRouteTraceFrameTest extends CamelTestSupport { String expectedBody = "Hello there!"; @BeforeAll - public static void beforeClass() throws Exception { + public static void beforeClass() { System.setProperty(AMQP_PORT, amqpPort + ""); } diff --git a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDSendDynamicTest.java b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDSendDynamicTest.java index b8e6305b9cdbe..b70f696726b41 100644 --- a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDSendDynamicTest.java +++ b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDSendDynamicTest.java @@ -41,12 +41,12 @@ public class AMQPToDSendDynamicTest extends CamelTestSupport { .build(); @BeforeAll - public static void beforeClass() throws Exception { + public static void beforeClass() { System.setProperty(AMQP_PORT, amqpPort + ""); } @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"); diff --git a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDTest.java b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDTest.java index 33964498aff2c..3b4123253fb48 100644 --- a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDTest.java +++ b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDTest.java @@ -40,7 +40,7 @@ public class AMQPToDTest extends CamelTestSupport { .build(); @BeforeAll - public static void beforeClass() throws Exception { + public static void beforeClass() { System.setProperty(AMQP_PORT, amqpPort + ""); } diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentBeanRefIT.java b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentBeanRefIT.java index f9a5ecc4820e1..dfad578f354e6 100644 --- a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentBeanRefIT.java +++ b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentBeanRefIT.java @@ -30,14 +30,14 @@ public class CassandraComponentBeanRefIT extends BaseCassandra { public static final String SESSION_URI = "cql:bean:cassandraSession?cql=" + CQL; @Override - protected Registry createCamelRegistry() throws Exception { + protected Registry createCamelRegistry() { SimpleRegistry registry = new SimpleRegistry(); registry.bind("cassandraSession", getSession()); return registry; } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { from("direct:inputSession").to(SESSION_URI); @@ -46,7 +46,7 @@ public void configure() { } @Test - public void testSession() throws Exception { + public void testSession() { CassandraEndpoint endpoint = getMandatoryEndpoint(SESSION_URI, CassandraEndpoint.class); assertEquals(KEYSPACE_NAME, endpoint.getKeyspace()); diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentConsumerIT.java b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentConsumerIT.java index fc02803af71e3..28cad34ea8ae8 100644 --- a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentConsumerIT.java +++ b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentConsumerIT.java @@ -38,7 +38,7 @@ public void testConsumeAll() throws Exception { mock.expectedMinimumMessageCount(1); mock.whenAnyExchangeReceived(new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { Object body = exchange.getIn().getBody(); assertTrue(body instanceof List); } @@ -53,7 +53,7 @@ public void testConsumeUnprepared() throws Exception { mock.expectedMinimumMessageCount(1); mock.whenAnyExchangeReceived(new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { Object body = exchange.getIn().getBody(); assertTrue(body instanceof List); } @@ -68,7 +68,7 @@ public void testConsumeOne() throws Exception { mock.expectedMinimumMessageCount(1); mock.whenAnyExchangeReceived(new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { Object body = exchange.getIn().getBody(); assertTrue(body instanceof Row); } @@ -79,7 +79,7 @@ public void process(Exchange exchange) throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { from(String.format("cql://%s/%s?cql=%s", getUrl(), KEYSPACE_NAME, CQL)).to("mock:resultAll"); diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerIT.java b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerIT.java index 6545c113e3781..9e1a357329036 100644 --- a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerIT.java +++ b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerIT.java @@ -38,7 +38,6 @@ import static org.apache.camel.test.junit5.TestSupport.assertIsInstanceOf; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertNotNull; -import static org.junit.jupiter.api.Assertions.assertTrue; public class CassandraComponentProducerIT extends BaseCassandra { @@ -61,7 +60,7 @@ public class CassandraComponentProducerIT extends BaseCassandra { ProducerTemplate producerTemplateNoEndpointCql; @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { @@ -79,7 +78,7 @@ public void configure() { } @Test - public void testRequestUriCql() throws Exception { + public void testRequestUriCql() { producerTemplate.requestBody(Arrays.asList("w_jiang", "Willem", "Jiang")); ResultSet resultSet = getSession() @@ -91,7 +90,7 @@ public void testRequestUriCql() throws Exception { } @Test - public void testRequestNoParameterNull() throws Exception { + public void testRequestNoParameterNull() { Object response = noParameterProducerTemplate.requestBody(null); assertNotNull(response); @@ -99,7 +98,7 @@ public void testRequestNoParameterNull() throws Exception { } @Test - public void testRequestNoParameterEmpty() throws Exception { + public void testRequestNoParameterEmpty() { Object response = noParameterProducerTemplate.requestBody(Collections.emptyList()); assertNotNull(response); @@ -107,7 +106,7 @@ public void testRequestNoParameterEmpty() throws Exception { } @Test - public void testRequestMessageCql() throws Exception { + public void testRequestMessageCql() { producerTemplate.requestBodyAndHeader(new Object[] { "Claus 2", "Ibsen 2", "c_ibsen" }, CassandraConstants.CQL_QUERY, "update camel_user set first_name=?, last_name=? where login=?"); @@ -120,7 +119,7 @@ public void testRequestMessageCql() throws Exception { } @Test - public void testLoadBalancing() throws Exception { + public void testLoadBalancing() { loadBalancingPolicyTemplate.requestBodyAndHeader(new Object[] { "Claus 2", "Ibsen 2", "c_ibsen" }, CassandraConstants.CQL_QUERY, "update camel_user set first_name=?, last_name=? where login=?"); @@ -139,7 +138,7 @@ public void testLoadBalancing() throws Exception { * Test with incoming message containing a header with RegularStatement. */ @Test - public void testRequestMessageStatement() throws Exception { + public void testRequestMessageStatement() { Update update = QueryBuilder.update("camel_user") .setColumn("first_name", bindMarker()) @@ -161,7 +160,7 @@ public void testRequestMessageStatement() throws Exception { * the cassandracql endpoint not containing a "cql" Uri parameter */ @Test - public void testEndpointNoCqlParameter() throws Exception { + public void testEndpointNoCqlParameter() { Update update = QueryBuilder.update("camel_user") .setColumn("first_name", bindMarker()) .whereColumn("login").isEqualTo(bindMarker()); @@ -190,7 +189,7 @@ public void testEndpointNoCqlParameter() throws Exception { } @Test - public void testRequestNotConsistent() throws Exception { + public void testRequestNotConsistent() { CassandraEndpoint endpoint = getMandatoryEndpoint(String.format("cql://%s/%s?cql=%s&consistencyLevel=ANY", getUrl(), KEYSPACE_NAME, CQL), CassandraEndpoint.class); diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerUnpreparedIT.java b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerUnpreparedIT.java index 9364647deffb4..16ce29ec60b5b 100644 --- a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerUnpreparedIT.java +++ b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerUnpreparedIT.java @@ -46,7 +46,7 @@ public class CassandraComponentProducerUnpreparedIT extends BaseCassandra { ProducerTemplate noParameterProducerTemplate; @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { @@ -59,7 +59,7 @@ public void configure() { } @Test - public void testRequestUriCql() throws Exception { + public void testRequestUriCql() { producerTemplate.requestBody(Arrays.asList("w_jiang", "Willem", "Jiang")); ResultSet resultSet = getSession() @@ -71,7 +71,7 @@ public void testRequestUriCql() throws Exception { } @Test - public void testRequestNoParameterNull() throws Exception { + public void testRequestNoParameterNull() { Object response = noParameterProducerTemplate.requestBody(null); assertNotNull(response); @@ -79,7 +79,7 @@ public void testRequestNoParameterNull() throws Exception { } @Test - public void testRequestNoParameterEmpty() throws Exception { + public void testRequestNoParameterEmpty() { Object response = noParameterProducerTemplate.requestBody(null); assertNotNull(response); @@ -87,7 +87,7 @@ public void testRequestNoParameterEmpty() throws Exception { } @Test - public void testRequestMessageCql() throws Exception { + public void testRequestMessageCql() { producerTemplate.requestBodyAndHeader(new Object[] { "Claus 2", "Ibsen 2", "c_ibsen" }, CassandraConstants.CQL_QUERY, "update camel_user set first_name=?, last_name=? where login=?"); @@ -103,7 +103,7 @@ public void testRequestMessageCql() throws Exception { * Test with incoming message containing a header with RegularStatement. */ @Test - public void testRequestMessageStatement() throws Exception { + public void testRequestMessageStatement() { Update update = QueryBuilder.update("camel_user") .setColumn("first_name", literal("Claus 2")) .setColumn("last_name", literal("Ibsen 2")) diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationIT.java b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationIT.java index 2f87a4aa96018..82701ea2b53d2 100644 --- a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationIT.java +++ b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationIT.java @@ -47,10 +47,10 @@ public void tearDown() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { AggregationStrategy aggregationStrategy = new AggregationStrategy() { @Override public Exchange aggregate(Exchange oldExchange, Exchange newExchange) { diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationSerializedHeadersIT.java b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationSerializedHeadersIT.java index b17aa3c17e953..0f845ad306bee 100644 --- a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationSerializedHeadersIT.java +++ b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationSerializedHeadersIT.java @@ -49,10 +49,10 @@ public void tearDown() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { AggregationStrategy aggregationStrategy = new AggregationStrategy() { @Override public Exchange aggregate(Exchange oldExchange, Exchange newExchange) { diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentIT.java b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentIT.java index 156471b25ace8..1f5ca44e802e6 100644 --- a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentIT.java +++ b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentIT.java @@ -45,10 +45,10 @@ public void tearDown() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:input").idempotentConsumer(header("idempotentId"), idempotentRepository).to("mock:output"); } }; diff --git a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseEndpointTest.java b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseEndpointTest.java index 646def35e6a03..bf050e20bd921 100644 --- a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseEndpointTest.java +++ b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseEndpointTest.java @@ -45,7 +45,7 @@ public void testDefaultPortIsSet() throws Exception { } @Test - public void testHostnameRequired() throws Exception { + public void testHostnameRequired() { final CouchbaseComponent component = new CouchbaseComponent(); assertThrows(IllegalArgumentException.class, @@ -55,7 +55,7 @@ public void testHostnameRequired() throws Exception { } @Test - public void testSchemeRequired() throws Exception { + public void testSchemeRequired() { final CouchbaseComponent component = new CouchbaseComponent(); assertThrows(IllegalArgumentException.class, @@ -70,7 +70,7 @@ public void testCouchbaseEndpoint() { } @Test - public void testCouchbaseEndpointWithoutProtocol() throws Exception { + public void testCouchbaseEndpointWithoutProtocol() { final CouchbaseComponent component = new CouchbaseComponent(); assertThrows(IllegalArgumentException.class, @@ -85,7 +85,7 @@ public void testCouchbaseEndpointUri() { } @Test - public void testCouchbaseEndpointCreateProducer() throws Exception { + public void testCouchbaseEndpointCreateProducer() { Map params = new HashMap<>(); params.put("bucket", "bucket"); diff --git a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseProducerTest.java b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseProducerTest.java index bbc47106ad75a..bbb7ea1f1f732 100644 --- a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseProducerTest.java +++ b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseProducerTest.java @@ -74,7 +74,7 @@ public class CouchbaseProducerTest { private CouchbaseProducer producer; @BeforeEach - public void before() throws Exception { + public void before() { lenient().when(endpoint.getProducerRetryAttempts()).thenReturn(CouchbaseConstants.DEFAULT_PRODUCER_RETRIES); lenient().when(endpoint.getProducerRetryAttempts()).thenReturn(3); lenient().when(endpoint.getProducerRetryPause()).thenReturn(200); @@ -85,31 +85,31 @@ public void before() throws Exception { } @Test - public void testBodyMandatory() throws Exception { + public void testBodyMandatory() { assertThrows(CouchbaseException.class, () -> producer.process(exchange)); } @Test - public void testPersistToLowerThanSupported() throws Exception { + public void testPersistToLowerThanSupported() { assertThrows(IllegalArgumentException.class, () -> new CouchbaseProducer(endpoint, client, -1, 0)); } @Test - public void testPersistToHigherThanSupported() throws Exception { + public void testPersistToHigherThanSupported() { assertThrows(IllegalArgumentException.class, () -> new CouchbaseProducer(endpoint, client, 5, 0)); } @Test - public void testReplicateToLowerThanSupported() throws Exception { + public void testReplicateToLowerThanSupported() { assertThrows(IllegalArgumentException.class, () -> new CouchbaseProducer(endpoint, client, 0, -1)); } @Test - public void testReplicateToHigherThanSupported() throws Exception { + public void testReplicateToHigherThanSupported() { assertThrows(IllegalArgumentException.class, () -> new CouchbaseProducer(endpoint, client, 0, 4)); } diff --git a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ConsumeMessagesWithLimitIT.java b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ConsumeMessagesWithLimitIT.java index 4f58e6a54672e..0170aed8c8c76 100644 --- a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ConsumeMessagesWithLimitIT.java +++ b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ConsumeMessagesWithLimitIT.java @@ -43,10 +43,10 @@ public void cleanBucket() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(String.format("%s&designDocumentName=%s&viewName=%s&limit=10", getConnectionUri(), bucketName, bucketName)) .log("message received") .to("mock:result"); diff --git a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesSimpleIT.java b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesSimpleIT.java index 26f63c5fe1e2d..03507cef2f778 100644 --- a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesSimpleIT.java +++ b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesSimpleIT.java @@ -41,7 +41,7 @@ public void testInsert() throws Exception { protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { // need couchbase installed on localhost from("direct:start").setHeader(CouchbaseConstants.HEADER_ID, constant("SimpleDocument_1")) diff --git a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesWithAutoIDIT.java b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesWithAutoIDIT.java index 8f1fc0ca12f68..118d8f413918f 100644 --- a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesWithAutoIDIT.java +++ b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesWithAutoIDIT.java @@ -34,10 +34,10 @@ public void testInsert() throws Exception { } @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( getConnectionUri() + "&autoStartIdForInserts=true&startingIdForInsertsFrom=1000") .to("mock:result"); diff --git a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/RemoveMessagesIT.java b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/RemoveMessagesIT.java index 89510525eb3ea..3199ffbd51ff2 100644 --- a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/RemoveMessagesIT.java +++ b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/RemoveMessagesIT.java @@ -41,10 +41,10 @@ public void testDelete() throws Exception { } @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(getConnectionUri() + "&operation=" + COUCHBASE_DELETE) .to("mock:result"); diff --git a/components/camel-couchdb/src/test/java/org/apache/camel/component/couchdb/CouchDbProducerTest.java b/components/camel-couchdb/src/test/java/org/apache/camel/component/couchdb/CouchDbProducerTest.java index 276b62ab75b11..4e9ffea65ebdd 100644 --- a/components/camel-couchdb/src/test/java/org/apache/camel/component/couchdb/CouchDbProducerTest.java +++ b/components/camel-couchdb/src/test/java/org/apache/camel/component/couchdb/CouchDbProducerTest.java @@ -141,7 +141,7 @@ void testStringBodyIsConvertedToJsonTree() throws Exception { when(client.save(any())).thenAnswer(new Answer() { @Override - public Response answer(InvocationOnMock invocation) throws Throwable { + public Response answer(InvocationOnMock invocation) { assertTrue(invocation.getArguments()[0] instanceof JsonElement, invocation.getArguments()[0].getClass() + " but wanted " + JsonElement.class); return new Response(); diff --git a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/ElasticsearchRestComponentVerifierExtensionTest.java b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/ElasticsearchRestComponentVerifierExtensionTest.java index 494efeea01f8c..19b3ce8208339 100644 --- a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/ElasticsearchRestComponentVerifierExtensionTest.java +++ b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/ElasticsearchRestComponentVerifierExtensionTest.java @@ -33,7 +33,7 @@ public boolean isUseRouteBuilder() { } @Test - public void testParameters() throws Exception { + public void testParameters() { Component component = context().getComponent("elasticsearch-rest"); ComponentVerifierExtension verifier @@ -49,7 +49,7 @@ public void testParameters() throws Exception { } @Test - public void testConnectivity() throws Exception { + public void testConnectivity() { Component component = context().getComponent("elasticsearch-rest"); ComponentVerifierExtension verifier = component.getExtension(ComponentVerifierExtension.class).orElseThrow(IllegalStateException::new); diff --git a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchBulkIT.java b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchBulkIT.java index 3d60ecaf02a67..df5e3617db457 100644 --- a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchBulkIT.java +++ b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchBulkIT.java @@ -37,7 +37,7 @@ public class ElasticsearchBulkIT extends ElasticsearchTestSupport { @Test - public void testBulkIndex() throws Exception { + public void testBulkIndex() { List> documents = new ArrayList<>(); Map document1 = createIndexedData("1"); Map document2 = createIndexedData("2"); @@ -51,7 +51,7 @@ public void testBulkIndex() throws Exception { } @Test - public void bulkIndexListRequestBody() throws Exception { + public void bulkIndexListRequestBody() { String prefix = createPrefix(); // given @@ -70,7 +70,7 @@ public void bulkIndexListRequestBody() throws Exception { } @Test - public void bulkIndexRequestBody() throws Exception { + public void bulkIndexRequestBody() { String prefix = createPrefix(); // given @@ -90,7 +90,7 @@ public void bulkIndexRequestBody() throws Exception { } @Test - public void bulkRequestBody() throws Exception { + public void bulkRequestBody() { String prefix = createPrefix(); // given @@ -107,7 +107,7 @@ public void bulkRequestBody() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override public void configure() { diff --git a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchClusterIndexIT.java b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchClusterIndexIT.java index b77e6a810d70f..cddeae31cb9e5 100644 --- a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchClusterIndexIT.java +++ b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchClusterIndexIT.java @@ -72,7 +72,7 @@ public void indexWithSnifferEnable() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override public void configure() { diff --git a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchGetSearchDeleteExistsUpdateIT.java b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchGetSearchDeleteExistsUpdateIT.java index 911b736072d59..4c6e17ba79c31 100644 --- a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchGetSearchDeleteExistsUpdateIT.java +++ b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchGetSearchDeleteExistsUpdateIT.java @@ -46,7 +46,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTestSupport { @Test - public void testGet() throws Exception { + public void testGet() { //first, Index a value Map map = createIndexedData(); sendBody("direct:index", map); @@ -60,7 +60,7 @@ public void testGet() throws Exception { } @Test - public void testDelete() throws Exception { + public void testDelete() { //first, Index a value Map map = createIndexedData(); sendBody("direct:index", map); @@ -83,7 +83,7 @@ public void testDelete() throws Exception { } @Test - public void testSearchWithMapQuery() throws Exception { + public void testSearchWithMapQuery() { //first, Index a value Map map = createIndexedData(); String indexId = template.requestBody("direct:index", map, String.class); @@ -106,7 +106,7 @@ public void testSearchWithMapQuery() throws Exception { } @Test - public void testSearchWithStringQuery() throws Exception { + public void testSearchWithStringQuery() { //first, Index a value Map map = createIndexedData(); String indexId = template.requestBody("direct:index", map, String.class); @@ -132,7 +132,7 @@ public void testSearchWithStringQuery() throws Exception { } @Test - public void testMultiSearch() throws Exception { + public void testMultiSearch() { //first, Index a value Map map = createIndexedData(); String indexId = template.requestBody("direct:index", map, String.class); @@ -156,7 +156,7 @@ public void testMultiSearch() throws Exception { } @Test - public void testUpdate() throws Exception { + public void testUpdate() { Map map = createIndexedData(); String indexId = template.requestBody("direct:index", map, String.class); assertNotNull(indexId, "indexId should be set"); @@ -170,7 +170,7 @@ public void testUpdate() throws Exception { } @Test - public void testGetWithHeaders() throws Exception { + public void testGetWithHeaders() { //first, Index a value Map map = createIndexedData(); Map headers = new HashMap<>(); @@ -187,7 +187,7 @@ public void testGetWithHeaders() throws Exception { } @Test - public void testExistsWithHeaders() throws Exception { + public void testExistsWithHeaders() { //first, Index a value Map map = createIndexedData(); Map headers = new HashMap<>(); @@ -205,7 +205,7 @@ public void testExistsWithHeaders() throws Exception { } @Test - public void testNotExistsWithHeaders() throws Exception { + public void testNotExistsWithHeaders() { //first, Index a value Map map = createIndexedData(); Map headers = new HashMap<>(); @@ -223,7 +223,7 @@ public void testNotExistsWithHeaders() throws Exception { } @Test - public void testDeleteWithHeaders() throws Exception { + public void testDeleteWithHeaders() { //first, Index a value Map map = createIndexedData(); Map headers = new HashMap<>(); @@ -252,7 +252,7 @@ public void testDeleteWithHeaders() throws Exception { } @Test - public void testUpdateWithIDInHeader() throws Exception { + public void testUpdateWithIDInHeader() { Map map = createIndexedData(); Map headers = new HashMap<>(); headers.put(ElasticsearchConstants.PARAM_OPERATION, ElasticsearchOperation.Index); @@ -271,7 +271,7 @@ public void testUpdateWithIDInHeader() throws Exception { } @Test - public void getRequestBody() throws Exception { + public void getRequestBody() { String prefix = createPrefix(); // given @@ -292,7 +292,7 @@ public void getRequestBody() throws Exception { } @Test - public void deleteRequestBody() throws Exception { + public void deleteRequestBody() { String prefix = createPrefix(); // given @@ -311,7 +311,7 @@ public void deleteRequestBody() throws Exception { } @Test - public void testStringUpdate() throws Exception { + public void testStringUpdate() { Map map = createIndexedData(); String indexId = template.requestBody("direct:index", map, String.class); assertNotNull(indexId, "indexId should be set"); @@ -328,7 +328,7 @@ public void testStringUpdate() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override public void configure() { diff --git a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchIndexIT.java b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchIndexIT.java index c6675485de7a6..850c1b684f098 100644 --- a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchIndexIT.java +++ b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchIndexIT.java @@ -31,14 +31,14 @@ public class ElasticsearchIndexIT extends ElasticsearchTestSupport { @Test - public void testIndex() throws Exception { + public void testIndex() { Map map = createIndexedData(); String indexId = template.requestBody("direct:index", map, String.class); assertNotNull(indexId, "indexId should be set"); } @Test - public void testIndexDelete() throws Exception { + public void testIndexDelete() { Map map = createIndexedData(); String indexId = template.requestBody("direct:index", map, String.class); assertNotNull(indexId, "indexId should be set"); @@ -49,14 +49,14 @@ public void testIndexDelete() throws Exception { } @Test - public void testIndexWithReplication() throws Exception { + public void testIndexWithReplication() { Map map = createIndexedData(); String indexId = template.requestBody("direct:indexWithReplication", map, String.class); assertNotNull(indexId, "indexId should be set"); } @Test - public void testIndexWithHeaders() throws Exception { + public void testIndexWithHeaders() { Map map = createIndexedData(); Map headers = new HashMap<>(); headers.put(ElasticsearchConstants.PARAM_OPERATION, ElasticsearchOperation.Index); @@ -67,7 +67,7 @@ public void testIndexWithHeaders() throws Exception { } @Test - public void testIndexWithIDInHeader() throws Exception { + public void testIndexWithIDInHeader() { Map map = createIndexedData(); Map headers = new HashMap<>(); headers.put(ElasticsearchConstants.PARAM_OPERATION, ElasticsearchOperation.Index); @@ -80,7 +80,7 @@ public void testIndexWithIDInHeader() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override public void configure() { diff --git a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchPingIT.java b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchPingIT.java index 312fd769de0a2..689827dfb517e 100644 --- a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchPingIT.java +++ b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchPingIT.java @@ -24,13 +24,13 @@ public class ElasticsearchPingIT extends ElasticsearchTestSupport { @Test - public void testPing() throws Exception { + public void testPing() { boolean pingResult = template.requestBody("direct:ping", "test", Boolean.class); assertTrue(pingResult, "indexId should be set"); } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override public void configure() { diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java index b95efcb7952e4..53cc17503d31e 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java @@ -36,7 +36,7 @@ public class KafkaComponentTest extends CamelTestSupport { @Test - public void testPropertiesSet() throws Exception { + public void testPropertiesSet() { String uri = "kafka:mytopic?brokers=broker1:12345,broker2:12566&partitioner=com.class.Party"; KafkaEndpoint endpoint = context.getEndpoint(uri, KafkaEndpoint.class); @@ -46,7 +46,7 @@ public void testPropertiesSet() throws Exception { } @Test - public void testBrokersOnComponent() throws Exception { + public void testBrokersOnComponent() { KafkaComponent kafka = context.getComponent("kafka", KafkaComponent.class); kafka.getConfiguration().setBrokers("broker1:12345,broker2:12566"); @@ -255,7 +255,7 @@ private void setProducerProperty(Map params) { } @Test - public void testCreateProducerConfigTruststorePassword() throws Exception { + public void testCreateProducerConfigTruststorePassword() { KeyStoreParameters keyStoreParameters = new KeyStoreParameters(); keyStoreParameters.setPassword("my-password"); @@ -275,7 +275,7 @@ public void testCreateProducerConfigTruststorePassword() throws Exception { } @Test - public void testCreateConsumerConfigTruststorePassword() throws Exception { + public void testCreateConsumerConfigTruststorePassword() { KeyStoreParameters keyStoreParameters = new KeyStoreParameters(); keyStoreParameters.setPassword("my-password"); diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java index 71712641c93a2..426f12b2d9f5f 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java @@ -38,7 +38,7 @@ public class KafkaConsumerTest { private ExchangeFactory ef = mock(ExchangeFactory.class); @Test - public void consumerRequiresBootstrapServers() throws Exception { + public void consumerRequiresBootstrapServers() { when(endpoint.getCamelContext()).thenReturn(ecc); when(ecc.adapt(ExtendedCamelContext.class)).thenReturn(ecc); when(ecc.getExchangeFactory()).thenReturn(ef); @@ -55,7 +55,7 @@ public void consumerRequiresBootstrapServers() throws Exception { } @Test - public void consumerOnlyRequiresBootstrapServers() throws Exception { + public void consumerOnlyRequiresBootstrapServers() { when(endpoint.getCamelContext()).thenReturn(ecc); when(ecc.adapt(ExtendedCamelContext.class)).thenReturn(ecc); when(ecc.getExchangeFactory()).thenReturn(ef); diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java index ec2750d1be4f7..3261e2a459ab4 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java @@ -107,7 +107,7 @@ public KafkaProducerTest() throws Exception { } @Test - public void testPropertyBuilder() throws Exception { + public void testPropertyBuilder() { Properties props = producer.getProps(); assertEquals("broker1:1234,broker2:4567", props.getProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG)); } @@ -142,7 +142,7 @@ public void processSendsMessageWithException() { } @Test - public void processAsyncSendsMessage() throws Exception { + public void processAsyncSendsMessage() { endpoint.getConfiguration().setTopic("sometopic"); Mockito.when(exchange.getIn()).thenReturn(in); Mockito.when(exchange.getMessage()).thenReturn(in); diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java index 6f2a6425bd2b8..dc82ca2104c66 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java @@ -73,7 +73,7 @@ public void after() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBatchSizeIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBatchSizeIT.java index b3b366b21f3bf..222981191f97b 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBatchSizeIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBatchSizeIT.java @@ -56,10 +56,10 @@ public void after() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(from).routeId("foo").to(to).setId("First"); } }; diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java index f7724234d2a00..2e0792e5fdb3a 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java @@ -16,7 +16,6 @@ */ package org.apache.camel.component.kafka.integration; -import java.io.IOException; import java.util.Collections; import java.util.Map; import java.util.Properties; @@ -84,7 +83,7 @@ public void after() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override @@ -97,7 +96,7 @@ public void configure() { @Order(3) @Test - public void kafkaMessageIsConsumedByCamel() throws InterruptedException, IOException { + public void kafkaMessageIsConsumedByCamel() throws InterruptedException { String propagatedHeaderKey = "PropagatedCustomHeader"; byte[] propagatedHeaderValue = "propagated header value".getBytes(); String skippedHeaderKey = "CamelSkippedHeader"; @@ -128,7 +127,7 @@ public void kafkaMessageIsConsumedByCamel() throws InterruptedException, IOExcep @Order(2) @Test - public void kafkaRecordSpecificHeadersAreNotOverwritten() throws InterruptedException, IOException { + public void kafkaRecordSpecificHeadersAreNotOverwritten() throws InterruptedException { String propagatedHeaderKey = KafkaConstants.TOPIC; byte[] propagatedHeaderValue = "propagated incorrect topic".getBytes(); to.expectedHeaderReceived(KafkaConstants.TOPIC, TOPIC); diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java index d5e973ca99951..a115113856e1e 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java @@ -16,7 +16,6 @@ */ package org.apache.camel.component.kafka.integration; -import java.io.IOException; import java.util.Collection; import java.util.Collections; import java.util.Map; @@ -110,7 +109,7 @@ protected CamelContext createCamelContext() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override @@ -123,7 +122,7 @@ public void configure() { @Order(1) @Test - public void kafkaConsumerHealthCheck() throws InterruptedException, IOException { + public void kafkaConsumerHealthCheck() throws InterruptedException { // health-check liveness should be UP Collection res = HealthCheckHelper.invokeLiveness(context); boolean up = res.stream().allMatch(r -> r.getState().equals(HealthCheck.State.UP)); diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java index b954fa43e0fa9..2976de3d4338f 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java @@ -17,8 +17,6 @@ package org.apache.camel.component.kafka.integration; import java.util.Arrays; -import java.util.concurrent.ExecutionException; -import java.util.concurrent.TimeoutException; import org.apache.camel.BindToRegistry; import org.apache.camel.Endpoint; @@ -57,7 +55,7 @@ public class KafkaConsumerIdempotentIT extends KafkaConsumerIdempotentTestSuppor private int size = 200; @BeforeEach - public void before() throws ExecutionException, InterruptedException, TimeoutException { + public void before() { kafkaAdminClient.deleteTopics(Arrays.asList(TOPIC, "TEST_IDEMPOTENT")).all(); doSend(size, TOPIC); } @@ -68,12 +66,12 @@ public void after() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(from).routeId("foo") .idempotentConsumer(numericHeader("id")) .idempotentRepository("kafkaIdempotentRepository") diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java index 2608054bc6548..2e80a8d23b76d 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java @@ -17,8 +17,6 @@ package org.apache.camel.component.kafka.integration; import java.util.Arrays; -import java.util.concurrent.ExecutionException; -import java.util.concurrent.TimeoutException; import org.apache.camel.BindToRegistry; import org.apache.camel.Endpoint; @@ -53,7 +51,7 @@ public class KafkaConsumerIdempotentWithCustomSerializerIT extends KafkaConsumer private int size = 200; @BeforeEach - public void before() throws ExecutionException, InterruptedException, TimeoutException { + public void before() { kafkaIdempotentRepository.clear(); kafkaAdminClient.deleteTopics(Arrays.asList(TOPIC, "TEST_IDEMPOTENT")).all(); doSend(size, TOPIC); @@ -65,7 +63,7 @@ public void after() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java index 95dc245a842a9..4a5f9ff685f7c 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java @@ -18,8 +18,6 @@ import java.math.BigInteger; import java.util.Arrays; -import java.util.concurrent.ExecutionException; -import java.util.concurrent.TimeoutException; import org.apache.camel.BindToRegistry; import org.apache.camel.Endpoint; @@ -52,7 +50,7 @@ public class KafkaConsumerIdempotentWithProcessorIT extends KafkaConsumerIdempot private int size = 200; @BeforeEach - public void before() throws ExecutionException, InterruptedException, TimeoutException { + public void before() { kafkaIdempotentRepository.clear(); kafkaAdminClient.deleteTopics(Arrays.asList(TOPIC, "TEST_IDEMPOTENT")).all(); doSend(size, TOPIC); @@ -65,12 +63,12 @@ public void after() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(from).routeId("idemp-with-prop") .process(exchange -> { byte[] id = exchange.getIn().getHeader("id", byte[].class); diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerLastRecordHeaderIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerLastRecordHeaderIT.java index 13ec66442ac92..5d30d5e0b71b9 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerLastRecordHeaderIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerLastRecordHeaderIT.java @@ -84,10 +84,10 @@ public void shouldStartFromBeginningWithEmptyOffsetRepository() throws Interrupt } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("kafka:" + TOPIC + "?groupId=A&autoOffsetReset=earliest&autoCommitEnable=false").to("mock:result"); } }; diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerManualCommitIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerManualCommitIT.java index 5334aa5de2ee6..e57e25f8800f6 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerManualCommitIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerManualCommitIT.java @@ -65,11 +65,11 @@ public void after() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(from).routeId("foo").to(to).process(e -> { KafkaManualCommit manual = e.getIn().getHeader(KafkaConstants.MANUAL_COMMIT, KafkaManualCommit.class); assertNotNull(manual); diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerRebalanceIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerRebalanceIT.java index 4fbef30ec3c15..b56211ff66d05 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerRebalanceIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerRebalanceIT.java @@ -43,7 +43,7 @@ public class KafkaConsumerRebalanceIT extends BaseEmbeddedKafkaTestSupport { private CountDownLatch messagesLatch; @Override - protected void doPreSetup() throws Exception { + protected void doPreSetup() { messagesLatch = new CountDownLatch(1); stateRepository = new OffsetStateRepository(messagesLatch); } @@ -63,10 +63,10 @@ public void after() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("kafka:" + TOPIC + "?groupId=" + TOPIC + "_GROUP" + "&autoCommitIntervalMs=1000" + "&autoOffsetReset=latest" + "&consumersCount=1" + "&offsetRepository=#offset").routeId("consumer-rebalance-route").to("mock:result"); diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java index 5c4702a308f05..ebe39dcd0e619 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java @@ -65,11 +65,11 @@ public void after() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from(from).to(to); } }; diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerWithResumeRouteStrategyIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerWithResumeRouteStrategyIT.java index dbc9d9168474d..02bccecfb5af0 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerWithResumeRouteStrategyIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerWithResumeRouteStrategyIT.java @@ -216,10 +216,10 @@ public void after() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("kafka:" + TOPIC + "?groupId=" + TOPIC + "_GROUP&autoCommitIntervalMs=1000" + "&autoOffsetReset=earliest&consumersCount=1") .routeId("resume-strategy-route") diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java index e62fe61a05578..c17cd47ae774c 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java @@ -16,7 +16,6 @@ */ package org.apache.camel.component.kafka.integration; -import java.io.IOException; import java.nio.ByteBuffer; import java.time.Duration; import java.util.ArrayList; @@ -141,10 +140,10 @@ public static void after() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:startStrings").to(toStrings).to(mockEndpoint); from("direct:startStrings2").to(toStrings2).to(mockEndpoint); @@ -161,7 +160,7 @@ public void configure() throws Exception { } @Test - public void producedStringMessageIsReceivedByKafka() throws InterruptedException, IOException { + public void producedStringMessageIsReceivedByKafka() throws InterruptedException { int messageInTopic = 10; int messageInOtherTopic = 5; @@ -192,7 +191,7 @@ public void producedStringMessageIsReceivedByKafka() throws InterruptedException } @Test - public void producedString2MessageIsReceivedByKafka() throws InterruptedException, IOException { + public void producedString2MessageIsReceivedByKafka() throws InterruptedException { int messageInTopic = 10; int messageInOtherTopic = 5; @@ -223,7 +222,7 @@ public void producedString2MessageIsReceivedByKafka() throws InterruptedExceptio } @Test - public void producedStringMessageIsIntercepted() throws InterruptedException, IOException { + public void producedStringMessageIsIntercepted() throws InterruptedException { int messageInTopic = 10; int messageInOtherTopic = 5; @@ -244,7 +243,7 @@ public void producedStringMessageIsIntercepted() throws InterruptedException, IO } @Test - public void producedStringCollectionMessageIsReceivedByKafka() throws InterruptedException, IOException { + public void producedStringCollectionMessageIsReceivedByKafka() throws InterruptedException { int messageInTopic = 10; int messageInOtherTopic = 5; @@ -290,7 +289,7 @@ public void producedStringCollectionMessageIsReceivedByKafka() throws Interrupte } @Test - public void producedBytesMessageIsReceivedByKafka() throws InterruptedException, IOException { + public void producedBytesMessageIsReceivedByKafka() throws InterruptedException { int messageInTopic = 10; int messageInOtherTopic = 5; diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaToDIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaToDIT.java index 5037895773dfb..8234d5c312dcf 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaToDIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaToDIT.java @@ -24,7 +24,7 @@ public class KafkaToDIT extends BaseEmbeddedKafkaTestSupport { @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"); @@ -34,10 +34,10 @@ public void testToD() throws Exception { } @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("kafka://${header.where}"); } diff --git a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java index 9fb1e4e8d9691..a859306c64101 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java @@ -46,10 +46,10 @@ public class KafkaIdempotentRepositoryEagerIT extends BaseEmbeddedKafkaTestSuppo private MockEndpoint mockBefore; @Override - protected RoutesBuilder createRouteBuilder() throws Exception { + protected RoutesBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:in").to("mock:before").idempotentConsumer(header("id")) .idempotentRepository("kafkaIdempotentRepository").to("mock:out").end(); } @@ -57,7 +57,7 @@ public void configure() throws Exception { } @Test - public void testRemovesDuplicates() throws InterruptedException { + public void testRemovesDuplicates() { for (int i = 0; i < 10; i++) { template.sendBodyAndHeader("direct:in", "Test message", "id", i % 5); } @@ -69,7 +69,7 @@ public void testRemovesDuplicates() throws InterruptedException { } @Test - public void testRollsBackOnException() throws InterruptedException { + public void testRollsBackOnException() { mockOut.whenAnyExchangeReceived(exchange -> { int id = exchange.getIn().getHeader("id", Integer.class); if (id == 0) { diff --git a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java index a4f369046f394..ba3563f2f98ee 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java @@ -48,10 +48,10 @@ public class KafkaIdempotentRepositoryNonEagerIT extends BaseEmbeddedKafkaTestSu private MockEndpoint mockBefore; @Override - protected RoutesBuilder createRouteBuilder() throws Exception { + protected RoutesBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:in").to("mock:before").idempotentConsumer(header("id")) .idempotentRepository("kafkaIdempotentRepository").eager(false).to("mock:out").end(); } @@ -59,7 +59,7 @@ public void configure() throws Exception { } @Test - public void testRemovesDuplicates() throws InterruptedException { + public void testRemovesDuplicates() { for (int i = 0; i < 10; i++) { template.sendBodyAndHeader("direct:in", "Test message", "id", i % 5); } @@ -71,7 +71,7 @@ public void testRemovesDuplicates() throws InterruptedException { } @Test - public void testRollsBackOnException() throws InterruptedException { + public void testRollsBackOnException() { mockOut.whenAnyExchangeReceived(exchange -> { int id = exchange.getIn().getHeader("id", Integer.class); if (id == 0) { diff --git a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java index 98b82f7f22b33..dfb8d8e23021f 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java @@ -65,7 +65,7 @@ void clearTopics() { } @Override - protected RoutesBuilder createRouteBuilder() throws Exception { + protected RoutesBuilder createRouteBuilder() { return new RouteBuilder() { @Override public void configure() { diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointClientTest.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointClientTest.java index abff7fff21a62..befd5790afe18 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointClientTest.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointClientTest.java @@ -27,7 +27,7 @@ class MongoDbEndpointClientTest extends CamelTestSupport { @Override - protected void bindToRegistry(Registry registry) throws Exception { + protected void bindToRegistry(Registry registry) { registry.bind("mongoClient", MongoClients.create("mongodb://localhost")); } @@ -44,10 +44,10 @@ void testMongoDbEndpoint() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:dbFromBean").to("mongodb:mongoClient?database=test&collection=test&operation=findAll"); } }; diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointHostsTest.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointHostsTest.java index ac07211976070..35b9927755ab1 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointHostsTest.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointHostsTest.java @@ -37,10 +37,10 @@ void testMongoDbEndpoint() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:dbFromHost").to("mongodb:dummy?hosts=localhost&database=test&collection=test&operation=findAll"); } }; diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbAggregateOperationIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbAggregateOperationIT.java index dcd9e97e6ed9a..9a8b0b33012a7 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbAggregateOperationIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbAggregateOperationIT.java @@ -34,7 +34,7 @@ public class MongoDbAggregateOperationIT extends AbstractMongoDbITSupport { @Test - public void testAggregate() throws Exception { + public void testAggregate() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -111,7 +111,7 @@ public void testAggregateWithOptions() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { from("direct:aggregate") diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBigDecimalConverterIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBigDecimalConverterIT.java index 0e10c5dcd1499..6cad896105e19 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBigDecimalConverterIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBigDecimalConverterIT.java @@ -53,7 +53,7 @@ public void testBigDecimalAutoConversion() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { from("direct:insert") diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBulkWriteOperationIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBulkWriteOperationIT.java index 0bb1a65fe7d9d..7c9599308a440 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBulkWriteOperationIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBulkWriteOperationIT.java @@ -40,7 +40,7 @@ public class MongoDbBulkWriteOperationIT extends AbstractMongoDbITSupport { @Test - public void testBulkWrite() throws Exception { + public void testBulkWrite() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -69,7 +69,7 @@ public void testBulkWrite() throws Exception { } @Test - public void testOrderedBulkWriteWithError() throws Exception { + public void testOrderedBulkWriteWithError() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -94,7 +94,7 @@ public void testOrderedBulkWriteWithError() throws Exception { } @Test - public void testUnorderedBulkWriteWithError() throws Exception { + public void testUnorderedBulkWriteWithError() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -118,7 +118,7 @@ public void testUnorderedBulkWriteWithError() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { from("direct:bulkWrite").to( diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConnectionBeansIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConnectionBeansIT.java index 5a10501f9dc57..0fca614c27a7b 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConnectionBeansIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConnectionBeansIT.java @@ -77,7 +77,7 @@ public void checkMissingConnection() { } @Test - public void checkConnectionOnComponent() throws Exception { + public void checkConnectionOnComponent() { Endpoint endpoint = context.getEndpoint("mongodb:justARouteName"); assertIsInstanceOf(MongoDbEndpoint.class, endpoint); diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConversionsIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConversionsIT.java index 7a39f20e79292..1dab32f58406c 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConversionsIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConversionsIT.java @@ -37,7 +37,7 @@ public class MongoDbConversionsIT extends AbstractMongoDbITSupport { @Test - public void testInsertMap() throws InterruptedException { + public void testInsertMap() { assertEquals(0, testCollection.countDocuments()); Map m1 = new HashMap<>(); @@ -111,7 +111,7 @@ public void testInsertBsonInputStream() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { @@ -140,7 +140,7 @@ private class MyPojoTest { } @Test - public void shouldConvertJsonStringListToBSONList() throws InterruptedException { + public void shouldConvertJsonStringListToBSONList() { String jsonListArray = "[{\"key\":\"value1\"}, {\"key\":\"value2\"}]"; List bsonList = MongoDbBasicConverters.fromStringToList(jsonListArray); assertNotNull(bsonList); @@ -153,7 +153,7 @@ public void shouldConvertJsonStringListToBSONList() throws InterruptedException } @Test - public void shouldNotConvertJsonStringListToBSONList() throws InterruptedException { + public void shouldNotConvertJsonStringListToBSONList() { String jsonSingleValue = "{\"key\":\"value1\"}"; List bsonList = MongoDbBasicConverters.fromStringToList(jsonSingleValue); assertNull(bsonList); diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbCredentialsFromUriConnectionIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbCredentialsFromUriConnectionIT.java index 212d919505ebe..71ee0a24e83b1 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbCredentialsFromUriConnectionIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbCredentialsFromUriConnectionIT.java @@ -42,7 +42,7 @@ public void doPreSetup() throws Exception { } @Override - protected CamelContext createCamelContext() throws Exception { + protected CamelContext createCamelContext() { //This is necessary to avoid creating connection bean for the mongodb component and test credentials instead @SuppressWarnings("deprecation") CamelContext ctx = new DefaultCamelContext(); @@ -67,7 +67,7 @@ public void testCountOperationAuthUser() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbDynamicityIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbDynamicityIT.java index 0db7eaf2af5ac..82092fc5ba9b4 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbDynamicityIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbDynamicityIT.java @@ -149,7 +149,7 @@ public void testInsertDynamicityEnabledDBAndCollection() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbExceptionHandlingIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbExceptionHandlingIT.java index fd5fad57117b7..1ccfcb231dfd6 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbExceptionHandlingIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbExceptionHandlingIT.java @@ -29,7 +29,7 @@ public class MongoDbExceptionHandlingIT extends AbstractMongoDbITSupport { @Test - public void testInduceParseException() throws Exception { + public void testInduceParseException() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -44,7 +44,7 @@ public void testInduceParseException() throws Exception { } @Test - public void testInduceParseAndThenOkException() throws Exception { + public void testInduceParseAndThenOkException() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -64,7 +64,7 @@ public void testInduceParseAndThenOkException() throws Exception { } @Test - public void testErroneousDynamicOperation() throws Exception { + public void testErroneousDynamicOperation() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -80,7 +80,7 @@ public void testErroneousDynamicOperation() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbFindOperationIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbFindOperationIT.java index 4b5b77be95f80..70b1abdd82c45 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbFindOperationIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbFindOperationIT.java @@ -98,7 +98,7 @@ protected void doPostSetup() { } @Override - protected CamelContext createCamelContext() throws Exception { + protected CamelContext createCamelContext() { MongoDbComponent component = new MongoDbComponent(); component.setMongoConnection(mongo); @@ -128,7 +128,7 @@ protected void pumpDataIntoTestCollection() { } @Test - public void testFindAllNoCriteriaOperation() throws Exception { + public void testFindAllNoCriteriaOperation() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -158,7 +158,7 @@ public void testFindAllNoCriteriaOperation() throws Exception { } @Test - public void testFindAllAllowDiskUse() throws Exception { + public void testFindAllAllowDiskUse() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -179,7 +179,7 @@ public void testFindAllAllowDiskUse() throws Exception { } @Test - public void testFindAllWithQueryAndNoFIlter() throws Exception { + public void testFindAllWithQueryAndNoFIlter() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -207,7 +207,7 @@ public void testFindAllWithQueryAndNoFIlter() throws Exception { } @Test - public void testFindAllWithQueryAndFilter() throws Exception { + public void testFindAllWithQueryAndFilter() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -236,7 +236,7 @@ public void testFindAllWithQueryAndFilter() throws Exception { } @Test - public void testFindAllNoCriteriaWithFilterOperation() throws Exception { + public void testFindAllNoCriteriaWithFilterOperation() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -267,7 +267,7 @@ public void testFindAllNoCriteriaWithFilterOperation() throws Exception { } @Test - public void testFindAllIterationOperation() throws Exception { + public void testFindAllIterationOperation() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -343,7 +343,7 @@ public void testFindDistinctWithQuery() { } @Test - public void testFindOneByQuery() throws Exception { + public void testFindOneByQuery() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -359,7 +359,7 @@ public void testFindOneByQuery() throws Exception { } @Test - public void testFindOneById() throws Exception { + public void testFindOneById() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -377,7 +377,7 @@ public void testFindOneById() throws Exception { } @Test - public void testFindOneByIdWithObjectId() throws Exception { + public void testFindOneByIdWithObjectId() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); Document insertObject = new Document("scientist", "Einstein"); @@ -398,7 +398,7 @@ public void testFindOneByIdWithObjectId() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbHeaderHandlingIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbHeaderHandlingIT.java index f79f4f74409a3..c80a5ea77aad4 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbHeaderHandlingIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbHeaderHandlingIT.java @@ -39,7 +39,7 @@ public void testInHeadersTransferredToOutOnCount() { assertEquals(0, testCollection.countDocuments()); Exchange result = template.request("direct:count", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setBody("irrelevant body"); exchange.getIn().setHeader("abc", "def"); } @@ -53,7 +53,7 @@ public void process(Exchange exchange) throws Exception { public void testInHeadersTransferredToOutOnInsert() { Exchange result = template.request("direct:insert", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setBody("{\"_id\":\"testInsertString\", \"scientist\":\"Einstein\"}"); exchange.getIn().setHeader("abc", "def"); } @@ -87,7 +87,7 @@ public void testWriteResultAsHeaderWithWriteOp() { // with the CamelMongoDbWriteResult header Exchange resultExch = template.request("direct:save", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setBody(record1); } }); @@ -105,7 +105,7 @@ public void process(Exchange exchange) throws Exception { public void testWriteResultAsHeaderWithReadOp() { Exchange resultExch = template.request("direct:getDbStats", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setBody("irrelevantBody"); exchange.getIn().setHeader("abc", "def"); } @@ -116,7 +116,7 @@ public void process(Exchange exchange) throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbIndexIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbIndexIT.java index 16b7be4d62216..7058596471d72 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbIndexIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbIndexIT.java @@ -203,7 +203,7 @@ public void testInsertAutoCreateCollectionAndURIIndex() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { from("direct:dynamicityEnabled").to( diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbInsertBatchIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbInsertBatchIT.java index 8d60e5260e620..b5d4a53a71ae4 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbInsertBatchIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbInsertBatchIT.java @@ -64,7 +64,7 @@ public void testInsertBatch() { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { from("direct:insert") diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOperationsIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOperationsIT.java index cc7cd930eb4a7..d5d77825cd260 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOperationsIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOperationsIT.java @@ -53,7 +53,7 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport { @Test - public void testCountOperation() throws Exception { + public void testCountOperation() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); Object result = template.requestBody("direct:count", "irrelevantBody"); @@ -77,7 +77,7 @@ public void testCountOperation() throws Exception { } @Test - public void testInsertString() throws Exception { + public void testInsertString() { assertEquals(0, testCollection.countDocuments()); Object result = template.requestBody("direct:insert", new Document(MONGO_ID, "testInsertString").append("scientist", "Einstein").toJson()); @@ -87,14 +87,14 @@ public void testInsertString() throws Exception { } @Test - public void testStoreOidOnInsert() throws Exception { + public void testStoreOidOnInsert() { Document document = new Document(); ObjectId oid = template.requestBody("direct:testStoreOidOnInsert", document, ObjectId.class); assertEquals(document.get(MONGO_ID), oid); } @Test - public void testStoreOidsOnInsert() throws Exception { + public void testStoreOidsOnInsert() { Document firsDocument = new Document(); Document secondDoocument = new Document(); List oids @@ -104,7 +104,7 @@ public void testStoreOidsOnInsert() throws Exception { } @Test - public void testSave() throws Exception { + public void testSave() { // Prepare test assertEquals(0, testCollection.countDocuments()); Object[] req = new Object[] { @@ -149,21 +149,21 @@ public void testSaveWithoutId() { } @Test - public void testStoreOidOnSaveWithoutId() throws Exception { + public void testStoreOidOnSaveWithoutId() { Document document = new Document(); ObjectId oid = template.requestBody("direct:testStoreOidOnSave", document, ObjectId.class); assertNotNull(oid); } @Test - public void testStoreOidOnSave() throws Exception { + public void testStoreOidOnSave() { Document document = new Document(MONGO_ID, new ObjectId("5847e39e0824d6b54194e197")); ObjectId oid = template.requestBody("direct:testStoreOidOnSave", document, ObjectId.class); assertEquals(document.get(MONGO_ID), oid); } @Test - public void testUpdate() throws Exception { + public void testUpdate() { // Prepare test assertEquals(0, testCollection.countDocuments()); for (int i = 1; i <= 100; i++) { @@ -191,7 +191,7 @@ public void testUpdate() throws Exception { Exchange resultExchange = template.request("direct:update", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setBody(new Bson[] { extraField, updateObj }); exchange.getIn().setHeader(MongoDbConstants.MULTIUPDATE, true); } @@ -206,7 +206,7 @@ public void process(Exchange exchange) throws Exception { } @Test - public void testUpdateFromString() throws Exception { + public void testUpdateFromString() { // Prepare test assertEquals(0, testCollection.countDocuments()); for (int i = 1; i <= 100; i++) { @@ -238,7 +238,7 @@ public void testUpdateFromString() throws Exception { Exchange resultExchange = template.request("direct:update", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setBody(updates); exchange.getIn().setHeader(MongoDbConstants.MULTIUPDATE, true); } @@ -253,7 +253,7 @@ public void process(Exchange exchange) throws Exception { } @Test - public void testUpdateUsingFieldsFilterHeader() throws Exception { + public void testUpdateUsingFieldsFilterHeader() { // Prepare test assertEquals(0, testCollection.countDocuments()); for (int i = 1; i <= 100; i++) { @@ -290,7 +290,7 @@ public void testUpdateUsingFieldsFilterHeader() throws Exception { } @Test - public void testRemove() throws Exception { + public void testRemove() { // Prepare test assertEquals(0, testCollection.countDocuments()); for (int i = 1; i <= 100; i++) { @@ -314,7 +314,7 @@ public void testRemove() throws Exception { Exchange resultExchange = template.request("direct:remove", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setBody(extraField); } }); @@ -329,7 +329,7 @@ public void process(Exchange exchange) throws Exception { } @Test - public void testAggregate() throws Exception { + public void testAggregate() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); pumpDataIntoTestCollection(); @@ -347,7 +347,7 @@ public void testAggregate() throws Exception { } @Test - public void testDbStats() throws Exception { + public void testDbStats() { assertEquals(0, testCollection.countDocuments()); Object result = template.requestBody("direct:getDbStats", "irrelevantBody"); assertTrue(result instanceof Document, "Result is not of type Document"); @@ -355,7 +355,7 @@ public void testDbStats() throws Exception { } @Test - public void testColStats() throws Exception { + public void testColStats() { assertEquals(0, testCollection.countDocuments()); // Add some records to the collection (and do it via camel-mongodb) @@ -374,7 +374,7 @@ public void testColStats() throws Exception { } @Test - public void testCommand() throws Exception { + public void testCommand() { // Call hostInfo, command working with every configuration Object result = template.requestBody("direct:command", "{\"hostInfo\":\"1\"}"); assertTrue(result instanceof Document, "Result is not of type Document"); @@ -382,7 +382,7 @@ public void testCommand() throws Exception { } @Test - public void testOperationHeader() throws Exception { + public void testOperationHeader() { // Test that the collection has 0 documents in it assertEquals(0, testCollection.countDocuments()); @@ -403,7 +403,7 @@ public void testOperationHeader() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOutputTypeIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOutputTypeIT.java index e66cd076a43fd..b6bb6a789a8c9 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOutputTypeIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOutputTypeIT.java @@ -95,7 +95,7 @@ public void testInitFindWithWrongOutputType() { try { RouteBuilder taillableRouteBuilder = new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("mongodb:myDb?database={{mongodb.testDb}}&collection={{mongodb.testCollection}}&operation=findById&dynamicity=true&outputType=MongoIterable") .to("mock:dummy"); } @@ -113,7 +113,7 @@ public void testInitTailWithWrongOutputType() { try { RouteBuilder taillableRouteBuilder = new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("mongodb:myDb?database={{mongodb.testDb}}&collection={{mongodb.cappedTestCollection}}&tailTrackIncreasingField=increasing&outputType=MongoIterable") .id("tailableCursorConsumer1").autoStartup(false).to("mock:test"); } @@ -127,7 +127,7 @@ public void configure() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbSpringDslOperationsIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbSpringDslOperationsIT.java index d294bed6f0ff0..aa7a62be33b00 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbSpringDslOperationsIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbSpringDslOperationsIT.java @@ -42,10 +42,10 @@ protected CamelContext createCamelContext() throws Exception { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { // Nothing, all routes are initialized by the Spring DSL context // file } diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbStopEndpointIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbStopEndpointIT.java index 5ef8aeef39335..f3c743fe5c8be 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbStopEndpointIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbStopEndpointIT.java @@ -33,7 +33,7 @@ public class MongoDbStopEndpointIT extends AbstractMongoDbITSupport { MongoDbEndpoint endpoint; @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { from("direct:insertJsonString").routeId("insert").to(endpoint); @@ -44,7 +44,7 @@ public void configure() { } @Test - public void testStopEndpoint() throws Exception { + public void testStopEndpoint() { assertEquals(0, testCollection.countDocuments()); template.requestBody("direct:insertJsonString", "{\"scientist\": \"Newton\", \"_id\": \"" + MY_ID + "\"}"); diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbTailableCursorConsumerIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbTailableCursorConsumerIT.java index 336f2d0f8b593..b8789074be494 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbTailableCursorConsumerIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbTailableCursorConsumerIT.java @@ -426,7 +426,7 @@ protected void addTestRoutes() throws Exception { context.addRoutes(new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("mongodb:myDb?database={{mongodb.testDb}}&collection={{mongodb.cappedTestCollection}}&tailTrackIncreasingField=increasing") .id("tailableCursorConsumer1") diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/meta/integration/MongoDbMetaExtensionIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/meta/integration/MongoDbMetaExtensionIT.java index 9a6b6e81c81d4..cf6972dc51cd0 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/meta/integration/MongoDbMetaExtensionIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/meta/integration/MongoDbMetaExtensionIT.java @@ -52,7 +52,7 @@ protected MongoDbComponent getComponent() { } @Test - public void testValidMetaData() throws Exception { + public void testValidMetaData() { // When final String database = "test"; final String collection = "validatedCollection"; diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/processor/idempotent/integration/MongoDbIdempotentRepositoryIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/processor/idempotent/integration/MongoDbIdempotentRepositoryIT.java index 6bcf03f58d877..a8d9aa4625660 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/processor/idempotent/integration/MongoDbIdempotentRepositoryIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/processor/idempotent/integration/MongoDbIdempotentRepositoryIT.java @@ -45,7 +45,7 @@ public void doPostSetup() { } @Test - public void add() throws Exception { + public void add() { String randomUUIDString = UUID.randomUUID().toString(); boolean added = repo.add(randomUUIDString); @@ -54,7 +54,7 @@ public void add() throws Exception { } @Test - public void addAndContains() throws Exception { + public void addAndContains() { String randomUUIDString = UUID.randomUUID().toString(); repo.add(randomUUIDString); @@ -65,7 +65,7 @@ public void addAndContains() throws Exception { } @Test - public void addAndRemove() throws Exception { + public void addAndRemove() { String randomUUIDString = UUID.randomUUID().toString(); repo.add(randomUUIDString); @@ -77,7 +77,7 @@ public void addAndRemove() throws Exception { } @Test - public void addDuplicatedFails() throws Exception { + public void addDuplicatedFails() { String randomUUIDString = UUID.randomUUID().toString(); repo.add(randomUUIDString); @@ -89,7 +89,7 @@ public void addDuplicatedFails() throws Exception { } @Test - public void deleteMissingiIsFailse() throws Exception { + public void deleteMissingiIsFailse() { String randomUUIDString = UUID.randomUUID().toString(); assertEquals(0, testCollection.countDocuments()); boolean removed = repo.remove(randomUUIDString); @@ -97,14 +97,14 @@ public void deleteMissingiIsFailse() throws Exception { } @Test - public void containsMissingReturnsFalse() throws Exception { + public void containsMissingReturnsFalse() { String randomUUIDString = UUID.randomUUID().toString(); boolean found = repo.contains(randomUUIDString); assertTrue(!found, "Non existing item is not found"); } @Test - public void confirmAllwaysReturnsTrue() throws Exception { + public void confirmAllwaysReturnsTrue() { String randomUUIDString = UUID.randomUUID().toString(); boolean found = repo.confirm(randomUUIDString); assertTrue(found, "Confirm always returns true");