This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit c2df125dd06531f5b1109ddbccee458ba471628b Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Thu Mar 10 15:04:21 2022 +0100 CAMEL-17763: cleaned up unused exceptions in camel-paho-mqtt5 --- .../camel/component/paho/mqtt5/PahoMqtt5ComponentMqtt5Test.java | 7 +++---- .../paho/mqtt5/PahoMqtt5ComponentVerifierExtensionTest.java | 4 ++-- .../component/paho/mqtt5/PahoMqtt5OverrideTopicMqtt5Test.java | 4 ++-- .../component/paho/mqtt5/PahoMqtt5ReconnectAfterFailureTest.java | 6 +++--- .../camel/component/paho/mqtt5/PahoMqtt5ToDSendDynamicTest.java | 6 +++--- .../org/apache/camel/component/paho/mqtt5/PahoMqtt5ToDTest.java | 4 ++-- 6 files changed, 15 insertions(+), 16 deletions(-) diff --git a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ComponentMqtt5Test.java b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ComponentMqtt5Test.java index 69ae6c9..4491c97 100644 --- a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ComponentMqtt5Test.java +++ b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ComponentMqtt5Test.java @@ -16,7 +16,6 @@ */ package org.apache.camel.component.paho.mqtt5; -import java.io.UnsupportedEncodingException; import java.nio.charset.StandardCharsets; import org.apache.camel.EndpointInject; @@ -38,10 +37,10 @@ public class PahoMqtt5ComponentMqtt5Test extends PahoMqtt5TestSupport { MockEndpoint testCustomizedPahoMock; @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { PahoMqtt5Component customizedPaho = new PahoMqtt5Component(); context.addComponent("customizedPaho", customizedPaho); @@ -102,7 +101,7 @@ public class PahoMqtt5ComponentMqtt5Test extends PahoMqtt5TestSupport { } @Test - public void shouldKeepDefaultMessageInHeader() throws InterruptedException, UnsupportedEncodingException { + public void shouldKeepDefaultMessageInHeader() throws InterruptedException { // Given final String msg = "msg"; mock.expectedBodiesReceived(msg); diff --git a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ComponentVerifierExtensionTest.java b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ComponentVerifierExtensionTest.java index 32141bf..b94062d 100644 --- a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ComponentVerifierExtensionTest.java +++ b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ComponentVerifierExtensionTest.java @@ -34,7 +34,7 @@ public class PahoMqtt5ComponentVerifierExtensionTest extends CamelTestSupport { } @Test - public void testParameters() throws Exception { + public void testParameters() { Component component = context().getComponent("paho-mqtt5"); ComponentVerifierExtension verifier @@ -49,7 +49,7 @@ public class PahoMqtt5ComponentVerifierExtensionTest extends CamelTestSupport { } @Test - public void testConnectivity() throws Exception { + public void testConnectivity() { Component component = context().getComponent("paho-mqtt5"); ComponentVerifierExtension verifier = component.getExtension(ComponentVerifierExtension.class).orElseThrow(IllegalStateException::new); diff --git a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5OverrideTopicMqtt5Test.java b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5OverrideTopicMqtt5Test.java index 1b0a565..24e42917 100644 --- a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5OverrideTopicMqtt5Test.java +++ b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5OverrideTopicMqtt5Test.java @@ -22,10 +22,10 @@ import org.junit.jupiter.api.Test; public class PahoMqtt5OverrideTopicMqtt5Test extends PahoMqtt5TestSupport { @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { PahoMqtt5Component paho = context.getComponent("paho-mqtt5", PahoMqtt5Component.class); paho.getConfiguration().setBrokerUrl("tcp://localhost:" + mqttPort); diff --git a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ReconnectAfterFailureTest.java b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ReconnectAfterFailureTest.java index 98b87b2..a1c7c76 100644 --- a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ReconnectAfterFailureTest.java +++ b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ReconnectAfterFailureTest.java @@ -97,10 +97,10 @@ public class PahoMqtt5ReconnectAfterFailureTest extends CamelTestSupport { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:test").to("paho-mqtt5:queue?lazyStartProducer=true&brokerUrl=tcp://localhost:" + mqttPort); from("paho-mqtt5:queue?brokerUrl=tcp://localhost:" + mqttPort) @@ -162,7 +162,7 @@ public class PahoMqtt5ReconnectAfterFailureTest extends CamelTestSupport { mock.assertIsSatisfied(10000); } - private void startBroker() throws Exception { + private void startBroker() { service.initialize(); } } diff --git a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ToDSendDynamicTest.java b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ToDSendDynamicTest.java index 1c13670..41b81c4 100644 --- a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ToDSendDynamicTest.java +++ b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ToDSendDynamicTest.java @@ -24,7 +24,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals; public class PahoMqtt5ToDSendDynamicTest extends PahoMqtt5TestSupport { @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"); @@ -40,10 +40,10 @@ public class PahoMqtt5ToDSendDynamicTest extends PahoMqtt5TestSupport { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { PahoMqtt5Component paho = context.getComponent("paho-mqtt5", PahoMqtt5Component.class); paho.getConfiguration().setBrokerUrl("tcp://localhost:" + mqttPort); diff --git a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ToDTest.java b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ToDTest.java index d487e39..e5b5c2c 100644 --- a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ToDTest.java +++ b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ToDTest.java @@ -33,10 +33,10 @@ public class PahoMqtt5ToDTest extends PahoMqtt5TestSupport { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { PahoMqtt5Component paho = context.getComponent("paho-mqtt5", PahoMqtt5Component.class); paho.getConfiguration().setBrokerUrl("tcp://localhost:" + mqttPort);
