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
The following commit(s) were added to refs/heads/main by this push:
new 0d33d6f (chores): replace usages of RuntimeException with
RuntimeCamelException
0d33d6f is described below
commit 0d33d6f7b5d8493a3ef560f88d7a2401edffa78c
Author: Otavio Rodolfo Piske <[email protected]>
AuthorDate: Wed Sep 22 07:53:50 2021 +0200
(chores): replace usages of RuntimeException with RuntimeCamelException
components:
components/camel-activemq, components/camel-amqp, components/camel-atomix,
components/camel-aws, components/camel-azure, components/camel-bonita,
components/camel-box, components/camel-cdi, components/camel-cmis,
components/camel-consul, components/camel-crypto, components/camel-dozer,
components/camel-elytron, components/camel-etcd3, components/camel-facebook,
components/camel-file, components/camel-flink, components/camel-google,
components/camel-gora, components/camel-graphql, components/camel-hazelcast,
components/camel-hbase, components/camel-iec60870,
components/camel-infinispan,
components/camel-pdf, components/camel-pulsar, components/camel-rabbitmq
---
.../apache/camel/component/activemq/DlqTest.java | 3 ++-
.../apache/camel/component/activemq/JmsBridge.java | 3 ++-
.../camel/component/activemq/JmsJdbcXATest.java | 3 ++-
.../apache/camel/component/amqp/AMQPRouteTest.java | 5 +++--
...AtomixClientClusteredRoutePolicyFactoryMain.java | 3 ++-
.../camel/component/aws2/ddb/Ddb2Endpoint.java | 3 ++-
.../component/azure/cosmosdb/CosmosDbProducer.java | 3 ++-
.../azure/servicebus/ServiceBusConsumer.java | 3 ++-
.../azure/servicebus/ServiceBusProducer.java | 3 ++-
.../camel/component/bonita/api/BonitaAPI.java | 3 ++-
.../camel/component/box/AbstractBoxITSupport.java | 3 ++-
.../component/box/BoxCollaborationsManagerIT.java | 3 ++-
.../camel/component/box/BoxUsersManagerIT.java | 3 ++-
.../java/org/apache/camel/cdi/CdiSpiHelper.java | 6 ++++--
.../camel/component/cmis/CMISTestSupport.java | 3 ++-
.../ConsulClusteredRoutePolicyFactoryMain.java | 3 ++-
.../crypto/DigitalSignatureConfiguration.java | 4 ++--
.../apache/camel/component/dozer/CustomMapper.java | 9 +++++----
.../component/elytron/ElytronSecurityProvider.java | 3 ++-
.../aggregate/Etcd3AggregationRepository.java | 21 +++++++++++----------
.../facebook/CamelFacebookTestSupport.java | 3 ++-
.../component/file/cluster/FileLockClusterView.java | 3 ++-
.../flink/annotations/AnnotatedDataSetCallback.java | 3 ++-
.../bigquery/integration/BigQueryITSupport.java | 3 ++-
.../calendar/AbstractGoogleCalendarTestSupport.java | 4 +++-
.../drive/AbstractGoogleDriveTestSupport.java | 5 +++--
.../google/mail/AbstractGoogleMailTestSupport.java | 4 +++-
.../google/pubsub/GooglePubsubComponent.java | 3 ++-
.../google/pubsub/consumer/AcknowledgeSync.java | 3 ++-
.../component/google/pubsub/PubsubTestSupport.java | 7 ++++---
.../apache/camel/component/gora/GoraProducer.java | 5 +++--
.../component/graphql/server/GraphqlFactory.java | 3 ++-
.../hazelcast/HazelcastAggregationRepository.java | 3 ++-
.../ReplicatedHazelcastAggregationRepository.java | 3 ++-
.../apache/camel/component/hbase/HBaseEndpoint.java | 3 ++-
.../iec60870/AbstractConnectionMultiplexor.java | 3 ++-
.../component/iec60870/server/ServerComponent.java | 3 ++-
.../component/iec60870/server/ServerInstance.java | 3 ++-
.../cluster/InfinispanClusterConfiguration.java | 3 ++-
.../apache/camel/component/pdf/PdfAppendTest.java | 5 +++--
.../apache/camel/component/pdf/PdfCreationTest.java | 5 +++--
.../integration/PulsarConsumerInAsynchronousIT.java | 3 ++-
.../integration/RabbitMQDeadLetterArgsIT.java | 5 +++--
43 files changed, 110 insertions(+), 65 deletions(-)
diff --git
a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/DlqTest.java
b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/DlqTest.java
index 496694f..0d231ae 100644
---
a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/DlqTest.java
+++
b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/DlqTest.java
@@ -24,6 +24,7 @@ import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.util.Wait;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.activemq.support.ActiveMQSpringTestSupport;
import org.apache.camel.test.infra.activemq.services.ActiveMQEmbeddedService;
import
org.apache.camel.test.infra.activemq.services.ActiveMQEmbeddedServiceBuilder;
@@ -76,7 +77,7 @@ public class DlqTest extends ActiveMQSpringTestSupport {
public static class CanError {
public String enrich(String body) {
LOG.info("Got body: " + body);
- throw new RuntimeException("won't enrich today!");
+ throw new RuntimeCamelException("won't enrich today!");
}
}
}
diff --git
a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsBridge.java
b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsBridge.java
index 4f82cac..091d725 100644
---
a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsBridge.java
+++
b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsBridge.java
@@ -35,6 +35,7 @@ import org.apache.activemq.broker.ProducerBrokerExchange;
import org.apache.activemq.broker.TransportConnector;
import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ConnectionInfo;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.activemq.support.ActiveMQSpringTestSupport;
import org.apache.camel.test.infra.activemq.services.ActiveMQEmbeddedService;
import
org.apache.camel.test.infra.activemq.services.ActiveMQEmbeddedServiceBuilder;
@@ -121,7 +122,7 @@ public class JmsBridge extends ActiveMQSpringTestSupport {
org.apache.activemq.command.Message messageSend)
throws Exception {
if (sendCount.incrementAndGet() <= errorLimit) {
- throw new RuntimeException("You need to try send " +
errorLimit + " times!");
+ throw new RuntimeCamelException("You need to try send " +
errorLimit + " times!");
}
super.send(producerExchange, messageSend);
}
diff --git
a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsJdbcXATest.java
b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsJdbcXATest.java
index fc04938..3bb22c9 100644
---
a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsJdbcXATest.java
+++
b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsJdbcXATest.java
@@ -35,6 +35,7 @@ import org.apache.activemq.broker.ConnectionContext;
import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.TransactionId;
import org.apache.activemq.util.Wait;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.activemq.support.ActiveMQSpringTestSupport;
import org.apache.camel.test.infra.activemq.services.ActiveMQEmbeddedService;
import
org.apache.camel.test.infra.activemq.services.ActiveMQEmbeddedServiceBuilder;
@@ -210,7 +211,7 @@ public class JmsJdbcXATest extends
ActiveMQSpringTestSupport {
} });
broker.start();
} catch (Exception e) {
- throw new RuntimeException("Failed to start broker", e);
+ throw new RuntimeCamelException("Failed to start broker", e);
}
return super.createApplicationContext();
diff --git
a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
index 009498a..334ec84 100644
---
a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
+++
b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
@@ -27,6 +27,7 @@ import javax.jms.TextMessage;
import org.apache.camel.CamelContext;
import org.apache.camel.EndpointInject;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.AvailablePortFinder;
@@ -112,7 +113,7 @@ public class AMQPRouteTest extends CamelTestSupport {
facade.setApplicationProperty("cheese", 123);
facade.setTracingAnnotation("cheese", 456);
} catch (JMSException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
});
resultEndpoint.assertIsSatisfied();
@@ -129,7 +130,7 @@ public class AMQPRouteTest extends CamelTestSupport {
facade.setApplicationProperty("cheese", 123);
facade.setTracingAnnotation("cheese", 456);
} catch (JMSException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
});
resultEndpoint.assertIsSatisfied();
diff --git
a/components/camel-atomix/src/test/java/org/apache/camel/component/atomix/cluster/AtomixClientClusteredRoutePolicyFactoryMain.java
b/components/camel-atomix/src/test/java/org/apache/camel/component/atomix/cluster/AtomixClientClusteredRoutePolicyFactoryMain.java
index 513b0e7..0dfb5fe 100644
---
a/components/camel-atomix/src/test/java/org/apache/camel/component/atomix/cluster/AtomixClientClusteredRoutePolicyFactoryMain.java
+++
b/components/camel-atomix/src/test/java/org/apache/camel/component/atomix/cluster/AtomixClientClusteredRoutePolicyFactoryMain.java
@@ -21,6 +21,7 @@ import java.util.UUID;
import io.atomix.catalyst.transport.Address;
import io.atomix.copycat.server.storage.StorageLevel;
import org.apache.camel.CamelContext;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.cluster.ClusteredRoutePolicyFactory;
import org.apache.camel.impl.engine.ExplicitCamelContextNameStrategy;
@@ -50,7 +51,7 @@ public final class
AtomixClientClusteredRoutePolicyFactoryMain {
context.addService(service);
context.addRoutePolicyFactory(ClusteredRoutePolicyFactory.forNamespace("my-ns"));
} catch (Exception e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
});
diff --git
a/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddb/Ddb2Endpoint.java
b/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddb/Ddb2Endpoint.java
index 0e56167..aa52490 100644
---
a/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddb/Ddb2Endpoint.java
+++
b/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddb/Ddb2Endpoint.java
@@ -21,6 +21,7 @@ import org.apache.camel.Component;
import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.aws2.ddb.client.Ddb2ClientFactory;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
@@ -155,7 +156,7 @@ public class Ddb2Endpoint extends ScheduledPollEndpoint {
}
}
- throw new RuntimeException("Table " + tableName + " never went
active");
+ throw new RuntimeCamelException("Table " + tableName + " never went
active");
}
private boolean isTableActive(TableDescription tableDescription) {
diff --git
a/components/camel-azure/camel-azure-cosmosdb/src/main/java/org/apache/camel/component/azure/cosmosdb/CosmosDbProducer.java
b/components/camel-azure/camel-azure-cosmosdb/src/main/java/org/apache/camel/component/azure/cosmosdb/CosmosDbProducer.java
index 94d1aa4..3874594 100644
---
a/components/camel-azure/camel-azure-cosmosdb/src/main/java/org/apache/camel/component/azure/cosmosdb/CosmosDbProducer.java
+++
b/components/camel-azure/camel-azure-cosmosdb/src/main/java/org/apache/camel/component/azure/cosmosdb/CosmosDbProducer.java
@@ -32,6 +32,7 @@ import com.azure.cosmos.models.ThroughputResponse;
import org.apache.camel.AsyncCallback;
import org.apache.camel.Endpoint;
import org.apache.camel.Exchange;
+import org.apache.camel.RuntimeCamelException;
import
org.apache.camel.component.azure.cosmosdb.client.CosmosAsyncClientWrapper;
import
org.apache.camel.component.azure.cosmosdb.operations.CosmosDbClientOperations;
import
org.apache.camel.component.azure.cosmosdb.operations.CosmosDbContainerOperations;
@@ -122,7 +123,7 @@ public class CosmosDbProducer extends DefaultAsyncProducer {
if (fnToInvoke != null) {
fnToInvoke.accept(exchange, callback);
} else {
- throw new RuntimeException("Operation not supported. Value: " +
operationsToInvoke);
+ throw new RuntimeCamelException("Operation not supported. Value: "
+ operationsToInvoke);
}
}
diff --git
a/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConsumer.java
b/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConsumer.java
index af6e520..fcf1f5c 100644
---
a/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConsumer.java
+++
b/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConsumer.java
@@ -26,6 +26,7 @@ import org.apache.camel.Exchange;
import org.apache.camel.ExtendedExchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
+import org.apache.camel.RuntimeCamelException;
import
org.apache.camel.component.azure.servicebus.client.ServiceBusClientFactory;
import
org.apache.camel.component.azure.servicebus.client.ServiceBusReceiverAsyncClientWrapper;
import
org.apache.camel.component.azure.servicebus.operations.ServiceBusReceiverOperations;
@@ -120,7 +121,7 @@ public class ServiceBusConsumer extends DefaultConsumer {
if (fnToInvoke != null) {
fnToInvoke.run();
} else {
- throw new RuntimeException("Operation not supported. Value: " +
operationsToInvoke);
+ throw new RuntimeCamelException("Operation not supported. Value: "
+ operationsToInvoke);
}
}
diff --git
a/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusProducer.java
b/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusProducer.java
index 444f0f4..9d9a28f 100644
---
a/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusProducer.java
+++
b/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusProducer.java
@@ -28,6 +28,7 @@ import
com.azure.messaging.servicebus.ServiceBusSenderAsyncClient;
import org.apache.camel.AsyncCallback;
import org.apache.camel.Endpoint;
import org.apache.camel.Exchange;
+import org.apache.camel.RuntimeCamelException;
import
org.apache.camel.component.azure.servicebus.client.ServiceBusClientFactory;
import
org.apache.camel.component.azure.servicebus.client.ServiceBusSenderAsyncClientWrapper;
import
org.apache.camel.component.azure.servicebus.operations.ServiceBusSenderOperations;
@@ -134,7 +135,7 @@ public class ServiceBusProducer extends
DefaultAsyncProducer {
if (fnToInvoke != null) {
fnToInvoke.accept(exchange, callback);
} else {
- throw new RuntimeException("Operation not supported. Value: " +
operationsToInvoke);
+ throw new RuntimeCamelException("Operation not supported. Value: "
+ operationsToInvoke);
}
}
diff --git
a/components/camel-bonita/src/main/java/org/apache/camel/component/bonita/api/BonitaAPI.java
b/components/camel-bonita/src/main/java/org/apache/camel/component/bonita/api/BonitaAPI.java
index 409818b..b76e8a8 100644
---
a/components/camel-bonita/src/main/java/org/apache/camel/component/bonita/api/BonitaAPI.java
+++
b/components/camel-bonita/src/main/java/org/apache/camel/component/bonita/api/BonitaAPI.java
@@ -24,6 +24,7 @@ import javax.ws.rs.client.WebTarget;
import javax.ws.rs.core.GenericType;
import javax.ws.rs.core.MediaType;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.bonita.api.model.CaseCreationResponse;
import org.apache.camel.component.bonita.api.model.ProcessDefinitionResponse;
import org.apache.camel.component.bonita.api.util.BonitaAPIConfig;
@@ -58,7 +59,7 @@ public class BonitaAPI {
if (!listProcess.isEmpty()) {
return listProcess.get(0);
} else {
- throw new RuntimeException(
+ throw new RuntimeCamelException(
"The process with name " + processName + " has not been
retrieved");
}
}
diff --git
a/components/camel-box/camel-box-component/src/test/java/org/apache/camel/component/box/AbstractBoxITSupport.java
b/components/camel-box/camel-box-component/src/test/java/org/apache/camel/component/box/AbstractBoxITSupport.java
index ee59d5f..1e6ce06 100644
---
a/components/camel-box/camel-box-component/src/test/java/org/apache/camel/component/box/AbstractBoxITSupport.java
+++
b/components/camel-box/camel-box-component/src/test/java/org/apache/camel/component/box/AbstractBoxITSupport.java
@@ -24,6 +24,7 @@ import com.box.sdk.BoxFile;
import com.box.sdk.BoxFolder;
import org.apache.camel.CamelContext;
import org.apache.camel.CamelExecutionException;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.support.PropertyBindingSupport;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.TestInstance;
@@ -47,7 +48,7 @@ public class AbstractBoxITSupport extends CamelTestSupport {
try {
properties.load(AbstractBoxITSupport.class.getResourceAsStream(TEST_OPTIONS_PROPERTIES));
} catch (Exception e) {
- throw new RuntimeException(
+ throw new RuntimeCamelException(
String.format("%s could not be loaded: %s",
TEST_OPTIONS_PROPERTIES, e.getMessage()),
e);
}
diff --git
a/components/camel-box/camel-box-component/src/test/java/org/apache/camel/component/box/BoxCollaborationsManagerIT.java
b/components/camel-box/camel-box-component/src/test/java/org/apache/camel/component/box/BoxCollaborationsManagerIT.java
index 9413b10..8d2493d 100644
---
a/components/camel-box/camel-box-component/src/test/java/org/apache/camel/component/box/BoxCollaborationsManagerIT.java
+++
b/components/camel-box/camel-box-component/src/test/java/org/apache/camel/component/box/BoxCollaborationsManagerIT.java
@@ -26,6 +26,7 @@ import com.box.sdk.BoxCollaboration;
import com.box.sdk.BoxFolder;
import com.box.sdk.BoxUser;
import com.box.sdk.CreateUserParams;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.box.api.BoxCollaborationsManager;
import org.apache.camel.component.box.internal.BoxApiCollection;
@@ -102,7 +103,7 @@ public class BoxCollaborationsManagerIT extends
AbstractBoxITSupport {
assertNotNull(result, "addFolderCollaboration result");
LOG.debug("addFolderCollaboration: " + result);
} catch (BoxAPIException e) {
- throw new RuntimeException(
+ throw new RuntimeCamelException(
String.format("Box API returned the error code %d\n\n%s",
e.getResponseCode(), e.getResponse()), e);
} finally {
if (user != null) {
diff --git
a/components/camel-box/camel-box-component/src/test/java/org/apache/camel/component/box/BoxUsersManagerIT.java
b/components/camel-box/camel-box-component/src/test/java/org/apache/camel/component/box/BoxUsersManagerIT.java
index 01fcc31..7d1cdeb 100644
---
a/components/camel-box/camel-box-component/src/test/java/org/apache/camel/component/box/BoxUsersManagerIT.java
+++
b/components/camel-box/camel-box-component/src/test/java/org/apache/camel/component/box/BoxUsersManagerIT.java
@@ -25,6 +25,7 @@ import com.box.sdk.BoxAPIException;
import com.box.sdk.BoxUser;
import com.box.sdk.CreateUserParams;
import com.box.sdk.EmailAlias;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.box.api.BoxUsersManager;
import org.apache.camel.component.box.internal.BoxApiCollection;
@@ -187,7 +188,7 @@ public class BoxUsersManagerIT extends AbstractBoxITSupport
{
try {
emailAlias = testUser.addEmailAlias(CAMEL_TEST_USER_EMAIL_ALIAS);
} catch (BoxAPIException e) {
- throw new RuntimeException(
+ throw new RuntimeCamelException(
String.format("Box API returned the error code %d\n\n%s",
e.getResponseCode(), e.getResponse()), e);
}
diff --git
a/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiSpiHelper.java
b/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiSpiHelper.java
index e9708f1..cda4e85 100644
--- a/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiSpiHelper.java
+++ b/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiSpiHelper.java
@@ -45,6 +45,7 @@ import javax.enterprise.inject.spi.BeanManager;
import javax.enterprise.util.Nonbinding;
import org.apache.camel.CamelContext;
+import org.apache.camel.RuntimeCamelException;
import static java.security.AccessController.doPrivileged;
import static java.util.Comparator.comparing;
@@ -216,9 +217,10 @@ final class CdiSpiHelper {
joiner.add(method.getName() + "=" +
method.invoke(annotation).toString());
} catch (NullPointerException |
IllegalArgumentException | IllegalAccessException
| InvocationTargetException cause) {
- throw new RuntimeException(
+ throw new RuntimeCamelException(
"Error while accessing member [" +
method.getName() + "]"
- + " of annotation
[" + annotation.annotationType().getName() + "]",
+ + " of
annotation [" + annotation.annotationType().getName()
+ + "]",
cause);
}
},
diff --git
a/components/camel-cmis/src/test/java/org/apache/camel/component/cmis/CMISTestSupport.java
b/components/camel-cmis/src/test/java/org/apache/camel/component/cmis/CMISTestSupport.java
index 78af985..82b4728 100644
---
a/components/camel-cmis/src/test/java/org/apache/camel/component/cmis/CMISTestSupport.java
+++
b/components/camel-cmis/src/test/java/org/apache/camel/component/cmis/CMISTestSupport.java
@@ -26,6 +26,7 @@ import java.util.List;
import java.util.Map;
import org.apache.camel.Exchange;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.support.DefaultExchange;
import org.apache.camel.test.AvailablePortFinder;
import org.apache.camel.test.junit5.CamelTestSupport;
@@ -84,7 +85,7 @@ public class CMISTestSupport extends CamelTestSupport {
List<String> notDeltedIdList = ((Folder) cmisObject)
.deleteTree(true, UnfileObject.DELETE, true);
if (notDeltedIdList != null && notDeltedIdList.size() > 0) {
- throw new RuntimeException("Cannot empty repo");
+ throw new RuntimeCamelException("Cannot empty repo");
}
} else {
cmisObject.delete(true);
diff --git
a/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulClusteredRoutePolicyFactoryMain.java
b/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulClusteredRoutePolicyFactoryMain.java
index f619baf..1d21586 100644
---
a/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulClusteredRoutePolicyFactoryMain.java
+++
b/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulClusteredRoutePolicyFactoryMain.java
@@ -19,6 +19,7 @@ package org.apache.camel.component.consul.cluster;
import java.util.UUID;
import org.apache.camel.CamelContext;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.cluster.ClusteredRoutePolicyFactory;
import org.apache.camel.impl.engine.ExplicitCamelContextNameStrategy;
@@ -46,7 +47,7 @@ public final class ConsulClusteredRoutePolicyFactoryMain {
context.addService(service);
context.addRoutePolicyFactory(ClusteredRoutePolicyFactory.forNamespace("my-ns"));
} catch (Exception e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
});
diff --git
a/components/camel-crypto/src/main/java/org/apache/camel/component/crypto/DigitalSignatureConfiguration.java
b/components/camel-crypto/src/main/java/org/apache/camel/component/crypto/DigitalSignatureConfiguration.java
index 70077a6..08ed9a0 100644
---
a/components/camel-crypto/src/main/java/org/apache/camel/component/crypto/DigitalSignatureConfiguration.java
+++
b/components/camel-crypto/src/main/java/org/apache/camel/component/crypto/DigitalSignatureConfiguration.java
@@ -177,7 +177,7 @@ public class DigitalSignatureConfiguration implements
Cloneable, CamelContextAwa
try {
pk = (PrivateKey) keystore.getKey(alias, password);
} catch (Exception e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
if (pk == null) {
@@ -367,7 +367,7 @@ public class DigitalSignatureConfiguration implements
Cloneable, CamelContextAwa
try {
this.keystore = keyStoreParameters.createKeyStore();
} catch (Exception e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
}
diff --git
a/components/camel-dozer/src/main/java/org/apache/camel/component/dozer/CustomMapper.java
b/components/camel-dozer/src/main/java/org/apache/camel/component/dozer/CustomMapper.java
index 39d2523..763a48e 100644
---
a/components/camel-dozer/src/main/java/org/apache/camel/component/dozer/CustomMapper.java
+++
b/components/camel-dozer/src/main/java/org/apache/camel/component/dozer/CustomMapper.java
@@ -23,6 +23,7 @@ import java.util.Arrays;
import java.util.Iterator;
import java.util.List;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.spi.ClassResolver;
/**
@@ -99,7 +100,7 @@ public class CustomMapper extends BaseConverter {
String prm = prms[ndx + 2];
String[] parts = prm.split("=");
if (parts.length != 2) {
- throw new RuntimeException("Value missing for parameter "
+ prm);
+ throw new RuntimeCamelException("Value missing for
parameter " + prm);
}
prmTypesAndValues[ndx][0] = parts[0];
prmTypesAndValues[ndx][1] = parts[1];
@@ -123,12 +124,12 @@ public class CustomMapper extends BaseConverter {
method = selectMethod(customClass, sourceClass);
}
} catch (Exception e) {
- throw new RuntimeException("Failed to load custom function", e);
+ throw new RuntimeCamelException("Failed to load custom function",
e);
}
// Verify that we found a matching method
if (method == null) {
- throw new RuntimeException("No eligible custom function methods in
" + className);
+ throw new RuntimeCamelException("No eligible custom function
methods in " + className);
}
// Invoke the custom mapping method
@@ -139,7 +140,7 @@ public class CustomMapper extends BaseConverter {
return method.invoke(customObj, source);
}
} catch (Exception e) {
- throw new RuntimeException("Error while invoking custom function",
e);
+ throw new RuntimeCamelException("Error while invoking custom
function", e);
}
}
diff --git
a/components/camel-elytron/src/main/java/org/apache/camel/component/elytron/ElytronSecurityProvider.java
b/components/camel-elytron/src/main/java/org/apache/camel/component/elytron/ElytronSecurityProvider.java
index 8857959..c51ba6a 100644
---
a/components/camel-elytron/src/main/java/org/apache/camel/component/elytron/ElytronSecurityProvider.java
+++
b/components/camel-elytron/src/main/java/org/apache/camel/component/elytron/ElytronSecurityProvider.java
@@ -28,6 +28,7 @@ import
io.undertow.security.handlers.AuthenticationConstraintHandler;
import io.undertow.server.HttpHandler;
import io.undertow.server.HttpServerExchange;
import io.undertow.util.StatusCodes;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.undertow.spi.UndertowSecurityProvider;
import
org.wildfly.elytron.web.undertow.server.ElytronContextAssociationHandler;
import org.wildfly.elytron.web.undertow.server.ElytronRunAsHandler;
@@ -124,7 +125,7 @@ public class ElytronSecurityProvider implements
UndertowSecurityProvider {
try {
return
Collections.singletonList(httpAuthenticationFactory.createMechanism(mechanismName));
} catch (HttpAuthenticationException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}).build();
}
diff --git
a/components/camel-etcd3/src/main/java/org/apache/camel/component/etcd3/processor/aggregate/Etcd3AggregationRepository.java
b/components/camel-etcd3/src/main/java/org/apache/camel/component/etcd3/processor/aggregate/Etcd3AggregationRepository.java
index db5f84d..5c290e6 100644
---
a/components/camel-etcd3/src/main/java/org/apache/camel/component/etcd3/processor/aggregate/Etcd3AggregationRepository.java
+++
b/components/camel-etcd3/src/main/java/org/apache/camel/component/etcd3/processor/aggregate/Etcd3AggregationRepository.java
@@ -46,6 +46,7 @@ import io.etcd.jetcd.options.GetOption;
import io.etcd.jetcd.options.PutOption;
import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.spi.OptimisticLockingAggregationRepository;
import org.apache.camel.spi.RecoverableAggregationRepository;
import org.apache.camel.support.DefaultExchange;
@@ -182,7 +183,7 @@ public class Etcd3AggregationRepository extends
ServiceSupport
.commit();
} catch (InterruptedException | ExecutionException | IOException e) {
LOG.error(e.getMessage(), e);
- throw new RuntimeException(e.getMessage(), e);
+ throw new RuntimeCamelException(e.getMessage(), e);
}
return unmarshallExchange(camelContext, newHolder);
}
@@ -204,7 +205,7 @@ public class Etcd3AggregationRepository extends
ServiceSupport
return scanned;
} catch (InterruptedException | ExecutionException e) {
LOG.error(e.getMessage(), e);
- throw new RuntimeException(e.getMessage(), e);
+ throw new RuntimeCamelException(e.getMessage(), e);
}
} else {
LOG.warn(
@@ -226,7 +227,7 @@ public class Etcd3AggregationRepository extends
ServiceSupport
return useRecovery ? unmarshallExchange(camelContext, holder) :
null;
} catch (InterruptedException | ExecutionException | IOException |
ClassNotFoundException e) {
LOG.error(e.getMessage(), e);
- throw new RuntimeException(e.getMessage(), e);
+ throw new RuntimeCamelException(e.getMessage(), e);
}
}
@@ -328,7 +329,7 @@ public class Etcd3AggregationRepository extends
ServiceSupport
return unmarshallExchange(camelContext, holder);
} catch (InterruptedException | ExecutionException | IOException |
ClassNotFoundException e) {
LOG.error(e.getMessage(), e);
- throw new RuntimeException(e.getMessage(), e);
+ throw new RuntimeCamelException(e.getMessage(), e);
}
}
@@ -364,7 +365,7 @@ public class Etcd3AggregationRepository extends
ServiceSupport
} catch (InterruptedException | ExecutionException |
ClassNotFoundException | IOException e) {
LOG.error(e.getMessage(), e);
- throw new RuntimeException(e.getMessage(), e);
+ throw new RuntimeCamelException(e.getMessage(), e);
}
LOG.trace("Removed an exchange with ID {} for key {} in an
optimistic manner.", exchange.getExchangeId(),
key);
@@ -382,7 +383,7 @@ public class Etcd3AggregationRepository extends
ServiceSupport
exchange.getExchangeId(), key);
} catch (IOException | InterruptedException |
ExecutionException e) {
LOG.error(e.getMessage(), e);
- throw new RuntimeException(e.getMessage(), e);
+ throw new RuntimeCamelException(e.getMessage(), e);
}
}
@@ -415,7 +416,7 @@ public class Etcd3AggregationRepository extends
ServiceSupport
"Put an exchange with ID {} for key {} into a
recoverable storage in a thread-safe manner.",
exchange.getExchangeId(), key);
} catch (Throwable throwable) {
- throw new RuntimeException(throwable.getMessage(),
throwable);
+ throw new RuntimeCamelException(throwable.getMessage(),
throwable);
}
} else {
CompletableFuture<DeleteResponse> completableDeleteResponse =
kvClient
@@ -424,7 +425,7 @@ public class Etcd3AggregationRepository extends
ServiceSupport
completableDeleteResponse.get();
} catch (InterruptedException | ExecutionException e) {
LOG.error(e.getMessage(), e);
- throw new RuntimeException(e.getMessage(), e);
+ throw new RuntimeCamelException(e.getMessage(), e);
}
}
}
@@ -440,7 +441,7 @@ public class Etcd3AggregationRepository extends
ServiceSupport
completableDeleteResponse.get();
} catch (InterruptedException | ExecutionException e) {
LOG.error(e.getMessage(), e);
- throw new RuntimeException(e.getMessage(), e);
+ throw new RuntimeCamelException(e.getMessage(), e);
}
}
}
@@ -457,7 +458,7 @@ public class Etcd3AggregationRepository extends
ServiceSupport
scanned = Collections.unmodifiableSet(keys);
} catch (InterruptedException | ExecutionException e) {
LOG.error(e.getMessage(), e);
- throw new RuntimeException(e.getMessage(), e);
+ throw new RuntimeCamelException(e.getMessage(), e);
}
return scanned;
}
diff --git
a/components/camel-facebook/src/test/java/org/apache/camel/component/facebook/CamelFacebookTestSupport.java
b/components/camel-facebook/src/test/java/org/apache/camel/component/facebook/CamelFacebookTestSupport.java
index cf09f3a..6d1ec19 100644
---
a/components/camel-facebook/src/test/java/org/apache/camel/component/facebook/CamelFacebookTestSupport.java
+++
b/components/camel-facebook/src/test/java/org/apache/camel/component/facebook/CamelFacebookTestSupport.java
@@ -24,6 +24,7 @@ import java.util.Map;
import java.util.Properties;
import org.apache.camel.CamelContext;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.facebook.config.FacebookConfiguration;
import org.apache.camel.support.PropertyBindingSupport;
import org.apache.camel.test.junit5.CamelTestSupport;
@@ -56,7 +57,7 @@ public abstract class CamelFacebookTestSupport extends
CamelTestSupport {
properties.load(inStream);
return properties;
} catch (IOException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
diff --git
a/components/camel-file/src/main/java/org/apache/camel/component/file/cluster/FileLockClusterView.java
b/components/camel-file/src/main/java/org/apache/camel/component/file/cluster/FileLockClusterView.java
index 655996a..700996f 100644
---
a/components/camel-file/src/main/java/org/apache/camel/component/file/cluster/FileLockClusterView.java
+++
b/components/camel-file/src/main/java/org/apache/camel/component/file/cluster/FileLockClusterView.java
@@ -30,6 +30,7 @@ import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.cluster.CamelClusterMember;
import org.apache.camel.support.cluster.AbstractCamelClusterView;
import org.apache.camel.util.IOHelper;
@@ -153,7 +154,7 @@ public class FileLockClusterView extends
AbstractCamelClusterView {
} catch (OverlappingFileLockException e) {
LOGGER.debug("Lock on file {} not acquired ", path);
} catch (Exception e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
}
diff --git
a/components/camel-flink/src/main/java/org/apache/camel/component/flink/annotations/AnnotatedDataSetCallback.java
b/components/camel-flink/src/main/java/org/apache/camel/component/flink/annotations/AnnotatedDataSetCallback.java
index 78da055..9c1a945 100644
---
a/components/camel-flink/src/main/java/org/apache/camel/component/flink/annotations/AnnotatedDataSetCallback.java
+++
b/components/camel-flink/src/main/java/org/apache/camel/component/flink/annotations/AnnotatedDataSetCallback.java
@@ -23,6 +23,7 @@ import java.util.Arrays;
import java.util.List;
import org.apache.camel.CamelContext;
+import org.apache.camel.RuntimeCamelException;
import org.apache.flink.api.java.DataSet;
import static org.apache.camel.support.ObjectHelper.invokeMethodSafe;
@@ -75,7 +76,7 @@ public class AnnotatedDataSetCallback implements
org.apache.camel.component.flin
Object[] args = arguments.toArray(new Object[arguments.size()]);
return invokeMethodSafe(callbackMethod, objectWithCallback, args);
} catch (IllegalAccessException | InvocationTargetException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
}
diff --git
a/components/camel-google/camel-google-bigquery/src/test/java/org/apache/camel/component/google/bigquery/integration/BigQueryITSupport.java
b/components/camel-google/camel-google-bigquery/src/test/java/org/apache/camel/component/google/bigquery/integration/BigQueryITSupport.java
index b3c2ec6..6b8a7a9 100644
---
a/components/camel-google/camel-google-bigquery/src/test/java/org/apache/camel/component/google/bigquery/integration/BigQueryITSupport.java
+++
b/components/camel-google/camel-google-bigquery/src/test/java/org/apache/camel/component/google/bigquery/integration/BigQueryITSupport.java
@@ -36,6 +36,7 @@ import com.google.cloud.bigquery.TableInfo;
import com.google.cloud.bigquery.TableResult;
import org.apache.camel.BindToRegistry;
import org.apache.camel.CamelContext;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.google.bigquery.GoogleBigQueryComponent;
import
org.apache.camel.component.google.bigquery.GoogleBigQueryConnectionFactory;
import
org.apache.camel.component.google.bigquery.sql.GoogleBigQuerySQLComponent;
@@ -72,7 +73,7 @@ public class BigQueryITSupport extends CamelTestSupport {
testProperties.load(fileIn);
} catch (Exception e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
return testProperties;
diff --git
a/components/camel-google/camel-google-calendar/src/test/java/org/apache/camel/component/google/calendar/AbstractGoogleCalendarTestSupport.java
b/components/camel-google/camel-google-calendar/src/test/java/org/apache/camel/component/google/calendar/AbstractGoogleCalendarTestSupport.java
index 4f36792..3c54d62f 100644
---
a/components/camel-google/camel-google-calendar/src/test/java/org/apache/camel/component/google/calendar/AbstractGoogleCalendarTestSupport.java
+++
b/components/camel-google/camel-google-calendar/src/test/java/org/apache/camel/component/google/calendar/AbstractGoogleCalendarTestSupport.java
@@ -25,6 +25,7 @@ import java.util.Properties;
import com.google.api.services.calendar.model.Calendar;
import org.apache.camel.CamelContext;
import org.apache.camel.CamelExecutionException;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.support.PropertyBindingSupport;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.AfterEach;
@@ -52,7 +53,8 @@ public class AbstractGoogleCalendarTestSupport extends
CamelTestSupport {
try {
properties.load(AbstractGoogleCalendarTestSupport.class.getResourceAsStream(TEST_OPTIONS_PROPERTIES));
} catch (Exception e) {
- throw new RuntimeException(String.format("%s could not be loaded:
%s", TEST_OPTIONS_PROPERTIES, e.getMessage()), e);
+ throw new RuntimeCamelException(
+ String.format("%s could not be loaded: %s",
TEST_OPTIONS_PROPERTIES, e.getMessage()), e);
}
return properties;
diff --git
a/components/camel-google/camel-google-drive/src/test/java/org/apache/camel/component/google/drive/AbstractGoogleDriveTestSupport.java
b/components/camel-google/camel-google-drive/src/test/java/org/apache/camel/component/google/drive/AbstractGoogleDriveTestSupport.java
index f2013fd..a129415 100644
---
a/components/camel-google/camel-google-drive/src/test/java/org/apache/camel/component/google/drive/AbstractGoogleDriveTestSupport.java
+++
b/components/camel-google/camel-google-drive/src/test/java/org/apache/camel/component/google/drive/AbstractGoogleDriveTestSupport.java
@@ -29,6 +29,7 @@ import com.google.api.client.http.FileContent;
import com.google.api.services.drive.model.File;
import org.apache.camel.CamelContext;
import org.apache.camel.CamelExecutionException;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.support.PropertyBindingSupport;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.TestInstance;
@@ -64,7 +65,7 @@ public abstract class AbstractGoogleDriveTestSupport extends
CamelTestSupport {
private static Properties loadProperties() {
final InputStream in =
AbstractGoogleDriveTestSupport.class.getResourceAsStream(TEST_OPTIONS_PROPERTIES);
if (in == null) {
- throw new RuntimeException(TEST_OPTIONS_PROPERTIES + " could not
be found");
+ throw new RuntimeCamelException(TEST_OPTIONS_PROPERTIES + " could
not be found");
}
final StringBuilder builder = new StringBuilder();
@@ -82,7 +83,7 @@ public abstract class AbstractGoogleDriveTestSupport extends
CamelTestSupport {
return properties;
} catch (IOException e) {
- throw new RuntimeException(
+ throw new RuntimeCamelException(
String.format("%s could not be loaded: %s",
TEST_OPTIONS_PROPERTIES, e.getMessage()),
e);
}
diff --git
a/components/camel-google/camel-google-mail/src/test/java/org/apache/camel/component/google/mail/AbstractGoogleMailTestSupport.java
b/components/camel-google/camel-google-mail/src/test/java/org/apache/camel/component/google/mail/AbstractGoogleMailTestSupport.java
index ca9cd93..1305881 100644
---
a/components/camel-google/camel-google-mail/src/test/java/org/apache/camel/component/google/mail/AbstractGoogleMailTestSupport.java
+++
b/components/camel-google/camel-google-mail/src/test/java/org/apache/camel/component/google/mail/AbstractGoogleMailTestSupport.java
@@ -22,6 +22,7 @@ import java.util.Properties;
import org.apache.camel.CamelContext;
import org.apache.camel.CamelExecutionException;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.support.PropertyBindingSupport;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.TestInstance;
@@ -42,7 +43,8 @@ public class AbstractGoogleMailTestSupport extends
CamelTestSupport {
try {
properties.load(AbstractGoogleMailTestSupport.class.getResourceAsStream(TEST_OPTIONS_PROPERTIES));
} catch (Exception e) {
- throw new RuntimeException(String.format("%s could not be loaded:
%s", TEST_OPTIONS_PROPERTIES, e.getMessage()), e);
+ throw new RuntimeCamelException(
+ String.format("%s could not be loaded: %s",
TEST_OPTIONS_PROPERTIES, e.getMessage()), e);
}
return properties;
}
diff --git
a/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubComponent.java
b/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubComponent.java
index 83b7732..1f9b69f 100644
---
a/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubComponent.java
+++
b/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubComponent.java
@@ -40,6 +40,7 @@ import com.google.common.cache.RemovalListener;
import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import org.apache.camel.Endpoint;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.annotations.Component;
import org.apache.camel.support.DefaultComponent;
@@ -95,7 +96,7 @@ public class GooglePubsubComponent extends DefaultComponent {
try {
publisher.awaitTermination(publisherTerminationTimeout,
TimeUnit.MILLISECONDS);
} catch (Exception e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
};
diff --git
a/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/AcknowledgeSync.java
b/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/AcknowledgeSync.java
index 9756483..df44986 100644
---
a/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/AcknowledgeSync.java
+++
b/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/AcknowledgeSync.java
@@ -22,6 +22,7 @@ import java.util.List;
import com.google.cloud.pubsub.v1.stub.SubscriberStub;
import com.google.pubsub.v1.AcknowledgeRequest;
import org.apache.camel.Exchange;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.google.pubsub.GooglePubsubConstants;
import org.apache.camel.spi.Synchronization;
@@ -43,7 +44,7 @@ public class AcknowledgeSync implements Synchronization {
try {
subscriber.acknowledgeCallable().call(ackRequest);
} catch (Exception e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
diff --git
a/components/camel-google/camel-google-pubsub/src/test/java/org/apache/camel/component/google/pubsub/PubsubTestSupport.java
b/components/camel-google/camel-google-pubsub/src/test/java/org/apache/camel/component/google/pubsub/PubsubTestSupport.java
index 041aaae..d979871 100644
---
a/components/camel-google/camel-google-pubsub/src/test/java/org/apache/camel/component/google/pubsub/PubsubTestSupport.java
+++
b/components/camel-google/camel-google-pubsub/src/test/java/org/apache/camel/component/google/pubsub/PubsubTestSupport.java
@@ -36,6 +36,7 @@ import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import org.apache.camel.BindToRegistry;
import org.apache.camel.CamelContext;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.test.infra.google.pubsub.services.GooglePubSubService;
import
org.apache.camel.test.infra.google.pubsub.services.GooglePubSubServiceFactory;
import org.apache.camel.test.junit5.CamelTestSupport;
@@ -59,7 +60,7 @@ public class PubsubTestSupport extends CamelTestSupport {
testProperties.load(fileIn);
} catch (Exception e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
return testProperties;
@@ -150,7 +151,7 @@ public class PubsubTestSupport extends CamelTestSupport {
.setCredentialsProvider(credentialsProvider)
.build());
} catch (IOException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
@@ -165,7 +166,7 @@ public class PubsubTestSupport extends CamelTestSupport {
.setCredentialsProvider(credentialsProvider)
.build());
} catch (IOException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
}
diff --git
a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraProducer.java
b/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraProducer.java
index 2fa389a..8a38af1 100644
---
a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraProducer.java
+++
b/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraProducer.java
@@ -19,6 +19,7 @@ package org.apache.camel.component.gora;
import java.util.Map;
import org.apache.camel.Exchange;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.support.DefaultProducer;
import org.apache.gora.persistency.Persistent;
import org.apache.gora.store.DataStore;
@@ -63,7 +64,7 @@ public class GoraProducer extends DefaultProducer {
final String operation = (String)
exchange.getIn().getHeader(GoraAttribute.GORA_OPERATION.value);
if (operation == null || operation.isEmpty()) {
- throw new RuntimeException("Gora operation is null or empty!");
+ throw new RuntimeCamelException("Gora operation is null or
empty!");
}
Object result = 0; // 0 used as default response in order to avoid
null body exception
@@ -89,7 +90,7 @@ public class GoraProducer extends DefaultProducer {
} else if
(GoraOperation.SCHEMA_EXIST.value.equalsIgnoreCase(operation)) {
result = dataStore.schemaExists();
} else {
- throw new RuntimeException("Unknown operation: " + operation);
+ throw new RuntimeCamelException("Unknown operation: " + operation);
}
/*
diff --git
a/components/camel-graphql/src/test/java/org/apache/camel/component/graphql/server/GraphqlFactory.java
b/components/camel-graphql/src/test/java/org/apache/camel/component/graphql/server/GraphqlFactory.java
index 402a2f8..7652874 100644
---
a/components/camel-graphql/src/test/java/org/apache/camel/component/graphql/server/GraphqlFactory.java
+++
b/components/camel-graphql/src/test/java/org/apache/camel/component/graphql/server/GraphqlFactory.java
@@ -22,6 +22,7 @@ import graphql.schema.idl.RuntimeWiring;
import graphql.schema.idl.SchemaGenerator;
import graphql.schema.idl.SchemaParser;
import graphql.schema.idl.TypeDefinitionRegistry;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.util.IOHelper;
import org.apache.camel.util.ObjectHelper;
@@ -38,7 +39,7 @@ public final class GraphqlFactory {
GraphQLSchema graphQLSchema = buildSchema(schema);
return GraphQL.newGraphQL(graphQLSchema).build();
} catch (Exception e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
diff --git
a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java
b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java
index f8cb6fc..fe13dcb 100644
---
a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java
+++
b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java
@@ -31,6 +31,7 @@ import com.hazelcast.transaction.TransactionOptions;
import com.hazelcast.transaction.TransactionalMap;
import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.spi.OptimisticLockingAggregationRepository;
import org.apache.camel.spi.RecoverableAggregationRepository;
import org.apache.camel.support.DefaultExchange;
@@ -388,7 +389,7 @@ public class HazelcastAggregationRepository extends
ServiceSupport
"Transaction with ID %s was rolled back for remove
operation with a key %s and an Exchange ID %s.",
tCtx.getTxnId(), key, exchange.getExchangeId());
LOG.warn(msg, throwable);
- throw new RuntimeException(msg, throwable);
+ throw new RuntimeCamelException(msg, throwable);
}
} else {
cache.remove(key);
diff --git
a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/ReplicatedHazelcastAggregationRepository.java
b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/ReplicatedHazelcastAggregationRepository.java
index 2185c61..021e5c6 100644
---
a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/ReplicatedHazelcastAggregationRepository.java
+++
b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/ReplicatedHazelcastAggregationRepository.java
@@ -31,6 +31,7 @@ import com.hazelcast.transaction.TransactionOptions;
import com.hazelcast.transaction.TransactionalMap;
import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.spi.OptimisticLockingAggregationRepository;
import org.apache.camel.spi.RecoverableAggregationRepository;
import org.apache.camel.support.DefaultExchangeHolder;
@@ -302,7 +303,7 @@ public class ReplicatedHazelcastAggregationRepository
extends HazelcastAggregati
"Transaction with ID %s was rolled back for remove
operation with a key %s and an Exchange ID %s.",
tCtx.getTxnId(), key, exchange.getExchangeId());
LOG.warn(msg, throwable);
- throw new RuntimeException(msg, throwable);
+ throw new RuntimeCamelException(msg, throwable);
}
} else {
replicatedCache.remove(key);
diff --git
a/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java
b/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java
index d3cd84e..0db0d73 100644
---
a/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java
+++
b/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java
@@ -25,6 +25,7 @@ import org.apache.camel.Category;
import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.hbase.mapping.CellMappingStrategyFactory;
import org.apache.camel.component.hbase.model.HBaseCell;
import org.apache.camel.component.hbase.model.HBaseRow;
@@ -274,7 +275,7 @@ public class HBaseEndpoint extends DefaultEndpoint {
try {
return
getComponent().getConnection().getTable(tableNameObj);
} catch (IOException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
});
diff --git
a/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/AbstractConnectionMultiplexor.java
b/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/AbstractConnectionMultiplexor.java
index e7450fa..fdd9cc1 100644
---
a/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/AbstractConnectionMultiplexor.java
+++
b/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/AbstractConnectionMultiplexor.java
@@ -19,6 +19,7 @@ package org.apache.camel.component.iec60870;
import java.util.Set;
import java.util.concurrent.CopyOnWriteArraySet;
+import org.apache.camel.RuntimeCamelException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -78,7 +79,7 @@ public abstract class AbstractConnectionMultiplexor {
try {
performStop();
} catch (final Exception e) {
- throw new RuntimeException("Failed to stop on dispose", e);
+ throw new RuntimeCamelException("Failed to stop on dispose", e);
}
}
diff --git
a/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/server/ServerComponent.java
b/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/server/ServerComponent.java
index 7766ea5..aa965ae 100644
---
a/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/server/ServerComponent.java
+++
b/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/server/ServerComponent.java
@@ -21,6 +21,7 @@ import java.util.Map;
import org.apache.camel.CamelContext;
import org.apache.camel.Endpoint;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.iec60870.AbstractIecComponent;
import org.apache.camel.component.iec60870.ConnectionId;
import org.apache.camel.component.iec60870.Constants;
@@ -52,7 +53,7 @@ public class ServerComponent extends
AbstractIecComponent<ServerConnectionMultip
try {
return new ServerConnectionMultiplexor(new
ServerInstance(id.getHost(), id.getPort(), options));
} catch (final UnknownHostException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
diff --git
a/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/server/ServerInstance.java
b/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/server/ServerInstance.java
index ad680d5..92cf5f4 100644
---
a/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/server/ServerInstance.java
+++
b/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/server/ServerInstance.java
@@ -25,6 +25,7 @@ import java.util.Objects;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.ConcurrentHashMap;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.iec60870.DiscardAckModule;
import org.apache.camel.component.iec60870.ObjectAddress;
import org.eclipse.neoscada.protocol.iec60870.asdu.types.ASDUAddress;
@@ -156,7 +157,7 @@ public class ServerInstance {
if (e instanceof RuntimeException) {
re = (RuntimeException) e;
} else {
- re = new RuntimeException(e);
+ re = new RuntimeCamelException(e);
}
ex.forEach(re::addSuppressed);
throw re;
diff --git
a/components/camel-infinispan/camel-infinispan-common/src/main/java/org/apache/camel/component/infinispan/cluster/InfinispanClusterConfiguration.java
b/components/camel-infinispan/camel-infinispan-common/src/main/java/org/apache/camel/component/infinispan/cluster/InfinispanClusterConfiguration.java
index 617a95a..f449b69 100644
---
a/components/camel-infinispan/camel-infinispan-common/src/main/java/org/apache/camel/component/infinispan/cluster/InfinispanClusterConfiguration.java
+++
b/components/camel-infinispan/camel-infinispan-common/src/main/java/org/apache/camel/component/infinispan/cluster/InfinispanClusterConfiguration.java
@@ -18,6 +18,7 @@ package org.apache.camel.component.infinispan.cluster;
import java.util.concurrent.TimeUnit;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.infinispan.InfinispanConfiguration;
public abstract class InfinispanClusterConfiguration<C extends
InfinispanConfiguration> implements Cloneable {
@@ -68,7 +69,7 @@ public abstract class InfinispanClusterConfiguration<C
extends InfinispanConfigu
try {
return (InfinispanClusterConfiguration) super.clone();
} catch (CloneNotSupportedException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
}
diff --git
a/components/camel-pdf/src/test/java/org/apache/camel/component/pdf/PdfAppendTest.java
b/components/camel-pdf/src/test/java/org/apache/camel/component/pdf/PdfAppendTest.java
index 5ca9a9e..14af9ee 100644
---
a/components/camel-pdf/src/test/java/org/apache/camel/component/pdf/PdfAppendTest.java
+++
b/components/camel-pdf/src/test/java/org/apache/camel/component/pdf/PdfAppendTest.java
@@ -25,6 +25,7 @@ import java.util.Map;
import org.apache.camel.EndpointInject;
import org.apache.camel.Exchange;
import org.apache.camel.Predicate;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.junit5.CamelTestSupport;
@@ -87,7 +88,7 @@ public class PdfAppendTest extends CamelTestSupport {
assertThat(text, containsString(originalText));
assertThat(text, containsString(textToAppend));
} catch (IOException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
return true;
}
@@ -147,7 +148,7 @@ public class PdfAppendTest extends CamelTestSupport {
assertThat(text, containsString(originalText));
assertThat(text, containsString(textToAppend));
} catch (IOException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
return true;
}
diff --git
a/components/camel-pdf/src/test/java/org/apache/camel/component/pdf/PdfCreationTest.java
b/components/camel-pdf/src/test/java/org/apache/camel/component/pdf/PdfCreationTest.java
index 3c2643d..76b5304 100644
---
a/components/camel-pdf/src/test/java/org/apache/camel/component/pdf/PdfCreationTest.java
+++
b/components/camel-pdf/src/test/java/org/apache/camel/component/pdf/PdfCreationTest.java
@@ -23,6 +23,7 @@ import java.io.IOException;
import org.apache.camel.EndpointInject;
import org.apache.camel.Exchange;
import org.apache.camel.Predicate;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.junit5.CamelTestSupport;
@@ -68,7 +69,7 @@ public class PdfCreationTest extends CamelTestSupport {
assertEquals(1, doc.getNumberOfPages());
assertThat(text, containsString(expectedText));
} catch (IOException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
return true;
}
@@ -106,7 +107,7 @@ public class PdfCreationTest extends CamelTestSupport {
assertEquals(1, doc.getNumberOfPages());
assertThat(text, containsString(expectedText));
} catch (Exception e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
return true;
}
diff --git
a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerInAsynchronousIT.java
b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerInAsynchronousIT.java
index 0d4096f..f285732 100644
---
a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerInAsynchronousIT.java
+++
b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerInAsynchronousIT.java
@@ -23,6 +23,7 @@ import org.apache.camel.Endpoint;
import org.apache.camel.EndpointInject;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.component.pulsar.PulsarComponent;
@@ -108,7 +109,7 @@ public class PulsarConsumerInAsynchronousIT extends
PulsarITSupport {
from(synchronousFalseThrowsException)
.threads(2)
- .throwException(new RuntimeException("Processor throws
exception."))
+ .throwException(new RuntimeCamelException("Processor
throws exception."))
.end()
.to(to);
diff --git
a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/integration/RabbitMQDeadLetterArgsIT.java
b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/integration/RabbitMQDeadLetterArgsIT.java
index 5931cb4..9c42011 100644
---
a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/integration/RabbitMQDeadLetterArgsIT.java
+++
b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/integration/RabbitMQDeadLetterArgsIT.java
@@ -25,6 +25,7 @@ import org.apache.camel.BindToRegistry;
import org.apache.camel.EndpointInject;
import org.apache.camel.Produce;
import org.apache.camel.ProducerTemplate;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.component.rabbitmq.RabbitMQEndpoint;
@@ -86,7 +87,7 @@ public class RabbitMQDeadLetterArgsIT extends
AbstractRabbitMQIT {
.routeId("consumer")
.convertBodyTo(String.class)
.to(receivedEndpoint)
- .throwException(new RuntimeException("Simulated"));
+ .throwException(new
RuntimeCamelException("Simulated"));
final String endpointUri2 = String.format(
"rabbitmq:anotherExchange?%s&queue=%s&deadLetterQueue=%s&autoAck=false&durable=true&deadLetterExchange=anotherExchange&skipDlqDeclare=true",
@@ -94,7 +95,7 @@ public class RabbitMQDeadLetterArgsIT extends
AbstractRabbitMQIT {
from("direct:start_skip_dlq_declare")
.to(endpointUri2);
from(endpointUri2)
- .throwException(new RuntimeException("Simulated"));
+ .throwException(new
RuntimeCamelException("Simulated"));
fromF("rabbitmq:anotherExchange?%s&queue=%s&args=#args",
localRabbitmqParams, DLQ_SKIP_DECLARE)
.convertBodyTo(String.class)
.to(receivedDlqEndpoint);
