This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit df27d6f1961a345c0ea99c2976275e885f96d6dc Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Wed Jan 13 15:07:47 2021 +0100 Removed declarations of exceptions never thrown --- .../azure/storage/blob/sink/CamelSinkAzureStorageBlobITCase.java | 2 +- .../azure/storage/queue/sink/CamelSinkAzureStorageQueueITCase.java | 2 +- .../kafkaconnector/common/services/kafka/EmbeddedKafkaService.java | 4 ++-- .../common/services/kafkaconnect/KafkaConnectService.java | 4 ++-- .../camel/kafkaconnector/mongodb/sink/CamelSinkMongoDBITCase.java | 2 +- .../java/org/apache/camel/kafkaconnector/ssh/services/SshService.java | 4 ++-- .../apache/camel/kafkaconnector/syslog/services/SyslogService.java | 4 ++-- .../camel/kafkaconnector/syslog/source/CamelSourceSyslogITCase.java | 4 ++-- 8 files changed, 13 insertions(+), 13 deletions(-) diff --git a/tests/itests-azure-storage-blob/src/test/java/org/apache/camel/kafkaconnector/azure/storage/blob/sink/CamelSinkAzureStorageBlobITCase.java b/tests/itests-azure-storage-blob/src/test/java/org/apache/camel/kafkaconnector/azure/storage/blob/sink/CamelSinkAzureStorageBlobITCase.java index e7e5b81..938ac03 100644 --- a/tests/itests-azure-storage-blob/src/test/java/org/apache/camel/kafkaconnector/azure/storage/blob/sink/CamelSinkAzureStorageBlobITCase.java +++ b/tests/itests-azure-storage-blob/src/test/java/org/apache/camel/kafkaconnector/azure/storage/blob/sink/CamelSinkAzureStorageBlobITCase.java @@ -134,7 +134,7 @@ public class CamelSinkAzureStorageBlobITCase extends AbstractKafkaTest { } } - public void runTest(ConnectorPropertyFactory connectorPropertyFactory) throws ExecutionException, InterruptedException, IOException { + public void runTest(ConnectorPropertyFactory connectorPropertyFactory) throws ExecutionException, InterruptedException { connectorPropertyFactory.log(); getKafkaConnectService().initializeConnectorBlocking(connectorPropertyFactory, 1); diff --git a/tests/itests-azure-storage-queue/src/test/java/org/apache/camel/kafkaconnector/azure/storage/queue/sink/CamelSinkAzureStorageQueueITCase.java b/tests/itests-azure-storage-queue/src/test/java/org/apache/camel/kafkaconnector/azure/storage/queue/sink/CamelSinkAzureStorageQueueITCase.java index 2a49dcc..b0636ff 100644 --- a/tests/itests-azure-storage-queue/src/test/java/org/apache/camel/kafkaconnector/azure/storage/queue/sink/CamelSinkAzureStorageQueueITCase.java +++ b/tests/itests-azure-storage-queue/src/test/java/org/apache/camel/kafkaconnector/azure/storage/queue/sink/CamelSinkAzureStorageQueueITCase.java @@ -118,7 +118,7 @@ public class CamelSinkAzureStorageQueueITCase extends AbstractKafkaTest { } - public void runTest(ConnectorPropertyFactory connectorPropertyFactory) throws ExecutionException, InterruptedException, IOException { + public void runTest(ConnectorPropertyFactory connectorPropertyFactory) throws ExecutionException, InterruptedException { connectorPropertyFactory.log(); getKafkaConnectService().initializeConnectorBlocking(connectorPropertyFactory, 1); diff --git a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/EmbeddedKafkaService.java b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/EmbeddedKafkaService.java index 4c43ae0..3ce25d3 100644 --- a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/EmbeddedKafkaService.java +++ b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/EmbeddedKafkaService.java @@ -105,12 +105,12 @@ public class EmbeddedKafkaService implements KafkaService { } @Override - public void beforeTestExecution(ExtensionContext extensionContext) throws Exception { + public void beforeTestExecution(ExtensionContext extensionContext) { initialize(); } @Override - public void afterTestExecution(ExtensionContext context) throws Exception { + public void afterTestExecution(ExtensionContext context) { shutdown(); } diff --git a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectService.java b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectService.java index 39a11c9..5ae9e07 100644 --- a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectService.java +++ b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectService.java @@ -33,12 +33,12 @@ public interface KafkaConnectService extends BeforeTestExecutionCallback, AfterT void start(); @Override - default void afterTestExecution(ExtensionContext extensionContext) throws Exception { + default void afterTestExecution(ExtensionContext extensionContext) { stop(); } @Override - default void beforeTestExecution(ExtensionContext extensionContext) throws Exception { + default void beforeTestExecution(ExtensionContext extensionContext) { start(); } } diff --git a/tests/itests-mongodb/src/test/java/org/apache/camel/kafkaconnector/mongodb/sink/CamelSinkMongoDBITCase.java b/tests/itests-mongodb/src/test/java/org/apache/camel/kafkaconnector/mongodb/sink/CamelSinkMongoDBITCase.java index 19862b5..eb4cf2f 100644 --- a/tests/itests-mongodb/src/test/java/org/apache/camel/kafkaconnector/mongodb/sink/CamelSinkMongoDBITCase.java +++ b/tests/itests-mongodb/src/test/java/org/apache/camel/kafkaconnector/mongodb/sink/CamelSinkMongoDBITCase.java @@ -87,7 +87,7 @@ public class CamelSinkMongoDBITCase extends AbstractKafkaTest { return collection.countDocuments() >= expect; } - private void verifyDocuments(String database, String collectionName) throws InterruptedException { + private void verifyDocuments(String database, String collectionName) { MongoDatabase mongoDatabase = mongoClient.getDatabase(database); MongoCollection<Document> collection = mongoDatabase.getCollection(collectionName); diff --git a/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshService.java b/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshService.java index d5a375e..c2dcef7 100644 --- a/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshService.java +++ b/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshService.java @@ -42,12 +42,12 @@ public interface SshService extends BeforeAllCallback, AfterAllCallback { void shutdown(); @Override - default void beforeAll(ExtensionContext extensionContext) throws Exception { + default void beforeAll(ExtensionContext extensionContext) { initialize(); } @Override - default void afterAll(ExtensionContext extensionContext) throws Exception { + default void afterAll(ExtensionContext extensionContext) { shutdown(); } } diff --git a/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/services/SyslogService.java b/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/services/SyslogService.java index 3b3a508..3bc07b3 100644 --- a/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/services/SyslogService.java +++ b/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/services/SyslogService.java @@ -44,7 +44,7 @@ public class SyslogService implements BeforeAllCallback, AfterAllCallback { CAMEL_CONTEXT.getRegistry().bind("decoder", new Rfc5425FrameDecoder()); CAMEL_CONTEXT.addRoutes(new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("netty:" + protocol + ":" + host + ":" + port + "?sync=false&decoders=#decoder").unmarshal(new SyslogDataFormat()).to("seda:syslog"); } }); @@ -52,7 +52,7 @@ public class SyslogService implements BeforeAllCallback, AfterAllCallback { } @Override - public void afterAll(ExtensionContext context) throws Exception { + public void afterAll(ExtensionContext context) { CAMEL_CONTEXT.stop(); } diff --git a/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/source/CamelSourceSyslogITCase.java b/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/source/CamelSourceSyslogITCase.java index 548d9cf..8dc49bc 100644 --- a/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/source/CamelSourceSyslogITCase.java +++ b/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/source/CamelSourceSyslogITCase.java @@ -64,14 +64,14 @@ public class CamelSourceSyslogITCase extends AbstractKafkaTest { received = 0; } - private void produceLogMessages(String protocol, String host, String port, String message) throws Exception { + private void produceLogMessages(String protocol, String host, String port, String message) { CamelContext camelContext = new DefaultCamelContext(); try { camelContext.getRegistry().bind("encoder", new Rfc5425Encoder()); camelContext.addRoutes(new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:test").marshal(new SyslogDataFormat()).to("netty:" + protocol + ":" + host + ":" + port + "?sync=false&encoders=#encoder&useByteBuf=true"); } });
