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.gitcommit df27d6f1961a345c0ea99c2976275e885f96d6dc
Author: Otavio Rodolfo Piske <
[hidden email]>
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");
}
});
Locked
