You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/04/12 16:45:01 UTC
[camel] branch main updated (3fc4736bc47 -> 284feaeab3b)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from 3fc4736bc47 CAMEL-17945: Fix the unstable test HazelcastSedaTransferExchangeTest (#7418)
new c596eb135cf CAMEL-17763: cleaned up unused exceptions in camel-lra
new e84e878d54f CAMEL-17763: cleaned up unused exceptions in camel-leveldb
new 3d46ff3b6ac CAMEL-17763: cleaned up unused exceptions in camel-ldif
new de5257e63cb CAMEL-17763: cleaned up unused exceptions in camel-ldap
new 3bdb5079bf5 CAMEL-17763: cleaned up unused exceptions in camel-kudu
new d0512e1aa88 CAMEL-17763: cleaned up unused exceptions in camel-kubernetes
new dfdb5969a67 CAMEL-17763: cleaned up unused exceptions in camel-kamelet
new 9f550dc8b3d CAMEL-17763: cleaned up unused exceptions in camel-jt400
new 284feaeab3b CAMEL-17763: cleaned up unused exceptions in camel-jsonb
The 9 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../component/jsonb/JsonbJsonDataFormatTest.java | 2 +-
.../Jt400ComponentDefaultConnectionPoolTest.java | 2 +-
...00ComponentDefaultSecureConnectionPoolTest.java | 2 +-
.../camel/component/jt400/Jt400ComponentTest.java | 2 +-
.../jt400/Jt400MultipleConsumersRouteTest.java | 4 +--
.../camel/component/jt400/Jt400PgmRouteTest.java | 4 +--
.../camel/component/jt400/Jt400RouteTest.java | 4 +--
.../component/jt400/MockAS400ConnectionPool.java | 6 ++---
.../jt400/MockAS400SecureConnectionPool.java | 29 +++++++++-------------
.../component/kamelet/KameletEipMulticastTest.java | 4 +--
.../apache/camel/component/KubernetesServer.java | 4 +--
.../apache/camel/component/OpenShiftServer.java | 4 +--
.../cloud/ServiceCallClientRouteTest.java | 4 +--
.../cloud/ServiceCallEnvironmentRouteTest.java | 4 +--
.../cluster/KubernetesClusterServiceTest.java | 15 ++++++-----
.../cluster/TimedLeaderNotifierTest.java | 4 +--
.../KubernetesConfigMapsConsumerIT.java | 12 ++++-----
.../KubernetesCustomResourcesConsumerIT.java | 10 ++++----
.../KubernetesNamespacesConsumerIT.java | 10 ++++----
.../integration/KubernetesNodesConsumerIT.java | 6 ++---
.../integration/KubernetesPodsConsumerIT.java | 6 ++---
...KubernetesReplicationControllersConsumerIT.java | 6 ++---
.../integration/KubernetesServicesConsumerIT.java | 10 ++++----
.../producer/KubernetesConfigMapsProducerTest.java | 14 +++++------
.../KubernetesCustomResourcesProducerTest.java | 6 ++---
.../KubernetesDeploymentsProducerTest.java | 12 ++++-----
.../producer/KubernetesHPAProducerTest.java | 18 +++++++-------
.../producer/KubernetesJobProducerTest.java | 10 ++++----
.../producer/KubernetesNamespacesProducerTest.java | 12 ++++-----
.../producer/KubernetesNodesProducerTest.java | 12 ++++-----
...ernetesPersistentVolumesClaimsProducerTest.java | 10 ++++----
.../KubernetesPersistentVolumesProducerTest.java | 8 +++---
.../producer/KubernetesPodsProducerTest.java | 12 ++++-----
...bernetesReplicationControllersProducerTest.java | 12 ++++-----
.../KubernetesResourcesQuotaProducerTest.java | 10 ++++----
.../producer/KubernetesSecretsProducerTest.java | 12 ++++-----
.../KubernetesServiceAccountsProducerTest.java | 10 ++++----
.../producer/KubernetesServicesProducerTest.java | 12 ++++-----
.../OpenshiftBuildConfigsProducerTest.java | 8 +++---
.../producer/OpenshiftBuildsProducerTest.java | 10 ++++----
.../kudu/KuduComponentConfigurationTest.java | 2 +-
.../camel/component/ldap/LdapRouteManualIT.java | 6 ++---
.../camel/component/ldap/LdapRouteTwoManualIT.java | 8 +++---
.../server/core/integ5/DirectoryExtension.java | 3 +--
.../core/integ5/ServerAnnotationProcessor.java | 3 +--
.../apache/camel/component/ldif/LdifRouteIT.java | 8 +++---
.../server/core/integ5/DirectoryExtension.java | 3 +--
.../core/integ5/ServerAnnotationProcessor.java | 3 +--
...elDBAggregateConcurrentDifferentGroupsTest.java | 4 +--
.../LevelDBAggregateConcurrentSameGroupTest.java | 4 +--
.../LevelDBAggregateDiscardOnTimeoutTest.java | 4 +--
.../LevelDBAggregateForceCompletionHeaderTest.java | 4 +--
.../LevelDBAggregateLoadAndRecoverTest.java | 6 ++---
.../LevelDBAggregateLoadConcurrentTest.java | 4 +--
.../leveldb/LevelDBAggregateLoadTest.java | 4 +--
...DBAggregateNotLostRemovedWhenConfirmedTest.java | 4 +--
.../leveldb/LevelDBAggregateNotLostTest.java | 4 +--
...ggregateRecoverDeadLetterChannelFailedTest.java | 4 +--
...velDBAggregateRecoverDeadLetterChannelTest.java | 4 +--
.../leveldb/LevelDBAggregateRecoverTest.java | 6 ++---
...DBAggregateRecoverWithRedeliveryPolicyTest.java | 6 ++---
.../LevelDBAggregateRecoverWithSedaTest.java | 6 ++---
.../LevelDBAggregateSerializedHeadersTest.java | 4 +--
.../component/leveldb/LevelDBAggregateTest.java | 4 +--
...velDBAggregateTimeoutCompletionRestartTest.java | 4 +--
.../component/leveldb/LevelDBBigPayloadTest.java | 4 +--
.../camel/component/leveldb/LevelDBBinaryTest.java | 4 +--
.../leveldb/LevelDBCustomSerializationTest.java | 7 +++---
...ngAggregateRecoverWithRedeliveryPolicyTest.java | 2 +-
.../camel/service/lra/AbstractLRATestSupport.java | 2 +-
.../org/apache/camel/service/lra/LRACreditIT.java | 8 +++---
.../apache/camel/service/lra/LRAFailuresIT.java | 4 +--
.../org/apache/camel/service/lra/LRAManualIT.java | 4 +--
.../org/apache/camel/service/lra/LRAOptionsIT.java | 6 ++---
.../org/apache/camel/service/lra/LRATimeoutIT.java | 4 +--
75 files changed, 244 insertions(+), 255 deletions(-)
[camel] 09/09: CAMEL-17763: cleaned up unused exceptions in camel-jsonb
Posted by or...@apache.org.
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 284feaeab3b116f004ad9e0548bf42899afbf9cd
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 16:46:37 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-jsonb
---
.../java/org/apache/camel/component/jsonb/JsonbJsonDataFormatTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/components/camel-jsonb/src/test/java/org/apache/camel/component/jsonb/JsonbJsonDataFormatTest.java b/components/camel-jsonb/src/test/java/org/apache/camel/component/jsonb/JsonbJsonDataFormatTest.java
index 30b89cbc5cb..b62aa9ecd5f 100644
--- a/components/camel-jsonb/src/test/java/org/apache/camel/component/jsonb/JsonbJsonDataFormatTest.java
+++ b/components/camel-jsonb/src/test/java/org/apache/camel/component/jsonb/JsonbJsonDataFormatTest.java
@@ -25,7 +25,7 @@ public class JsonbJsonDataFormatTest extends JsonbMarshalTest {
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:in").marshal().json(JsonLibrary.Jsonb);
from("direct:back").unmarshal().json(JsonLibrary.Jsonb).to("mock:reverse");
[camel] 07/09: CAMEL-17763: cleaned up unused exceptions in camel-kamelet
Posted by or...@apache.org.
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 dfdb5969a6778f8129939f583d3000920c2b4b90
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 16:46:53 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-kamelet
---
.../org/apache/camel/component/kamelet/KameletEipMulticastTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletEipMulticastTest.java b/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletEipMulticastTest.java
index 5c8a93dd51f..57633576408 100644
--- a/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletEipMulticastTest.java
+++ b/components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletEipMulticastTest.java
@@ -36,7 +36,7 @@ public class KameletEipMulticastTest extends CamelTestSupport {
public void testOne() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
routeTemplate("echo")
.from("kamelet:source")
.setBody(body().append(body()));
@@ -76,7 +76,7 @@ public class KameletEipMulticastTest extends CamelTestSupport {
public void testTwo() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
routeTemplate("echo")
.from("kamelet:source")
.setBody(body().append(body()));
[camel] 08/09: CAMEL-17763: cleaned up unused exceptions in camel-jt400
Posted by or...@apache.org.
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 9f550dc8b3d70cd39c35f754af74afead161a337
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 16:46:44 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-jt400
---
.../Jt400ComponentDefaultConnectionPoolTest.java | 2 +-
...00ComponentDefaultSecureConnectionPoolTest.java | 2 +-
.../camel/component/jt400/Jt400ComponentTest.java | 2 +-
.../jt400/Jt400MultipleConsumersRouteTest.java | 4 +--
.../camel/component/jt400/Jt400PgmRouteTest.java | 4 +--
.../camel/component/jt400/Jt400RouteTest.java | 4 +--
.../component/jt400/MockAS400ConnectionPool.java | 6 ++---
.../jt400/MockAS400SecureConnectionPool.java | 29 +++++++++-------------
8 files changed, 24 insertions(+), 29 deletions(-)
diff --git a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400ComponentDefaultConnectionPoolTest.java b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400ComponentDefaultConnectionPoolTest.java
index 60b78ef1979..210fc223839 100644
--- a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400ComponentDefaultConnectionPoolTest.java
+++ b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400ComponentDefaultConnectionPoolTest.java
@@ -46,7 +46,7 @@ public class Jt400ComponentDefaultConnectionPoolTest extends Jt400TestSupport {
@Override
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
if (component != null) {
component.stop();
}
diff --git a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400ComponentDefaultSecureConnectionPoolTest.java b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400ComponentDefaultSecureConnectionPoolTest.java
index 3a0d4a59d71..85404502188 100644
--- a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400ComponentDefaultSecureConnectionPoolTest.java
+++ b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400ComponentDefaultSecureConnectionPoolTest.java
@@ -46,7 +46,7 @@ public class Jt400ComponentDefaultSecureConnectionPoolTest extends Jt400TestSupp
@Override
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
if (component != null) {
component.stop();
}
diff --git a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400ComponentTest.java b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400ComponentTest.java
index 2b942560649..697879aca74 100644
--- a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400ComponentTest.java
+++ b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400ComponentTest.java
@@ -66,7 +66,7 @@ public class Jt400ComponentTest extends Jt400TestSupport {
* Test exception when trying to access any other object type on AS/400
*/
@Test
- public void testCreateEndpointForOtherObjectType() throws Exception {
+ public void testCreateEndpointForOtherObjectType() {
try {
component.createEndpoint("jt400://user:password@host/qsys.lib/library.lib/program.xxx");
fail("Exception should been thrown when trying to create an endpoint for an unsupported object type");
diff --git a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400MultipleConsumersRouteTest.java b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400MultipleConsumersRouteTest.java
index d77d9cfce11..6ef64a1895b 100644
--- a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400MultipleConsumersRouteTest.java
+++ b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400MultipleConsumersRouteTest.java
@@ -47,11 +47,11 @@ public class Jt400MultipleConsumersRouteTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
if (SYSTEM != null) {
String uri = String.format("jt400://%s:%s@%s/QSYS.LIB/%s.LIB/%s.DTAQ", USER, PASSWORD,
SYSTEM, LIBRARY, QUEUE);
diff --git a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400PgmRouteTest.java b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400PgmRouteTest.java
index 63f15b47733..bb5a3abfd8b 100644
--- a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400PgmRouteTest.java
+++ b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400PgmRouteTest.java
@@ -75,11 +75,11 @@ public class Jt400PgmRouteTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
if (SYSTEM != null) {
String uri = String
.format("jt400://%s:%s@%s/QSYS.LIB/%s.LIB/%s.pgm?outputFieldsIdx=%s&fieldsLength=%s",
diff --git a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400RouteTest.java b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400RouteTest.java
index a67eb4243b7..c88c4d14ed9 100644
--- a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400RouteTest.java
+++ b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400RouteTest.java
@@ -47,11 +47,11 @@ public class Jt400RouteTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
if (SYSTEM != null) {
String uri = String.format("jt400://%s:%s@%s/QSYS.LIB/%s.LIB/%s.DTAQ", USER, PASSWORD,
SYSTEM, LIBRARY, QUEUE);
diff --git a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/MockAS400ConnectionPool.java b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/MockAS400ConnectionPool.java
index 0e9099d10e4..9c8dcce1b5b 100644
--- a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/MockAS400ConnectionPool.java
+++ b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/MockAS400ConnectionPool.java
@@ -36,18 +36,18 @@ public class MockAS400ConnectionPool extends AS400ConnectionPool {
@Deprecated
@Override
- public AS400 getConnection(String systemName, String userID) throws ConnectionPoolException {
+ public AS400 getConnection(String systemName, String userID) {
throw new UnsupportedOperationException();
}
@Deprecated
@Override
- public AS400 getConnection(String systemName, String userID, int service) throws ConnectionPoolException {
+ public AS400 getConnection(String systemName, String userID, int service) {
throw new UnsupportedOperationException();
}
@Override
- public AS400 getConnection(String systemName, String userID, String password) throws ConnectionPoolException {
+ public AS400 getConnection(String systemName, String userID, String password) {
return new AS400(systemName, userID, password);
}
diff --git a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/MockAS400SecureConnectionPool.java b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/MockAS400SecureConnectionPool.java
index 492b17ee45b..00d1c6fb44f 100644
--- a/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/MockAS400SecureConnectionPool.java
+++ b/components/camel-jt400/src/test/java/org/apache/camel/component/jt400/MockAS400SecureConnectionPool.java
@@ -20,7 +20,6 @@ import java.util.Locale;
import com.ibm.as400.access.AS400;
import com.ibm.as400.access.AS400ConnectionPool;
-import com.ibm.as400.access.ConnectionPoolException;
import com.ibm.as400.security.auth.ProfileTokenCredential;
/**
@@ -34,70 +33,66 @@ public class MockAS400SecureConnectionPool extends AS400ConnectionPool {
}
@Override
- public AS400 getSecureConnection(String systemName, String userID, String password) throws ConnectionPoolException {
+ public AS400 getSecureConnection(String systemName, String userID, String password) {
return new AS400(systemName, userID, password);
}
@Deprecated
@Override
- public AS400 getSecureConnection(String systemName, String userID) throws ConnectionPoolException {
+ public AS400 getSecureConnection(String systemName, String userID) {
throw new UnsupportedOperationException();
}
@Override
- public AS400 getSecureConnection(String systemName, String userID, String password, int i) throws ConnectionPoolException {
+ public AS400 getSecureConnection(String systemName, String userID, String password, int i) {
return new AS400(systemName, userID, password);
}
@Deprecated
@Override
- public AS400 getSecureConnection(String systemName, String userID, int i) throws ConnectionPoolException {
+ public AS400 getSecureConnection(String systemName, String userID, int i) {
throw new UnsupportedOperationException();
}
@Override
- public AS400 getSecureConnection(String systemName, String userID, ProfileTokenCredential profileTokenCredential)
- throws ConnectionPoolException {
+ public AS400 getSecureConnection(String systemName, String userID, ProfileTokenCredential profileTokenCredential) {
return new AS400(systemName, userID);
}
@Override
- public AS400 getSecureConnection(String systemName, String userID, ProfileTokenCredential profileTokenCredential, int i)
- throws ConnectionPoolException {
+ public AS400 getSecureConnection(String systemName, String userID, ProfileTokenCredential profileTokenCredential, int i) {
return new AS400(systemName, userID);
}
@Deprecated
@Override
- public AS400 getConnection(String systemName, String userID) throws ConnectionPoolException {
+ public AS400 getConnection(String systemName, String userID) {
throw new UnsupportedOperationException();
}
@Deprecated
@Override
- public AS400 getConnection(String systemName, String userID, int service) throws ConnectionPoolException {
+ public AS400 getConnection(String systemName, String userID, int service) {
throw new UnsupportedOperationException();
}
@Override
- public AS400 getConnection(String systemName, String userID, String password) throws ConnectionPoolException {
+ public AS400 getConnection(String systemName, String userID, String password) {
throw new UnsupportedOperationException();
}
@Override
- public AS400 getConnection(String systemName, String userID, String password, int service) throws ConnectionPoolException {
+ public AS400 getConnection(String systemName, String userID, String password, int service) {
throw new UnsupportedOperationException();
}
@Override
- public AS400 getConnection(String systemName, String userID, String password, int service, Locale locale)
- throws ConnectionPoolException {
+ public AS400 getConnection(String systemName, String userID, String password, int service, Locale locale) {
throw new UnsupportedOperationException();
}
@Override
- public AS400 getConnection(String systemName, String userID, String password, Locale locale)
- throws ConnectionPoolException {
+ public AS400 getConnection(String systemName, String userID, String password, Locale locale) {
throw new UnsupportedOperationException();
}
[camel] 04/09: CAMEL-17763: cleaned up unused exceptions in camel-ldap
Posted by or...@apache.org.
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 de5257e63cbd92567799c1e8185dbce3b3c5fea2
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 17:15:02 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-ldap
---
.../java/org/apache/camel/component/ldap/LdapRouteManualIT.java | 6 +++---
.../org/apache/camel/component/ldap/LdapRouteTwoManualIT.java | 8 ++++----
.../apache/directory/server/core/integ5/DirectoryExtension.java | 3 +--
.../directory/server/core/integ5/ServerAnnotationProcessor.java | 3 +--
4 files changed, 9 insertions(+), 11 deletions(-)
diff --git a/components/camel-ldap/src/test/java/org/apache/camel/component/ldap/LdapRouteManualIT.java b/components/camel-ldap/src/test/java/org/apache/camel/component/ldap/LdapRouteManualIT.java
index fac5e492395..17cb18ad819 100644
--- a/components/camel-ldap/src/test/java/org/apache/camel/component/ldap/LdapRouteManualIT.java
+++ b/components/camel-ldap/src/test/java/org/apache/camel/component/ldap/LdapRouteManualIT.java
@@ -72,7 +72,7 @@ public class LdapRouteManualIT extends AbstractLdapTestUnit {
}
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
camel.stop();
}
@@ -182,10 +182,10 @@ public class LdapRouteManualIT extends AbstractLdapTestUnit {
return false;
}
- protected RouteBuilder createRouteBuilder(final String ldapEndpointUrl) throws Exception {
+ protected RouteBuilder createRouteBuilder(final String ldapEndpointUrl) {
return new RouteBuilder() {
// START SNIPPET: route
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to(ldapEndpointUrl);
}
// END SNIPPET: route
diff --git a/components/camel-ldap/src/test/java/org/apache/camel/component/ldap/LdapRouteTwoManualIT.java b/components/camel-ldap/src/test/java/org/apache/camel/component/ldap/LdapRouteTwoManualIT.java
index b3143ce0740..c56af46b999 100644
--- a/components/camel-ldap/src/test/java/org/apache/camel/component/ldap/LdapRouteTwoManualIT.java
+++ b/components/camel-ldap/src/test/java/org/apache/camel/component/ldap/LdapRouteTwoManualIT.java
@@ -56,7 +56,7 @@ public class LdapRouteTwoManualIT extends AbstractLdapTestUnit {
private int port;
@BeforeEach
- public void setup() throws Exception {
+ public void setup() {
// you can assign port number in the @CreateTransport annotation
port = super.getLdapServer().getPort();
@@ -75,7 +75,7 @@ public class LdapRouteTwoManualIT extends AbstractLdapTestUnit {
}
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
camel.stop();
}
@@ -134,10 +134,10 @@ public class LdapRouteTwoManualIT extends AbstractLdapTestUnit {
return false;
}
- protected RouteBuilder createRouteBuilder(final String ldapEndpointUrl) throws Exception {
+ protected RouteBuilder createRouteBuilder(final String ldapEndpointUrl) {
return new RouteBuilder() {
// START SNIPPET: route
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to(ldapEndpointUrl);
}
// END SNIPPET: route
diff --git a/components/camel-ldap/src/test/java/org/apache/directory/server/core/integ5/DirectoryExtension.java b/components/camel-ldap/src/test/java/org/apache/directory/server/core/integ5/DirectoryExtension.java
index 58718efbdec..6728221735e 100644
--- a/components/camel-ldap/src/test/java/org/apache/directory/server/core/integ5/DirectoryExtension.java
+++ b/components/camel-ldap/src/test/java/org/apache/directory/server/core/integ5/DirectoryExtension.java
@@ -25,7 +25,6 @@ import org.apache.directory.api.ldap.model.entry.Entry;
import org.apache.directory.api.ldap.model.entry.Modification;
import org.apache.directory.api.ldap.model.entry.ModificationOperation;
import org.apache.directory.api.ldap.model.exception.LdapException;
-import org.apache.directory.api.ldap.model.exception.LdapInvalidDnException;
import org.apache.directory.api.ldap.model.name.Dn;
import org.apache.directory.api.util.FileUtils;
import org.apache.directory.server.constants.ServerDNConstants;
@@ -239,7 +238,7 @@ public class DirectoryExtension implements BeforeAllCallback, AfterAllCallback,
}
}
- private void updateTlsKey(DirectoryService ds) throws LdapException, LdapInvalidDnException {
+ private void updateTlsKey(DirectoryService ds) throws LdapException {
// Update TLS key for tests. Newer Java 8 releases consider RSA keys
// with less than 1024 bits as insecure and such are disabled by default, see
// http://www.oracle.com/technetwork/java/javase/8-compatibility-guide-2156366.html
diff --git a/components/camel-ldap/src/test/java/org/apache/directory/server/core/integ5/ServerAnnotationProcessor.java b/components/camel-ldap/src/test/java/org/apache/directory/server/core/integ5/ServerAnnotationProcessor.java
index 292b05bba58..5324c9bbb4f 100644
--- a/components/camel-ldap/src/test/java/org/apache/directory/server/core/integ5/ServerAnnotationProcessor.java
+++ b/components/camel-ldap/src/test/java/org/apache/directory/server/core/integ5/ServerAnnotationProcessor.java
@@ -440,8 +440,7 @@ public final class ServerAnnotationProcessor {
return port;
}
- public static KdcServer getKdcServer(Description description, DirectoryService directoryService)
- throws Exception {
+ public static KdcServer getKdcServer(Description description, DirectoryService directoryService) {
CreateKdcServer createLdapServer = description.getAnnotation(CreateKdcServer.class);
return createKdcServer(createLdapServer, directoryService);
[camel] 05/09: CAMEL-17763: cleaned up unused exceptions in camel-kudu
Posted by or...@apache.org.
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 3bdb5079bf593519cacda9cc4fb4b2fef9f5cda3
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 17:14:45 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-kudu
---
.../org/apache/camel/component/kudu/KuduComponentConfigurationTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/components/camel-kudu/src/test/java/org/apache/camel/component/kudu/KuduComponentConfigurationTest.java b/components/camel-kudu/src/test/java/org/apache/camel/component/kudu/KuduComponentConfigurationTest.java
index d9ffd43bd03..846706b885a 100644
--- a/components/camel-kudu/src/test/java/org/apache/camel/component/kudu/KuduComponentConfigurationTest.java
+++ b/components/camel-kudu/src/test/java/org/apache/camel/component/kudu/KuduComponentConfigurationTest.java
@@ -42,7 +42,7 @@ public class KuduComponentConfigurationTest extends CamelTestSupport {
}
@Test
- public void wrongUrl() throws Exception {
+ public void wrongUrl() {
KuduComponent component = new KuduComponent(this.context());
assertThrows(Exception.class,
() -> component.createEndpoint("wrong url"));
[camel] 02/09: CAMEL-17763: cleaned up unused exceptions in camel-leveldb
Posted by or...@apache.org.
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 e84e878d54ff215aedbb00ea66e3df24a0b6ef15
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 17:17:32 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-leveldb
---
.../leveldb/LevelDBAggregateConcurrentDifferentGroupsTest.java | 4 ++--
.../component/leveldb/LevelDBAggregateConcurrentSameGroupTest.java | 4 ++--
.../component/leveldb/LevelDBAggregateDiscardOnTimeoutTest.java | 4 ++--
.../leveldb/LevelDBAggregateForceCompletionHeaderTest.java | 4 ++--
.../component/leveldb/LevelDBAggregateLoadAndRecoverTest.java | 6 +++---
.../component/leveldb/LevelDBAggregateLoadConcurrentTest.java | 4 ++--
.../apache/camel/component/leveldb/LevelDBAggregateLoadTest.java | 4 ++--
.../leveldb/LevelDBAggregateNotLostRemovedWhenConfirmedTest.java | 4 ++--
.../camel/component/leveldb/LevelDBAggregateNotLostTest.java | 4 ++--
.../LevelDBAggregateRecoverDeadLetterChannelFailedTest.java | 4 ++--
.../leveldb/LevelDBAggregateRecoverDeadLetterChannelTest.java | 4 ++--
.../camel/component/leveldb/LevelDBAggregateRecoverTest.java | 6 +++---
.../leveldb/LevelDBAggregateRecoverWithRedeliveryPolicyTest.java | 6 +++---
.../component/leveldb/LevelDBAggregateRecoverWithSedaTest.java | 6 +++---
.../component/leveldb/LevelDBAggregateSerializedHeadersTest.java | 4 ++--
.../org/apache/camel/component/leveldb/LevelDBAggregateTest.java | 4 ++--
.../leveldb/LevelDBAggregateTimeoutCompletionRestartTest.java | 4 ++--
.../org/apache/camel/component/leveldb/LevelDBBigPayloadTest.java | 4 ++--
.../java/org/apache/camel/component/leveldb/LevelDBBinaryTest.java | 4 ++--
.../camel/component/leveldb/LevelDBCustomSerializationTest.java | 7 +++----
.../LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest.java | 2 +-
21 files changed, 46 insertions(+), 47 deletions(-)
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentDifferentGroupsTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentDifferentGroupsTest.java
index 33a9091f00d..38884ff9a57 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentDifferentGroupsTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentDifferentGroupsTest.java
@@ -78,9 +78,9 @@ public class LevelDBAggregateConcurrentDifferentGroupsTest extends LevelDBTestSu
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.aggregate(header("id"), new StringAggregationStrategy())
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentSameGroupTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentSameGroupTest.java
index ac91b503d69..5b1979e5372 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentSameGroupTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentSameGroupTest.java
@@ -77,9 +77,9 @@ public class LevelDBAggregateConcurrentSameGroupTest extends LevelDBTestSupport
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
LevelDBAggregationRepository repo = new LevelDBAggregationRepository("repo1", "target/data/leveldb.dat");
from("direct:start")
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateDiscardOnTimeoutTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateDiscardOnTimeoutTest.java
index eb888b04a7c..681b769c553 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateDiscardOnTimeoutTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateDiscardOnTimeoutTest.java
@@ -63,11 +63,11 @@ public class LevelDBAggregateDiscardOnTimeoutTest extends LevelDBTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.aggregate(header("id"), new StringAggregationStrategy())
.completionSize(3).aggregationRepository(getRepo())
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateForceCompletionHeaderTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateForceCompletionHeaderTest.java
index 9a25c9cea05..4044bad6778 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateForceCompletionHeaderTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateForceCompletionHeaderTest.java
@@ -89,10 +89,10 @@ public class LevelDBAggregateForceCompletionHeaderTest extends LevelDBTestSuppor
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// here is the Camel route where we aggregate
from("direct:start")
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadAndRecoverTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadAndRecoverTest.java
index 8632fc1c123..fea80170ee0 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadAndRecoverTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadAndRecoverTest.java
@@ -90,10 +90,10 @@ public class LevelDBAggregateLoadAndRecoverTest extends LevelDBTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
LevelDBAggregationRepository repo = getRepo();
repo.setUseRecovery(true);
// for faster unit testing
@@ -107,7 +107,7 @@ public class LevelDBAggregateLoadAndRecoverTest extends LevelDBTestSupport {
.to("log:output?showHeaders=true")
// have every 10th exchange fail which should then be recovered
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
int num = counter.incrementAndGet();
if (num % 10 == 0) {
throw new IllegalStateException("Failed for num " + num);
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadConcurrentTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadConcurrentTest.java
index 8420e1e7fa2..5b5114a8e47 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadConcurrentTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadConcurrentTest.java
@@ -77,10 +77,10 @@ public class LevelDBAggregateLoadConcurrentTest extends LevelDBTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
LevelDBAggregationRepository repo = new LevelDBAggregationRepository("repo1", "target/data/leveldb.dat");
from("direct:start")
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadTest.java
index e8a03f735ad..8bf0152bae0 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadTest.java
@@ -63,10 +63,10 @@ public class LevelDBAggregateLoadTest extends LevelDBTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("seda:start?size=" + SIZE)
.to("log:input?groupSize=500")
.aggregate(header("id"), new IntegerAggregationStrategy())
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateNotLostRemovedWhenConfirmedTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateNotLostRemovedWhenConfirmedTest.java
index 535800937d6..4cd9225eec3 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateNotLostRemovedWhenConfirmedTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateNotLostRemovedWhenConfirmedTest.java
@@ -68,10 +68,10 @@ public class LevelDBAggregateNotLostRemovedWhenConfirmedTest extends LevelDBTest
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.aggregate(header("id"), new MyAggregationStrategy())
.completionSize(5).aggregationRepository(repo)
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateNotLostTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateNotLostTest.java
index 3bf0a89f22c..fda9e672978 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateNotLostTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateNotLostTest.java
@@ -77,10 +77,10 @@ public class LevelDBAggregateNotLostTest extends LevelDBTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.aggregate(header("id"), new StringAggregationStrategy())
.completionSize(5).aggregationRepository(getRepo())
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverDeadLetterChannelFailedTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverDeadLetterChannelFailedTest.java
index 298845baaa3..e7f9d40a5ec 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverDeadLetterChannelFailedTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverDeadLetterChannelFailedTest.java
@@ -79,10 +79,10 @@ public class LevelDBAggregateRecoverDeadLetterChannelFailedTest extends LevelDBT
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.aggregate(header("id"), new StringAggregationStrategy())
.completionSize(5).aggregationRepository(getRepo())
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverDeadLetterChannelTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverDeadLetterChannelTest.java
index 103e0ccf68e..3a242528991 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverDeadLetterChannelTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverDeadLetterChannelTest.java
@@ -78,10 +78,10 @@ public class LevelDBAggregateRecoverDeadLetterChannelTest extends LevelDBTestSup
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.aggregate(header("id"), new StringAggregationStrategy())
.completionSize(5).aggregationRepository(getRepo())
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverTest.java
index c2496086fd9..b1fee1e250c 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverTest.java
@@ -76,10 +76,10 @@ public class LevelDBAggregateRecoverTest extends LevelDBTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.aggregate(header("id"), new StringAggregationStrategy())
.completionSize(5).aggregationRepository(getRepo())
@@ -88,7 +88,7 @@ public class LevelDBAggregateRecoverTest extends LevelDBTestSupport {
.delay(1000)
// simulate errors the first two times
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
int count = getCounter(getSerializerType()).incrementAndGet();
if (count <= 2) {
throw new IllegalArgumentException("Damn");
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithRedeliveryPolicyTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithRedeliveryPolicyTest.java
index b5bb38656d0..c3b49a88d6c 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithRedeliveryPolicyTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithRedeliveryPolicyTest.java
@@ -80,10 +80,10 @@ public class LevelDBAggregateRecoverWithRedeliveryPolicyTest extends LevelDBTest
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// CHECKSTYLE:OFF
from("direct:start")
.aggregate(header("id"), new StringAggregationStrategy())
@@ -93,7 +93,7 @@ public class LevelDBAggregateRecoverWithRedeliveryPolicyTest extends LevelDBTest
.to("mock:aggregated")
// simulate errors the first three times
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
int count = getCounter(getSerializerType()).incrementAndGet();
if (count <= 3) {
throw new IllegalArgumentException("Damn");
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithSedaTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithSedaTest.java
index fee9a7129ec..d6d06aa8e77 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithSedaTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithSedaTest.java
@@ -73,10 +73,10 @@ public class LevelDBAggregateRecoverWithSedaTest extends LevelDBTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// enable recovery
LevelDBAggregationRepository repo = getRepo();
repo.setUseRecovery(true);
@@ -96,7 +96,7 @@ public class LevelDBAggregateRecoverWithSedaTest extends LevelDBTestSupport {
.delay(1000)
// simulate errors the first two times
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
int count = getCounter(getSerializerType()).incrementAndGet();
if (count <= 2) {
throw new IllegalArgumentException("Damn");
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateSerializedHeadersTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateSerializedHeadersTest.java
index 634aedb09fc..2b2424cfb97 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateSerializedHeadersTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateSerializedHeadersTest.java
@@ -69,10 +69,10 @@ public class LevelDBAggregateSerializedHeadersTest extends LevelDBTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("seda:start?size=" + SIZE)
.to("log:input?groupSize=500")
.aggregate(header("id"), new IntegerAggregationStrategy())
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateTest.java
index 29b1deba8ca..886434e0145 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateTest.java
@@ -58,11 +58,11 @@ public class LevelDBAggregateTest extends LevelDBTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
// START SNIPPET: e1
- public void configure() throws Exception {
+ public void configure() {
// here is the Camel route where we aggregate
from("direct:start")
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateTimeoutCompletionRestartTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateTimeoutCompletionRestartTest.java
index 14b3a198e63..47822e6a38b 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateTimeoutCompletionRestartTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateTimeoutCompletionRestartTest.java
@@ -60,10 +60,10 @@ public class LevelDBAggregateTimeoutCompletionRestartTest extends LevelDBTestSup
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// here is the Camel route where we aggregate
from("direct:start")
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBBigPayloadTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBBigPayloadTest.java
index 0a03d77bc38..4a0067bf472 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBBigPayloadTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBBigPayloadTest.java
@@ -66,10 +66,10 @@ public class LevelDBBigPayloadTest extends LevelDBTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("timer:foo")
.bean(BigPayload.class)
.aggregate(method(LevelDBBigPayloadTest.class, "number"), new UseLatestAggregationStrategy())
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBBinaryTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBBinaryTest.java
index 0258ee084fa..509c52509be 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBBinaryTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBBinaryTest.java
@@ -71,11 +71,11 @@ public class LevelDBBinaryTest extends LevelDBTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
// START SNIPPET: e1
- public void configure() throws Exception {
+ public void configure() {
// here is the Camel route where we aggregate
from("direct:start")
.aggregate(header("id"), new ByteAggregationStrategy())
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBCustomSerializationTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBCustomSerializationTest.java
index 2131d4792db..64f5942d25e 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBCustomSerializationTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBCustomSerializationTest.java
@@ -25,7 +25,6 @@ import java.util.concurrent.TimeUnit;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.core.JsonParser;
-import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.DeserializationContext;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.SerializerProvider;
@@ -76,11 +75,11 @@ public class LevelDBCustomSerializationTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
// START SNIPPET: e1
- public void configure() throws Exception {
+ public void configure() {
// create the leveldb repo
LevelDBAggregationRepository repo = new LevelDBAggregationRepository("repo1", "target/data/leveldb.dat");
@@ -200,7 +199,7 @@ public class LevelDBCustomSerializationTest extends CamelTestSupport {
@Override
public ObjectWithBinaryField deserialize(JsonParser p, DeserializationContext ctxt)
- throws IOException, JsonProcessingException {
+ throws IOException {
JsonNode treeNode = p.getCodec().readTree(p);
String s = treeNode.textValue();
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest.java
index b1cc76825fd..a6fade30b27 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest.java
@@ -75,7 +75,7 @@ public class LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest extends Camel
public static class MyFailProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
int count = counter.incrementAndGet();
if (count <= 3) {
throw new IllegalArgumentException("Damn");
[camel] 03/09: CAMEL-17763: cleaned up unused exceptions in camel-ldif
Posted by or...@apache.org.
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 3d46ff3b6ac3e14131263c953b0506f95f9a05f0
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 17:15:45 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-ldif
---
.../test/java/org/apache/camel/component/ldif/LdifRouteIT.java | 8 ++++----
.../apache/directory/server/core/integ5/DirectoryExtension.java | 3 +--
.../directory/server/core/integ5/ServerAnnotationProcessor.java | 3 +--
3 files changed, 6 insertions(+), 8 deletions(-)
diff --git a/components/camel-ldif/src/test/java/org/apache/camel/component/ldif/LdifRouteIT.java b/components/camel-ldif/src/test/java/org/apache/camel/component/ldif/LdifRouteIT.java
index 53416116129..c1d4fe605a9 100644
--- a/components/camel-ldif/src/test/java/org/apache/camel/component/ldif/LdifRouteIT.java
+++ b/components/camel-ldif/src/test/java/org/apache/camel/component/ldif/LdifRouteIT.java
@@ -111,7 +111,7 @@ public class LdifRouteIT extends LdifTestSupport {
}
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
if (camel != null) {
camel.stop();
}
@@ -325,11 +325,11 @@ public class LdifRouteIT extends LdifTestSupport {
return data;
}
- protected RouteBuilder createRouteBuilder(final String ldapEndpointUrl) throws Exception {
+ protected RouteBuilder createRouteBuilder(final String ldapEndpointUrl) {
return new RouteBuilder() {
// START SNIPPET: route
@Override
- public void configure() throws Exception {
+ public void configure() {
from(ENDPOINT_START).to(ldapEndpointUrl);
}
// END SNIPPET: route
@@ -362,7 +362,7 @@ public class LdifRouteIT extends LdifTestSupport {
setupCamel.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(ENDPOINT_SETUP_START).to(ENDPOINT_LDIF);
}
});
diff --git a/components/camel-ldif/src/test/java/org/apache/directory/server/core/integ5/DirectoryExtension.java b/components/camel-ldif/src/test/java/org/apache/directory/server/core/integ5/DirectoryExtension.java
index 58718efbdec..6728221735e 100644
--- a/components/camel-ldif/src/test/java/org/apache/directory/server/core/integ5/DirectoryExtension.java
+++ b/components/camel-ldif/src/test/java/org/apache/directory/server/core/integ5/DirectoryExtension.java
@@ -25,7 +25,6 @@ import org.apache.directory.api.ldap.model.entry.Entry;
import org.apache.directory.api.ldap.model.entry.Modification;
import org.apache.directory.api.ldap.model.entry.ModificationOperation;
import org.apache.directory.api.ldap.model.exception.LdapException;
-import org.apache.directory.api.ldap.model.exception.LdapInvalidDnException;
import org.apache.directory.api.ldap.model.name.Dn;
import org.apache.directory.api.util.FileUtils;
import org.apache.directory.server.constants.ServerDNConstants;
@@ -239,7 +238,7 @@ public class DirectoryExtension implements BeforeAllCallback, AfterAllCallback,
}
}
- private void updateTlsKey(DirectoryService ds) throws LdapException, LdapInvalidDnException {
+ private void updateTlsKey(DirectoryService ds) throws LdapException {
// Update TLS key for tests. Newer Java 8 releases consider RSA keys
// with less than 1024 bits as insecure and such are disabled by default, see
// http://www.oracle.com/technetwork/java/javase/8-compatibility-guide-2156366.html
diff --git a/components/camel-ldif/src/test/java/org/apache/directory/server/core/integ5/ServerAnnotationProcessor.java b/components/camel-ldif/src/test/java/org/apache/directory/server/core/integ5/ServerAnnotationProcessor.java
index 292b05bba58..5324c9bbb4f 100644
--- a/components/camel-ldif/src/test/java/org/apache/directory/server/core/integ5/ServerAnnotationProcessor.java
+++ b/components/camel-ldif/src/test/java/org/apache/directory/server/core/integ5/ServerAnnotationProcessor.java
@@ -440,8 +440,7 @@ public final class ServerAnnotationProcessor {
return port;
}
- public static KdcServer getKdcServer(Description description, DirectoryService directoryService)
- throws Exception {
+ public static KdcServer getKdcServer(Description description, DirectoryService directoryService) {
CreateKdcServer createLdapServer = description.getAnnotation(CreateKdcServer.class);
return createKdcServer(createLdapServer, directoryService);
[camel] 06/09: CAMEL-17763: cleaned up unused exceptions in camel-kubernetes
Posted by or...@apache.org.
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 d0512e1aa88ab4d2f7b3ef5f8246a1141fdeaad5
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 16:48:06 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-kubernetes
---
.../org/apache/camel/component/KubernetesServer.java | 4 ++--
.../org/apache/camel/component/OpenShiftServer.java | 4 ++--
.../kubernetes/cloud/ServiceCallClientRouteTest.java | 4 ++--
.../cloud/ServiceCallEnvironmentRouteTest.java | 4 ++--
.../cluster/KubernetesClusterServiceTest.java | 15 +++++++--------
.../kubernetes/cluster/TimedLeaderNotifierTest.java | 4 ++--
.../integration/KubernetesConfigMapsConsumerIT.java | 12 ++++++------
.../KubernetesCustomResourcesConsumerIT.java | 10 +++++-----
.../integration/KubernetesNamespacesConsumerIT.java | 10 +++++-----
.../integration/KubernetesNodesConsumerIT.java | 6 +++---
.../consumer/integration/KubernetesPodsConsumerIT.java | 6 +++---
.../KubernetesReplicationControllersConsumerIT.java | 6 +++---
.../integration/KubernetesServicesConsumerIT.java | 10 +++++-----
.../producer/KubernetesConfigMapsProducerTest.java | 14 +++++++-------
.../KubernetesCustomResourcesProducerTest.java | 6 +++---
.../producer/KubernetesDeploymentsProducerTest.java | 12 ++++++------
.../kubernetes/producer/KubernetesHPAProducerTest.java | 18 +++++++++---------
.../kubernetes/producer/KubernetesJobProducerTest.java | 10 +++++-----
.../producer/KubernetesNamespacesProducerTest.java | 12 ++++++------
.../producer/KubernetesNodesProducerTest.java | 12 ++++++------
.../KubernetesPersistentVolumesClaimsProducerTest.java | 10 +++++-----
.../KubernetesPersistentVolumesProducerTest.java | 8 ++++----
.../producer/KubernetesPodsProducerTest.java | 12 ++++++------
.../KubernetesReplicationControllersProducerTest.java | 12 ++++++------
.../producer/KubernetesResourcesQuotaProducerTest.java | 10 +++++-----
.../producer/KubernetesSecretsProducerTest.java | 12 ++++++------
.../KubernetesServiceAccountsProducerTest.java | 10 +++++-----
.../producer/KubernetesServicesProducerTest.java | 12 ++++++------
.../producer/OpenshiftBuildConfigsProducerTest.java | 8 ++++----
.../producer/OpenshiftBuildsProducerTest.java | 10 +++++-----
30 files changed, 141 insertions(+), 142 deletions(-)
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/KubernetesServer.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/KubernetesServer.java
index 1524e27bba0..1f50c32614e 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/KubernetesServer.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/KubernetesServer.java
@@ -52,7 +52,7 @@ public class KubernetesServer implements BeforeEachCallback, AfterEachCallback {
}
@Override
- public void beforeEach(ExtensionContext context) throws Exception {
+ public void beforeEach(ExtensionContext context) {
this.mock = this.crudMode
? new KubernetesMockServer(
new Context(), new MockWebServer(), new HashMap(), new KubernetesCrudDispatcher(), true)
@@ -62,7 +62,7 @@ public class KubernetesServer implements BeforeEachCallback, AfterEachCallback {
}
@Override
- public void afterEach(ExtensionContext context) throws Exception {
+ public void afterEach(ExtensionContext context) {
this.mock.destroy();
this.client.close();
}
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/OpenShiftServer.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/OpenShiftServer.java
index 861d757aa6f..1223c0e8dac 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/OpenShiftServer.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/OpenShiftServer.java
@@ -53,7 +53,7 @@ public class OpenShiftServer implements BeforeEachCallback, AfterEachCallback {
}
@Override
- public void beforeEach(ExtensionContext context) throws Exception {
+ public void beforeEach(ExtensionContext context) {
this.mock = this.curdMode
? new OpenShiftMockServer(
new Context(), new MockWebServer(), new HashMap(), new KubernetesCrudDispatcher(), true)
@@ -63,7 +63,7 @@ public class OpenShiftServer implements BeforeEachCallback, AfterEachCallback {
}
@Override
- public void afterEach(ExtensionContext context) throws Exception {
+ public void afterEach(ExtensionContext context) {
this.mock.destroy();
this.client.close();
}
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallClientRouteTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallClientRouteTest.java
index c9410d9f3e8..8f70851d13b 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallClientRouteTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallClientRouteTest.java
@@ -37,10 +37,10 @@ public class ServiceCallClientRouteTest extends CamelTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
KubernetesConfiguration kubernetesConfiguration = new KubernetesConfiguration();
kubernetesConfiguration.setMasterUrl("http://172.28.128.80:8080");
kubernetesConfiguration.setUsername("admin");
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallEnvironmentRouteTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallEnvironmentRouteTest.java
index 0c68842490a..5a232b3e958 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallEnvironmentRouteTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallEnvironmentRouteTest.java
@@ -36,10 +36,10 @@ public class ServiceCallEnvironmentRouteTest extends CamelTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
ServiceCallConfigurationDefinition config = new ServiceCallConfigurationDefinition();
config.kubernetesEnvServiceDiscovery();
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java
index 9fa4d2bd201..01f05155965 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java
@@ -92,7 +92,7 @@ public class KubernetesClusterServiceTest extends CamelTestSupport {
@ParameterizedTest
@EnumSource(LeaseResourceType.class)
- public void testSimpleLeaderElection(LeaseResourceType type) throws Exception {
+ public void testSimpleLeaderElection(LeaseResourceType type) {
LeaderRecorder mypod1 = addMember("mypod1", type);
LeaderRecorder mypod2 = addMember("mypod2", type);
context.start();
@@ -108,7 +108,7 @@ public class KubernetesClusterServiceTest extends CamelTestSupport {
@ParameterizedTest
@EnumSource(LeaseResourceType.class)
- public void testMultipleMembersLeaderElection(LeaseResourceType type) throws Exception {
+ public void testMultipleMembersLeaderElection(LeaseResourceType type) {
int number = 5;
List<LeaderRecorder> members
= IntStream.range(0, number).mapToObj(i -> addMember("mypod" + i, type)).collect(Collectors.toList());
@@ -125,7 +125,7 @@ public class KubernetesClusterServiceTest extends CamelTestSupport {
}
@Test
- public void testSimpleLeaderElectionWithExistingConfigMap() throws Exception {
+ public void testSimpleLeaderElectionWithExistingConfigMap() {
this.configMapLockSimulator = new ConfigMapLockSimulator("leaders");
configMapLockSimulator.setResource(new ConfigMapBuilder().withNewMetadata().withName("leaders").and().build(), true);
@@ -142,7 +142,7 @@ public class KubernetesClusterServiceTest extends CamelTestSupport {
}
@Test
- public void testSimpleLeaderElectionWithExistingLeases() throws Exception {
+ public void testSimpleLeaderElectionWithExistingLeases() {
LeaseLockSimulator simulator = new LeaseLockSimulator("leaders-mygroup");
simulator.setResource(new LeaseBuilder()
.withNewMetadata().withName("leaders-mygroup")
@@ -164,7 +164,7 @@ public class KubernetesClusterServiceTest extends CamelTestSupport {
@ParameterizedTest
@EnumSource(LeaseResourceType.class)
- public void testLeadershipLoss(LeaseResourceType type) throws Exception {
+ public void testLeadershipLoss(LeaseResourceType type) {
LeaderRecorder mypod1 = addMember("mypod1", type);
LeaderRecorder mypod2 = addMember("mypod2", type);
context.start();
@@ -240,7 +240,7 @@ public class KubernetesClusterServiceTest extends CamelTestSupport {
}
@Test
- public void testSharedConfigMap() throws Exception {
+ public void testSharedConfigMap() {
LeaderRecorder a1 = addMember("a1", LeaseResourceType.ConfigMap);
LeaderRecorder a2 = addMember("a2", LeaseResourceType.ConfigMap);
LeaderRecorder b1 = addMember("b1", "app2", LeaseResourceType.ConfigMap);
@@ -276,8 +276,7 @@ public class KubernetesClusterServiceTest extends CamelTestSupport {
@ParameterizedTest
@MethodSource("rebalancingProvider")
- public void testRebalancing(LeaseResourceType type, int pods, int partitions, int expectedPartitionsPerPod, int tolerance)
- throws Exception {
+ public void testRebalancing(LeaseResourceType type, int pods, int partitions, int expectedPartitionsPerPod, int tolerance) {
Map<String, List<LeaderRecorder>> recorders = createCluster(type, pods, partitions);
context.start();
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/TimedLeaderNotifierTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/TimedLeaderNotifierTest.java
index f0d338563c0..53c7adb2464 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/TimedLeaderNotifierTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/TimedLeaderNotifierTest.java
@@ -46,7 +46,7 @@ public class TimedLeaderNotifierTest {
private volatile Set<String> currentMembers;
@BeforeEach
- public void init() throws Exception {
+ public void init() {
this.context = new DefaultCamelContext();
this.context.start();
@@ -61,7 +61,7 @@ public class TimedLeaderNotifierTest {
}
@AfterEach
- public void destroy() throws Exception {
+ public void destroy() {
this.notifier.stop();
this.context.stop();
}
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesConfigMapsConsumerIT.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesConfigMapsConsumerIT.java
index c72c4e2d1fb..d8508157efa 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesConfigMapsConsumerIT.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesConfigMapsConsumerIT.java
@@ -65,7 +65,7 @@ public class KubernetesConfigMapsConsumerIT extends KubernetesTestSupport {
@Test
@Order(1)
- public void createConfigMapWithProperties() throws Exception {
+ public void createConfigMapWithProperties() {
configureMock();
Exchange ex = template.request("direct:createConfigmap", exchange -> {
@@ -87,7 +87,7 @@ public class KubernetesConfigMapsConsumerIT extends KubernetesTestSupport {
@Test
@Order(2)
- public void createConfigMap() throws Exception {
+ public void createConfigMap() {
configureMock();
Exchange ex = template.request("direct:createConfigmap", exchange -> {
@@ -108,7 +108,7 @@ public class KubernetesConfigMapsConsumerIT extends KubernetesTestSupport {
@ParameterizedTest
@Order(3)
@ValueSource(strings = { "test", "test1" })
- public void deleteConfigMaps(String configMapName) throws Exception {
+ public void deleteConfigMaps(String configMapName) {
Exchange ex = template.request("direct:deleteConfigmap", exchange -> {
exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, "default");
exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_CONFIGMAP_NAME, configMapName);
@@ -125,10 +125,10 @@ public class KubernetesConfigMapsConsumerIT extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:createConfigmap")
.toF("kubernetes-config-maps://%s?oauthToken=%s&operation=createConfigMap", host,
authToken);
@@ -145,7 +145,7 @@ public class KubernetesConfigMapsConsumerIT extends KubernetesTestSupport {
public class KubernetesProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
Message in = exchange.getIn();
ConfigMap cm = exchange.getIn().getBody(ConfigMap.class);
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesCustomResourcesConsumerIT.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesCustomResourcesConsumerIT.java
index d9d727ee94a..eff1b2187a7 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesCustomResourcesConsumerIT.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesCustomResourcesConsumerIT.java
@@ -66,7 +66,7 @@ public class KubernetesCustomResourcesConsumerIT extends KubernetesTestSupport {
@Test
@Order(1)
- public void createCustomResource() throws Exception {
+ public void createCustomResource() {
mockResultEndpoint.expectedMessageCount(2);
mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED",
"MODIFIED");
@@ -88,7 +88,7 @@ public class KubernetesCustomResourcesConsumerIT extends KubernetesTestSupport {
@Test
@Order(2)
- public void deleteCustomResource() throws Exception {
+ public void deleteCustomResource() {
mockResultEndpoint.expectedMessageCount(2);
mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED",
"MODIFIED");
@@ -112,10 +112,10 @@ public class KubernetesCustomResourcesConsumerIT extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:createCustomResource")
.toF("kubernetes-custom-resources://%s/?oauthToken=%s&operation=createCustomResource", host, authToken);
from("direct:deleteCustomResource")
@@ -130,7 +130,7 @@ public class KubernetesCustomResourcesConsumerIT extends KubernetesTestSupport {
public class KubernetesProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
Message in = exchange.getIn();
String json = exchange.getIn().getBody(String.class);
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNamespacesConsumerIT.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNamespacesConsumerIT.java
index a4e789355fc..e34c62cd465 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNamespacesConsumerIT.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNamespacesConsumerIT.java
@@ -56,7 +56,7 @@ public class KubernetesNamespacesConsumerIT extends KubernetesTestSupport {
@Test
@Order(1)
- public void createPod() throws Exception {
+ public void createPod() {
mockResultEndpoint.expectedMessageCount(5);
mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED",
"MODIFIED", "MODIFIED", "MODIFIED", "DELETED");
@@ -76,7 +76,7 @@ public class KubernetesNamespacesConsumerIT extends KubernetesTestSupport {
@Test
@Order(2)
- public void listByLabels() throws Exception {
+ public void listByLabels() {
Exchange ex = template.request("direct:listByLabels", exchange -> {
Map<String, String> labels = new HashMap<>();
labels.put("this", "rocks");
@@ -116,10 +116,10 @@ public class KubernetesNamespacesConsumerIT extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list").toF("kubernetes-namespaces://%s?oauthToken=%s&operation=listNamespaces", host, authToken);
from("direct:listByLabels").toF("kubernetes-namespaces://%s?oauthToken=%s&operation=listNamespacesByLabels",
host, authToken);
@@ -136,7 +136,7 @@ public class KubernetesNamespacesConsumerIT extends KubernetesTestSupport {
public class KubernetesProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
Message in = exchange.getIn();
log.info("Got event with body: " + in.getBody() + " and action "
+ in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNodesConsumerIT.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNodesConsumerIT.java
index 956885b552b..b43c04ebeaf 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNodesConsumerIT.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNodesConsumerIT.java
@@ -68,10 +68,10 @@ public class KubernetesNodesConsumerIT extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:listNode").toF("kubernetes-nodes://%s?oauthToken=%s&operation=listNodes", host, authToken);
fromF("kubernetes-nodes://%s?oauthToken=%s&operation=listNodes", host, authToken)
.process(new KubernetesProcessor()).to(mockResultEndpoint);
@@ -81,7 +81,7 @@ public class KubernetesNodesConsumerIT extends KubernetesTestSupport {
public class KubernetesProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
Message in = exchange.getIn();
Node node = exchange.getIn().getBody(Node.class);
log.info("Got event with node name: " + node.getMetadata().getName() + " and action "
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesPodsConsumerIT.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesPodsConsumerIT.java
index 41ea2abde8f..cd552995678 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesPodsConsumerIT.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesPodsConsumerIT.java
@@ -120,10 +120,10 @@ public class KubernetesPodsConsumerIT extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:createPod").toF("kubernetes-pods://%s?oauthToken=%s&operation=createPod", host, authToken);
from("direct:deletePod").toF("kubernetes-pods://%s?oauthToken=%s&operation=deletePod", host, authToken);
fromF("kubernetes-pods://%s?oauthToken=%s&namespace=default&labelKey=this&labelValue=rocks", host, authToken)
@@ -135,7 +135,7 @@ public class KubernetesPodsConsumerIT extends KubernetesTestSupport {
public class KubernetesProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
Message in = exchange.getIn();
Pod pod = exchange.getIn().getBody(Pod.class);
log.info("Got event with pod name: " + pod.getMetadata().getName() + " and action "
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesReplicationControllersConsumerIT.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesReplicationControllersConsumerIT.java
index b7151bc7df3..71b99b80cb4 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesReplicationControllersConsumerIT.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesReplicationControllersConsumerIT.java
@@ -107,10 +107,10 @@ public class KubernetesReplicationControllersConsumerIT extends KubernetesTestSu
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list").toF(
"kubernetes-replication-controllers://%s?oauthToken=%s&operation=listReplicationControllers", host,
authToken);
@@ -134,7 +134,7 @@ public class KubernetesReplicationControllersConsumerIT extends KubernetesTestSu
public class KubernetesProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
Message in = exchange.getIn();
log.info("Got event with body: " + in.getBody() + " and action "
+ in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesServicesConsumerIT.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesServicesConsumerIT.java
index a89260bd0e1..f4cbfc88c2e 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesServicesConsumerIT.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesServicesConsumerIT.java
@@ -60,7 +60,7 @@ public class KubernetesServicesConsumerIT extends KubernetesTestSupport {
@Test
@Order(1)
- public void createService() throws Exception {
+ public void createService() {
// mockResultEndpoint.expectedMessageCount(1);
mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED");
@@ -94,7 +94,7 @@ public class KubernetesServicesConsumerIT extends KubernetesTestSupport {
@Test
@Order(2)
- public void deleteService() throws Exception {
+ public void deleteService() {
Exchange ex = template.request("direct:deleteService", exchange -> {
exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, "default");
exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_SERVICE_NAME, TEST_SERVICE_NAME);
@@ -109,10 +109,10 @@ public class KubernetesServicesConsumerIT extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list").toF("kubernetes-services://%s?oauthToken=%s&operation=listServices", host, authToken);
from("direct:listByLabels").toF("kubernetes-services://%s?oauthToken=%s&operation=listServicesByLabels", host,
authToken);
@@ -129,7 +129,7 @@ public class KubernetesServicesConsumerIT extends KubernetesTestSupport {
public class KubernetesProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
Message in = exchange.getIn();
log.info("Got event with body: " + in.getBody() + " and action "
+ in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesConfigMapsProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesConfigMapsProducerTest.java
index d59a6ac885b..817e538d8fc 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesConfigMapsProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesConfigMapsProducerTest.java
@@ -43,12 +43,12 @@ public class KubernetesConfigMapsProducerTest extends KubernetesTestSupport {
public KubernetesServer server = new KubernetesServer();
@BindToRegistry("kubernetesClient")
- public KubernetesClient getClient() throws Exception {
+ public KubernetesClient getClient() {
return server.getClient();
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
server.expect().withPath("/api/v1/configmaps")
.andReturn(200, new ConfigMapListBuilder().addNewItem().and().addNewItem().and().addNewItem().and().build())
.once();
@@ -74,7 +74,7 @@ public class KubernetesConfigMapsProducerTest extends KubernetesTestSupport {
}
@Test
- public void getConfigMapTestDefaultNamespace() throws Exception {
+ public void getConfigMapTestDefaultNamespace() {
ObjectMeta meta = new ObjectMeta();
meta.setName("cm1");
server.expect().withPath("/api/v1/namespaces/test/configmaps/cm1")
@@ -90,7 +90,7 @@ public class KubernetesConfigMapsProducerTest extends KubernetesTestSupport {
}
@Test
- public void getConfigMapTestCustomNamespace() throws Exception {
+ public void getConfigMapTestCustomNamespace() {
ObjectMeta meta = new ObjectMeta();
meta.setName("cm1");
server.expect().withPath("/api/v1/namespaces/custom/configmaps/cm1")
@@ -108,7 +108,7 @@ public class KubernetesConfigMapsProducerTest extends KubernetesTestSupport {
}
@Test
- public void createGetAndDeleteConfigMap() throws Exception {
+ public void createGetAndDeleteConfigMap() {
ConfigMap cm1 = new ConfigMapBuilder().withNewMetadata().withName("cm1").withNamespace("test").and().build();
server.expect().withPath("/api/v1/namespaces/test/configmaps/cm1").andReturn(200, cm1).once();
@@ -123,10 +123,10 @@ public class KubernetesConfigMapsProducerTest extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list")
.to("kubernetes-config-maps:///?kubernetesClient=#kubernetesClient&operation=listConfigMaps");
from("direct:listConfigMapsByLabels")
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesCustomResourcesProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesCustomResourcesProducerTest.java
index a4aa43c5512..cc27f933c81 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesCustomResourcesProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesCustomResourcesProducerTest.java
@@ -71,7 +71,7 @@ public class KubernetesCustomResourcesProducerTest extends KubernetesTestSupport
}
@BindToRegistry("kubernetesClient")
- public KubernetesClient getClient() throws Exception {
+ public KubernetesClient getClient() {
return server.getClient();
}
@@ -211,10 +211,10 @@ public class KubernetesCustomResourcesProducerTest extends KubernetesTestSupport
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:getCustomResource")
.toF("kubernetes-custom-resources:///?kubernetesClient=#kubernetesClient&operation=getCustomResource");
from("direct:listCustomResources").toF(
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesDeploymentsProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesDeploymentsProducerTest.java
index 1c193624f5f..61190e74e99 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesDeploymentsProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesDeploymentsProducerTest.java
@@ -42,12 +42,12 @@ public class KubernetesDeploymentsProducerTest extends KubernetesTestSupport {
public KubernetesServer server = new KubernetesServer();
@BindToRegistry("kubernetesClient")
- public KubernetesClient getClient() throws Exception {
+ public KubernetesClient getClient() {
return server.getClient();
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
server.expect().withPath("/apis/extensions/v1beta1/namespaces/test/deployments")
.andReturn(200, new DeploymentListBuilder().addNewItem().and().build()).once();
List<Deployment> result = template.requestBody("direct:list", "", List.class);
@@ -75,7 +75,7 @@ public class KubernetesDeploymentsProducerTest extends KubernetesTestSupport {
}
@Test
- public void createAndDeleteDeployment() throws Exception {
+ public void createAndDeleteDeployment() {
Deployment de1 = new DeploymentBuilder().withNewMetadata().withNamespace("test").withName("de1")
.withResourceVersion("1").withGeneration(2L).endMetadata().withNewSpec()
.withReplicas(0).endSpec().withNewStatus().withReplicas(1).withObservedGeneration(1L).endStatus().build();
@@ -97,7 +97,7 @@ public class KubernetesDeploymentsProducerTest extends KubernetesTestSupport {
}
@Test
- public void createScaleAndDeleteDeployment() throws Exception {
+ public void createScaleAndDeleteDeployment() {
server.expect().withPath("/apis/extensions/v1beta1/namespaces/test/deployments/de1")
.andReturn(200, new DeploymentBuilder().withNewMetadata().withName("de1")
.withResourceVersion("1").endMetadata().withNewSpec().withReplicas(5).endSpec().withNewStatus()
@@ -122,10 +122,10 @@ public class KubernetesDeploymentsProducerTest extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list")
.toF("kubernetes-deployments:///?kubernetesClient=#kubernetesClient&operation=listDeployments");
from("direct:listByLabels")
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesHPAProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesHPAProducerTest.java
index 491d7c3fd05..17791425bf3 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesHPAProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesHPAProducerTest.java
@@ -44,12 +44,12 @@ public class KubernetesHPAProducerTest extends KubernetesTestSupport {
public KubernetesServer server = new KubernetesServer();
@BindToRegistry("kubernetesClient")
- public KubernetesClient getClient() throws Exception {
+ public KubernetesClient getClient() {
return server.getClient();
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
server.expect().withPath("/apis/autoscaling/v1/namespaces/test/horizontalpodautoscalers")
.andReturn(200, new HorizontalPodAutoscalerListBuilder().addNewItem().and().addNewItem().and().addNewItem()
.and().build())
@@ -68,7 +68,7 @@ public class KubernetesHPAProducerTest extends KubernetesTestSupport {
Exchange ex = template.request("direct:listByLabels", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
Map<String, String> labels = new HashMap<>();
labels.put("key1", "value1");
labels.put("key2", "value2");
@@ -82,7 +82,7 @@ public class KubernetesHPAProducerTest extends KubernetesTestSupport {
}
@Test
- public void getHPATest() throws Exception {
+ public void getHPATest() {
HorizontalPodAutoscaler hpa1
= new HorizontalPodAutoscalerBuilder().withNewMetadata().withName("hpa1").withNamespace("test").and().build();
HorizontalPodAutoscaler hpa2
@@ -95,7 +95,7 @@ public class KubernetesHPAProducerTest extends KubernetesTestSupport {
Exchange ex = template.request("direct:getHPA", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, "test");
exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_HPA_NAME, "hpa1");
}
@@ -107,7 +107,7 @@ public class KubernetesHPAProducerTest extends KubernetesTestSupport {
}
@Test
- public void deleteHPATest() throws Exception {
+ public void deleteHPATest() {
HorizontalPodAutoscaler hpa1
= new HorizontalPodAutoscalerBuilder().withNewMetadata().withName("hpa1").withNamespace("test").and().build();
server.expect().withPath("/apis/autoscaling/v1/namespaces/test/horizontalpodautoscalers/hpa1").andReturn(200, hpa1)
@@ -116,7 +116,7 @@ public class KubernetesHPAProducerTest extends KubernetesTestSupport {
Exchange ex = template.request("direct:deleteHPA", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, "test");
exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_HPA_NAME, "hpa1");
}
@@ -128,10 +128,10 @@ public class KubernetesHPAProducerTest extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list").to("kubernetes-hpa:///?kubernetesClient=#kubernetesClient&operation=listHPA");
from("direct:listByLabels")
.to("kubernetes-hpa:///?kubernetesClient=#kubernetesClient&operation=listHPAByLabels");
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesJobProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesJobProducerTest.java
index d797ac8d37d..a49eff69470 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesJobProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesJobProducerTest.java
@@ -43,12 +43,12 @@ public class KubernetesJobProducerTest extends KubernetesTestSupport {
public KubernetesServer server = new KubernetesServer();
@BindToRegistry("kubernetesClient")
- public KubernetesClient getClient() throws Exception {
+ public KubernetesClient getClient() {
return server.getClient();
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
server.expect().withPath("/apis/batch/v1/namespaces/test/jobs")
.andReturn(200, new JobListBuilder().addNewItem().and().addNewItem().and().addNewItem().and().build())
.once();
@@ -74,7 +74,7 @@ public class KubernetesJobProducerTest extends KubernetesTestSupport {
}
@Test
- public void getJobTest() throws Exception {
+ public void getJobTest() {
Job sc1 = new JobBuilder().withNewMetadata().withName("sc1").withNamespace("test").and().build();
server.expect().withPath("/apis/batch/v1/namespaces/test/jobs/sc1").andReturn(200, sc1).once();
@@ -89,10 +89,10 @@ public class KubernetesJobProducerTest extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list").to("kubernetes-job:///?kubernetesClient=#kubernetesClient&operation=listJob");
from("direct:listByLabels")
.to("kubernetes-job:///?kubernetesClient=#kubernetesClient&operation=listJobByLabels");
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNamespacesProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNamespacesProducerTest.java
index e1f1c5f47ff..ac149508f8b 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNamespacesProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNamespacesProducerTest.java
@@ -41,12 +41,12 @@ public class KubernetesNamespacesProducerTest extends KubernetesTestSupport {
public KubernetesServer server = new KubernetesServer();
@BindToRegistry("kubernetesClient")
- public KubernetesClient getClient() throws Exception {
+ public KubernetesClient getClient() {
return server.getClient();
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
server.expect().withPath("/api/v1/namespaces")
.andReturn(200, new NamespaceListBuilder().addNewItem().and().addNewItem().and().addNewItem().and().build())
.once();
@@ -55,7 +55,7 @@ public class KubernetesNamespacesProducerTest extends KubernetesTestSupport {
}
@Test
- public void getNamespace() throws Exception {
+ public void getNamespace() {
ObjectMeta meta = new ObjectMeta();
meta.setName("test");
server.expect().withPath("/api/v1/namespaces/test").andReturn(200, new NamespaceBuilder().withMetadata(meta).build())
@@ -70,7 +70,7 @@ public class KubernetesNamespacesProducerTest extends KubernetesTestSupport {
}
@Test
- public void createAndDeleteNamespace() throws Exception {
+ public void createAndDeleteNamespace() {
Namespace ns1 = new NamespaceBuilder().withNewMetadata().withName("ns1").endMetadata().build();
server.expect().withPath("/api/v1/namespaces/ns1").andReturn(200, ns1).once();
@@ -83,10 +83,10 @@ public class KubernetesNamespacesProducerTest extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list").to("kubernetes-namespaces:///?kubernetesClient=#kubernetesClient&operation=listNamespaces");
from("direct:getNs").to("kubernetes-namespaces:///?kubernetesClient=#kubernetesClient&operation=getNamespace");
from("direct:deleteNamespace")
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducerTest.java
index befeba51480..3449a712dff 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducerTest.java
@@ -45,12 +45,12 @@ public class KubernetesNodesProducerTest extends KubernetesTestSupport {
public KubernetesServer server = new KubernetesServer();
@BindToRegistry("kubernetesClient")
- public KubernetesClient getClient() throws Exception {
+ public KubernetesClient getClient() {
return server.getClient();
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
server.expect().withPath("/api/v1/nodes").andReturn(200, new NodeListBuilder().addNewItem().and().build()).once();
List<Node> result = template.requestBody("direct:list", "", List.class);
@@ -74,7 +74,7 @@ public class KubernetesNodesProducerTest extends KubernetesTestSupport {
}
@Test
- public void createNodeTest() throws Exception {
+ public void createNodeTest() {
ObjectMeta meta = new ObjectMeta();
meta.setName("test");
server.expect().withPath("/api/v1/nodes").andReturn(200, new NodeBuilder().withMetadata(meta).build()).once();
@@ -94,7 +94,7 @@ public class KubernetesNodesProducerTest extends KubernetesTestSupport {
}
@Test
- public void deleteNode() throws Exception {
+ public void deleteNode() {
Node node1 = new NodeBuilder().withNewMetadata().withName("node1").withNamespace("test").and().build();
server.expect().withPath("/api/v1/nodes/node1").andReturn(200, node1).once();
@@ -107,10 +107,10 @@ public class KubernetesNodesProducerTest extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list").toF("kubernetes-nodes:///?kubernetesClient=#kubernetesClient&operation=listNodes");
from("direct:listByLabels")
.toF("kubernetes-nodes:///?kubernetesClient=#kubernetesClient&operation=listNodesByLabels");
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesClaimsProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesClaimsProducerTest.java
index 397c91b5667..261692c5e05 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesClaimsProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesClaimsProducerTest.java
@@ -44,12 +44,12 @@ public class KubernetesPersistentVolumesClaimsProducerTest extends KubernetesTes
public KubernetesServer server = new KubernetesServer();
@BindToRegistry("kubernetesClient")
- public KubernetesClient getClient() throws Exception {
+ public KubernetesClient getClient() {
return server.getClient();
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
server.expect().withPath("/api/v1/namespaces/test/persistentvolumeclaims")
.andReturn(200,
new PersistentVolumeClaimListBuilder().addNewItem().and().addNewItem().and().addNewItem().and().build())
@@ -80,7 +80,7 @@ public class KubernetesPersistentVolumesClaimsProducerTest extends KubernetesTes
}
@Test
- public void createListAndDeletePersistentVolumeClaim() throws Exception {
+ public void createListAndDeletePersistentVolumeClaim() {
ObjectMeta meta = new ObjectMeta();
meta.setName("pvc1");
server.expect().withPath("/api/v1/namespaces/test/persistentvolumeclaims/pvc1")
@@ -96,10 +96,10 @@ public class KubernetesPersistentVolumesClaimsProducerTest extends KubernetesTes
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list").to(
"kubernetes-persistent-volumes-claims:///?kubernetesClient=#kubernetesClient&operation=listPersistentVolumesClaims");
from("direct:listByLabels").to(
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesProducerTest.java
index 4b317349517..7013aed2783 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesProducerTest.java
@@ -40,12 +40,12 @@ public class KubernetesPersistentVolumesProducerTest extends KubernetesTestSuppo
public KubernetesServer server = new KubernetesServer();
@BindToRegistry("kubernetesClient")
- public KubernetesClient getClient() throws Exception {
+ public KubernetesClient getClient() {
return server.getClient();
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
server.expect().withPath("/api/v1/persistentvolumes")
.andReturn(200,
new PersistentVolumeListBuilder().addNewItem().and().addNewItem().and().addNewItem().and().build())
@@ -74,10 +74,10 @@ public class KubernetesPersistentVolumesProducerTest extends KubernetesTestSuppo
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list").to(
"kubernetes-persistent-volumes:///?kubernetesClient=#kubernetesClient&operation=listPersistentVolumes");
from("direct:listByLabels").to(
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPodsProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPodsProducerTest.java
index a9fa3d04ba8..80e6db521f5 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPodsProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPodsProducerTest.java
@@ -42,12 +42,12 @@ public class KubernetesPodsProducerTest extends KubernetesTestSupport {
public KubernetesServer server = new KubernetesServer();
@BindToRegistry("kubernetesClient")
- public KubernetesClient getClient() throws Exception {
+ public KubernetesClient getClient() {
return server.getClient();
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
server.expect().withPath("/api/v1/pods")
.andReturn(200, new PodListBuilder().addNewItem().and().addNewItem().and().addNewItem().and().build()).once();
server.expect().withPath("/api/v1/namespaces/test/pods")
@@ -79,7 +79,7 @@ public class KubernetesPodsProducerTest extends KubernetesTestSupport {
}
@Test
- public void getPodTest() throws Exception {
+ public void getPodTest() {
Pod pod1 = new PodBuilder().withNewMetadata().withName("pod1").withNamespace("test").and().build();
Pod pod2 = new PodBuilder().withNewMetadata().withName("pod2").withNamespace("ns1").and().build();
@@ -96,7 +96,7 @@ public class KubernetesPodsProducerTest extends KubernetesTestSupport {
}
@Test
- public void deletePod() throws Exception {
+ public void deletePod() {
Pod pod1 = new PodBuilder().withNewMetadata().withName("pod1").withNamespace("test").and().build();
server.expect().withPath("/api/v1/namespaces/test/pods/pod1").andReturn(200, pod1).once();
@@ -111,10 +111,10 @@ public class KubernetesPodsProducerTest extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list").to("kubernetes-pods:///?kubernetesClient=#kubernetesClient&operation=listPods");
from("direct:listByLabels")
.to("kubernetes-pods:///?kubernetesClient=#kubernetesClient&operation=listPodsByLabels");
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesReplicationControllersProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesReplicationControllersProducerTest.java
index 8a95fdd7cc0..4fcb4b23813 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesReplicationControllersProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesReplicationControllersProducerTest.java
@@ -43,12 +43,12 @@ public class KubernetesReplicationControllersProducerTest extends KubernetesTest
public KubernetesServer server = new KubernetesServer();
@BindToRegistry("kubernetesClient")
- public KubernetesClient getClient() throws Exception {
+ public KubernetesClient getClient() {
return server.getClient();
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
server.expect().withPath("/api/v1/replicationcontrollers")
.andReturn(200,
new ReplicationControllerListBuilder().addNewItem().and().addNewItem().and().addNewItem().and().build())
@@ -77,7 +77,7 @@ public class KubernetesReplicationControllersProducerTest extends KubernetesTest
}
@Test
- public void getReplicationControllerTest() throws Exception {
+ public void getReplicationControllerTest() {
ReplicationController rc1
= new ReplicationControllerBuilder().withNewMetadata().withName("rc1").withNamespace("test").and().build();
@@ -93,7 +93,7 @@ public class KubernetesReplicationControllersProducerTest extends KubernetesTest
}
@Test
- public void createAndDeleteReplicationController() throws Exception {
+ public void createAndDeleteReplicationController() {
server.expect().withPath("/api/v1/namespaces/test/replicationcontrollers/repl1")
.andReturn(200, new ReplicationControllerBuilder().withNewMetadata().withName("repl1")
.withResourceVersion("1").endMetadata().withNewSpec().withReplicas(0).endSpec().withNewStatus()
@@ -142,10 +142,10 @@ public class KubernetesReplicationControllersProducerTest extends KubernetesTest
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list").to(
"kubernetes-replication-controllers:///?kubernetesClient=#kubernetesClient&operation=listReplicationControllers");
from("direct:listByLabels").to(
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesResourcesQuotaProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesResourcesQuotaProducerTest.java
index 7a472ffbfbe..9cf7fa36522 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesResourcesQuotaProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesResourcesQuotaProducerTest.java
@@ -40,12 +40,12 @@ public class KubernetesResourcesQuotaProducerTest extends KubernetesTestSupport
public KubernetesServer server = new KubernetesServer();
@BindToRegistry("kubernetesClient")
- public KubernetesClient getClient() throws Exception {
+ public KubernetesClient getClient() {
return server.getClient();
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
server.expect().withPath("/api/v1/resourcequotas")
.andReturn(200, new ResourceQuotaListBuilder().addNewItem().and().addNewItem().and().addNewItem().and().build())
.once();
@@ -55,7 +55,7 @@ public class KubernetesResourcesQuotaProducerTest extends KubernetesTestSupport
}
@Test
- public void deleteResourceQuota() throws Exception {
+ public void deleteResourceQuota() {
ResourceQuota rq1 = new ResourceQuotaBuilder().withNewMetadata().withName("rq1").withNamespace("test").and().build();
server.expect().withPath("/api/v1/namespaces/test/resourcequotas/rq1").andReturn(200, rq1).once();
@@ -70,10 +70,10 @@ public class KubernetesResourcesQuotaProducerTest extends KubernetesTestSupport
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list")
.to("kubernetes-resources-quota:///?kubernetesClient=#kubernetesClient&operation=listResourcesQuota");
from("direct:delete")
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesSecretsProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesSecretsProducerTest.java
index 8dde6f948b6..363a9ffd3d3 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesSecretsProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesSecretsProducerTest.java
@@ -43,12 +43,12 @@ public class KubernetesSecretsProducerTest extends KubernetesTestSupport {
public KubernetesServer server = new KubernetesServer();
@BindToRegistry("kubernetesClient")
- public KubernetesClient getClient() throws Exception {
+ public KubernetesClient getClient() {
return server.getClient();
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
server.expect().withPath("/api/v1/secrets")
.andReturn(200, new SecretListBuilder().addNewItem().and().addNewItem().and().addNewItem().and().build())
.once();
@@ -75,7 +75,7 @@ public class KubernetesSecretsProducerTest extends KubernetesTestSupport {
}
@Test
- public void getSecretTest() throws Exception {
+ public void getSecretTest() {
Secret sc1 = new SecretBuilder().withNewMetadata().withName("sc1").withNamespace("test").and().build();
server.expect().withPath("/api/v1/namespaces/test/secrets/sc1").andReturn(200, sc1).once();
@@ -90,7 +90,7 @@ public class KubernetesSecretsProducerTest extends KubernetesTestSupport {
}
@Test
- public void createAndDeleteSecret() throws Exception {
+ public void createAndDeleteSecret() {
Secret sc1 = new SecretBuilder().withNewMetadata().withName("sc1").withNamespace("test").and().build();
server.expect().withPath("/api/v1/namespaces/test/secrets/sc1").andReturn(200, sc1).once();
@@ -105,10 +105,10 @@ public class KubernetesSecretsProducerTest extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list").to("kubernetes-secrets:///?kubernetesClient=#kubernetesClient&operation=listSecrets");
from("direct:listByLabels")
.to("kubernetes-secrets:///?kubernetesClient=#kubernetesClient&operation=listSecretsByLabels");
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServiceAccountsProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServiceAccountsProducerTest.java
index 5dece9766f2..bd54fff8a57 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServiceAccountsProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServiceAccountsProducerTest.java
@@ -42,12 +42,12 @@ public class KubernetesServiceAccountsProducerTest extends KubernetesTestSupport
public KubernetesServer server = new KubernetesServer();
@BindToRegistry("kubernetesClient")
- public KubernetesClient getClient() throws Exception {
+ public KubernetesClient getClient() {
return server.getClient();
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
server.expect().withPath("/api/v1/serviceaccounts")
.andReturn(200,
new ServiceAccountListBuilder().addNewItem().and().addNewItem().and().addNewItem().and().build())
@@ -76,7 +76,7 @@ public class KubernetesServiceAccountsProducerTest extends KubernetesTestSupport
}
@Test
- public void createAndDeleteServiceAccount() throws Exception {
+ public void createAndDeleteServiceAccount() {
ServiceAccount pod1 = new ServiceAccountBuilder().withNewMetadata().withName("sa1").withNamespace("test").and().build();
server.expect().withPath("/api/v1/namespaces/test/serviceaccounts/sa1").andReturn(200, pod1).once();
@@ -91,10 +91,10 @@ public class KubernetesServiceAccountsProducerTest extends KubernetesTestSupport
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list")
.to("kubernetes-service-accounts:///?kubernetesClient=#kubernetesClient&operation=listServiceAccounts");
from("direct:listByLabels").to(
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServicesProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServicesProducerTest.java
index 59b90e546a7..64163fae41b 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServicesProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServicesProducerTest.java
@@ -44,12 +44,12 @@ public class KubernetesServicesProducerTest extends KubernetesTestSupport {
public KubernetesServer server = new KubernetesServer();
@BindToRegistry("kubernetesClient")
- public KubernetesClient getClient() throws Exception {
+ public KubernetesClient getClient() {
return server.getClient();
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
server.expect().withPath("/api/v1/services")
.andReturn(200, new ServiceListBuilder().addNewItem().and().addNewItem().and().addNewItem().and().build())
.once();
@@ -74,7 +74,7 @@ public class KubernetesServicesProducerTest extends KubernetesTestSupport {
}
@Test
- public void getServiceTest() throws Exception {
+ public void getServiceTest() {
Service se1 = new ServiceBuilder().withNewMetadata().withName("se1").withNamespace("test").and().build();
server.expect().withPath("/api/v1/namespaces/test/services/se1").andReturn(200, se1).once();
@@ -89,7 +89,7 @@ public class KubernetesServicesProducerTest extends KubernetesTestSupport {
}
@Test
- public void createAndDeleteService() throws Exception {
+ public void createAndDeleteService() {
Service se1 = new ServiceBuilder().withNewMetadata().withName("se1").withNamespace("test").and().build();
server.expect().withPath("/api/v1/namespaces/test/services/se1").andReturn(200, se1).once();
@@ -105,10 +105,10 @@ public class KubernetesServicesProducerTest extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list").to("kubernetes-services:///?kubernetesClient=#kubernetesClient&operation=listServices");
from("direct:listByLabels")
.to("kubernetes-services:///?kubernetesClient=#kubernetesClient&operation=listServicesByLabels");
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildConfigsProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildConfigsProducerTest.java
index a4e2576a301..5861b4b38cc 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildConfigsProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildConfigsProducerTest.java
@@ -37,7 +37,7 @@ public class OpenshiftBuildConfigsProducerTest extends KubernetesTestSupport {
public OpenShiftServer server = new OpenShiftServer();
@BindToRegistry("client")
- public NamespacedOpenShiftClient loadClient() throws Exception {
+ public NamespacedOpenShiftClient loadClient() {
server.expect().withPath("/apis/build.openshift.io/v1/namespaces/test/buildconfigs")
.andReturn(200, new BuildConfigListBuilder().build()).once();
@@ -59,17 +59,17 @@ public class OpenshiftBuildConfigsProducerTest extends KubernetesTestSupport {
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
List<BuildConfig> result = template.requestBody("direct:list", "", List.class);
assertEquals(3, result.size());
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list").to("openshift-build-configs:///?operation=listBuildConfigs&kubernetesClient=#client");
from("direct:listByLabels")
.to("openshift-build-configs:///?kubernetesClient=#client&operation=listBuildConfigsByLabels");
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildsProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildsProducerTest.java
index 78926242303..8c15d2e3b8f 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildsProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildsProducerTest.java
@@ -57,18 +57,18 @@ public class OpenshiftBuildsProducerTest extends KubernetesTestSupport {
}
@Test
- public void listTest() throws Exception {
+ public void listTest() {
List<Build> result = template.requestBody("direct:list", "", List.class);
assertEquals(2, result.size());
}
@Test
- public void listByLabelsTest() throws Exception {
+ public void listByLabelsTest() {
Exchange ex = template.request("direct:listByLabels", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
Map<String, String> labels = new HashMap<>();
labels.put("key1", "value1");
labels.put("key2", "value2");
@@ -82,10 +82,10 @@ public class OpenshiftBuildsProducerTest extends KubernetesTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:list").to("openshift-builds:///?operation=listBuilds&kubernetesClient=#client");
from("direct:listByLabels").to("openshift-builds:///?operation=listBuildsByLabels&kubernetesClient=#client");
}
[camel] 01/09: CAMEL-17763: cleaned up unused exceptions in camel-lra
Posted by or...@apache.org.
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 c596eb135cfc362da824988d7f628a316bc2d470
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 17:17:40 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-lra
---
.../java/org/apache/camel/service/lra/AbstractLRATestSupport.java | 2 +-
.../src/test/java/org/apache/camel/service/lra/LRACreditIT.java | 8 ++++----
.../src/test/java/org/apache/camel/service/lra/LRAFailuresIT.java | 4 ++--
.../src/test/java/org/apache/camel/service/lra/LRAManualIT.java | 4 ++--
.../src/test/java/org/apache/camel/service/lra/LRAOptionsIT.java | 6 +++---
.../src/test/java/org/apache/camel/service/lra/LRATimeoutIT.java | 4 ++--
6 files changed, 14 insertions(+), 14 deletions(-)
diff --git a/components/camel-lra/src/test/java/org/apache/camel/service/lra/AbstractLRATestSupport.java b/components/camel-lra/src/test/java/org/apache/camel/service/lra/AbstractLRATestSupport.java
index 492387a6f51..106c6e35f23 100644
--- a/components/camel-lra/src/test/java/org/apache/camel/service/lra/AbstractLRATestSupport.java
+++ b/components/camel-lra/src/test/java/org/apache/camel/service/lra/AbstractLRATestSupport.java
@@ -65,7 +65,7 @@ public abstract class AbstractLRATestSupport extends CamelTestSupport {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
restConfiguration()
.port(getServerPort());
}
diff --git a/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRACreditIT.java b/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRACreditIT.java
index 8cbca280d28..dccbdc15d49 100644
--- a/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRACreditIT.java
+++ b/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRACreditIT.java
@@ -43,7 +43,7 @@ public class LRACreditIT extends AbstractLRATestSupport {
private CreditService creditService;
@Test
- public void testCreditExhausted() throws Exception {
+ public void testCreditExhausted() {
// total credit is 100
buy(20, false, false);
buy(70, false, false);
@@ -55,7 +55,7 @@ public class LRACreditIT extends AbstractLRATestSupport {
}
@Test
- public void testTotalCompensation() throws Exception {
+ public void testTotalCompensation() {
// total credit is 100
for (int i = 0; i < 10; i++) {
if (i % 2 == 0) {
@@ -88,11 +88,11 @@ public class LRACreditIT extends AbstractLRATestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
orderManagerService = new OrderManagerService();
diff --git a/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRAFailuresIT.java b/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRAFailuresIT.java
index 46fde726958..a010a2650d0 100644
--- a/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRAFailuresIT.java
+++ b/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRAFailuresIT.java
@@ -61,11 +61,11 @@ public class LRAFailuresIT extends AbstractLRATestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:saga-compensate")
.saga()
diff --git a/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRAManualIT.java b/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRAManualIT.java
index 1f1d4aab578..5d82cfa294a 100644
--- a/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRAManualIT.java
+++ b/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRAManualIT.java
@@ -62,10 +62,10 @@ public class LRAManualIT extends AbstractLRATestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:saga")
.saga()
diff --git a/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRAOptionsIT.java b/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRAOptionsIT.java
index 11cbb5d30f0..736db907a58 100644
--- a/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRAOptionsIT.java
+++ b/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRAOptionsIT.java
@@ -59,17 +59,17 @@ public class LRAOptionsIT extends AbstractLRATestSupport {
}
@Test
- public void testRouteDoesNotHangOnOptionError() throws Exception {
+ public void testRouteDoesNotHangOnOptionError() {
assertThrows(RuntimeCamelException.class,
() -> template.sendBody("direct:wrong-expression", "Hello"));
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:workflow")
.saga()
diff --git a/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRATimeoutIT.java b/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRATimeoutIT.java
index 6b15cc54698..ab9d1d85cb1 100644
--- a/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRATimeoutIT.java
+++ b/components/camel-lra/src/test/java/org/apache/camel/service/lra/LRATimeoutIT.java
@@ -66,11 +66,11 @@ public class LRATimeoutIT extends AbstractLRATestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:saga")
.saga()