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 7b4ac71 (chores): replace usages of RuntimeException with
RuntimeCamelException
7b4ac71 is described below
commit 7b4ac7163f7276cf84b4d5832e360e116b1dc89d
Author: Otavio Rodolfo Piske <[email protected]>
AuthorDate: Thu Sep 23 10:57:22 2021 +0200
(chores): replace usages of RuntimeException with RuntimeCamelException
camel-grpc/src, camel-jaxb/src, camel-jcache/src, camel-jcr/src,
camel-jgroups-raft/src, camel-jms/src, camel-kubernetes/src, camel-lra/src,
camel-lumberjack/src, camel-oaipmh/src, camel-smpp/src, camel-web3j/src,
camel-xmlsecurity/src, camel-zookeeper/src
---
.../org/apache/camel/component/grpc/GrpcProducerStreamingTest.java | 3 ++-
.../src/test/java/org/apache/camel/example/JaxbErrorLogTest.java | 5 +++--
.../camel/component/jcache/policy/JCachePolicyProcessorTest.java | 3 ++-
.../src/main/java/org/apache/camel/component/jcr/JcrProducer.java | 3 ++-
.../camel/component/jgroups/raft/JGroupsRaftAbstractTest.java | 3 ++-
.../jgroups/raft/cluster/JGroupsRaftClusterAbstractTest.java | 3 ++-
...sTransactedDeadLetterChannelHandlerRollbackOnExceptionTest.java | 5 +++--
.../issues/JmsTransactedOnExceptionRollbackOnExceptionTest.java | 5 +++--
.../component/kubernetes/cluster/KubernetesClusterServiceTest.java | 5 +++--
.../camel/component/kubernetes/cluster/utils/LeaderRecorder.java | 3 ++-
.../camel/component/kubernetes/cluster/utils/LockTestServer.java | 3 ++-
.../src/test/java/org/apache/camel/service/lra/LRACreditIT.java | 3 ++-
.../src/test/java/org/apache/camel/service/lra/LRAFailuresIT.java | 7 ++++---
.../src/test/java/org/apache/camel/service/lra/LRAOptionsIT.java | 2 +-
.../camel/component/lumberjack/io/LumberjackFrameDecoder.java | 5 +++--
.../camel/component/lumberjack/LumberjackDisconnectionTest.java | 3 ++-
.../java/org/apache/camel/component/lumberjack/LumberjackUtil.java | 3 ++-
.../test/java/org/apache/camel/oaipmh/utils/MockOaipmhServer.java | 3 ++-
.../org/apache/camel/component/smpp/SmppConnectionFactory.java | 2 +-
.../component/web3j/Web3jConsumerBlockObservableMockTest.java | 3 ++-
...erCatchUpToLatestAndSubscribeToNewBlocksObservableMockTest.java | 3 ++-
...hUpToLatestAndSubscribeToNewTransactionsObservableMockTest.java | 3 ++-
.../Web3jConsumerCatchUpToLatestBlocksObservableMockTest.java | 3 ++-
...Web3jConsumerCatchUpToLatestTransactionsObservableMockTest.java | 3 ++-
.../web3j/Web3jConsumerEthBlockHashObservableMockTest.java | 3 ++-
.../component/web3j/Web3jConsumerEthLogObservableMockTest.java | 3 ++-
.../Web3jConsumerEthPendingTransactionHashObservableMockTest.java | 3 ++-
.../web3j/Web3jConsumerPendingTransactionObservableMockTest.java | 3 ++-
.../web3j/Web3jConsumerReplyBlocksObservableMockTest.java | 3 ++-
.../web3j/Web3jConsumerReplyTransactionsObservableMockTest.java | 3 ++-
.../web3j/Web3jConsumerTransactionObservableMockTest.java | 3 ++-
.../apache/camel/component/xmlsecurity/SignatureAlgorithmTest.java | 3 ++-
.../camel/component/xmlsecurity/SignatureDigestMethodTest.java | 3 ++-
.../org/apache/camel/component/xmlsecurity/XmlSignatureTest.java | 3 ++-
.../cluster/ZooKeeperClusteredRoutePolicyFactoryMain.java | 3 ++-
.../camel/component/zookeeper/cluster/ZooKeeperMasterMain.java | 3 ++-
36 files changed, 77 insertions(+), 43 deletions(-)
diff --git
a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerStreamingTest.java
b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerStreamingTest.java
index 48f2d69..41a0b90 100644
---
a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerStreamingTest.java
+++
b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerStreamingTest.java
@@ -23,6 +23,7 @@ import java.util.List;
import io.grpc.Server;
import io.grpc.ServerBuilder;
import io.grpc.stub.StreamObserver;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.AvailablePortFinder;
@@ -146,7 +147,7 @@ public class GrpcProducerStreamingTest extends
CamelTestSupport {
streamRequests.add(request);
if ("error".equals(request.getPingName())) {
PingPongImpl.this.streamRequests.add(streamRequests);
- responseObserver.onError(new
RuntimeException("Requested error"));
+ responseObserver.onError(new
RuntimeCamelException("Requested error"));
} else {
PongResponse response =
PongResponse.newBuilder().setPongName("Hello " + request.getPingName()).build();
responseObserver.onNext(response);
diff --git
a/components/camel-jaxb/src/test/java/org/apache/camel/example/JaxbErrorLogTest.java
b/components/camel-jaxb/src/test/java/org/apache/camel/example/JaxbErrorLogTest.java
index a09c8a5..0f272a3 100644
---
a/components/camel-jaxb/src/test/java/org/apache/camel/example/JaxbErrorLogTest.java
+++
b/components/camel-jaxb/src/test/java/org/apache/camel/example/JaxbErrorLogTest.java
@@ -20,6 +20,7 @@ import javax.xml.bind.annotation.XmlRootElement;
import org.apache.camel.Body;
import org.apache.camel.Handler;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Test;
@@ -56,7 +57,7 @@ public class JaxbErrorLogTest extends CamelTestSupport {
public void handle(@Body CannotMarshal body) {
if (body.getMessageNo() == 2) {
// fail on second message
- throw new RuntimeException("Kaboom");
+ throw new RuntimeCamelException("Kaboom");
}
}
}
@@ -88,7 +89,7 @@ public class JaxbErrorLogTest extends CamelTestSupport {
}
public String getUhoh() {
- throw new RuntimeException("Can't marshal this");
+ throw new RuntimeCamelException("Can't marshal this");
}
@Override
diff --git
a/components/camel-jcache/src/test/java/org/apache/camel/component/jcache/policy/JCachePolicyProcessorTest.java
b/components/camel-jcache/src/test/java/org/apache/camel/component/jcache/policy/JCachePolicyProcessorTest.java
index 191acab..a0ebf26 100644
---
a/components/camel-jcache/src/test/java/org/apache/camel/component/jcache/policy/JCachePolicyProcessorTest.java
+++
b/components/camel-jcache/src/test/java/org/apache/camel/component/jcache/policy/JCachePolicyProcessorTest.java
@@ -23,6 +23,7 @@ import javax.cache.configuration.MutableConfiguration;
import org.apache.camel.Exchange;
import org.apache.camel.LoggingLevel;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.language.simple.types.SimpleIllegalSyntaxException;
@@ -249,7 +250,7 @@ public class JCachePolicyProcessorTest extends
JCachePolicyTestBase {
final String key = randomString();
MockEndpoint mock = getMockEndpoint("mock:value");
mock.whenAnyExchangeReceived(e -> {
- throw new RuntimeException("unexpected");
+ throw new RuntimeCamelException("unexpected");
});
Cache cache = lookupCache("simple");
diff --git
a/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrProducer.java
b/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrProducer.java
index 8d9392d..c7f3c5a 100644
---
a/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrProducer.java
+++
b/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrProducer.java
@@ -32,6 +32,7 @@ import javax.jcr.Value;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.TypeConverter;
import org.apache.camel.support.DefaultProducer;
import org.apache.camel.util.ObjectHelper;
@@ -83,7 +84,7 @@ public class JcrProducer extends DefaultProducer {
message.setHeader(property.getName(), value);
}
} else {
- throw new RuntimeException("Unsupported operation: " +
operation);
+ throw new RuntimeCamelException("Unsupported operation: " +
operation);
}
} finally {
if (session != null && session.isLive()) {
diff --git
a/components/camel-jgroups-raft/src/test/java/org/apache/camel/component/jgroups/raft/JGroupsRaftAbstractTest.java
b/components/camel-jgroups-raft/src/test/java/org/apache/camel/component/jgroups/raft/JGroupsRaftAbstractTest.java
index 6f0af5f..1f6f301 100644
---
a/components/camel-jgroups-raft/src/test/java/org/apache/camel/component/jgroups/raft/JGroupsRaftAbstractTest.java
+++
b/components/camel-jgroups-raft/src/test/java/org/apache/camel/component/jgroups/raft/JGroupsRaftAbstractTest.java
@@ -19,6 +19,7 @@ package org.apache.camel.component.jgroups.raft;
import java.util.concurrent.TimeUnit;
import org.apache.camel.Exchange;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.jgroups.Address;
import org.jgroups.raft.RaftHandle;
@@ -45,7 +46,7 @@ public abstract class JGroupsRaftAbstractTest extends
CamelTestSupport {
attempts--;
}
if (attempts <= 0) {
- throw new RuntimeException("No leader in time!");
+ throw new RuntimeCamelException("No leader in time!");
}
}
}
diff --git
a/components/camel-jgroups-raft/src/test/java/org/apache/camel/component/jgroups/raft/cluster/JGroupsRaftClusterAbstractTest.java
b/components/camel-jgroups-raft/src/test/java/org/apache/camel/component/jgroups/raft/cluster/JGroupsRaftClusterAbstractTest.java
index 6f10c78..0d9e0c4 100644
---
a/components/camel-jgroups-raft/src/test/java/org/apache/camel/component/jgroups/raft/cluster/JGroupsRaftClusterAbstractTest.java
+++
b/components/camel-jgroups-raft/src/test/java/org/apache/camel/component/jgroups/raft/cluster/JGroupsRaftClusterAbstractTest.java
@@ -18,6 +18,7 @@ package org.apache.camel.component.jgroups.raft.cluster;
import java.util.concurrent.TimeUnit;
+import org.apache.camel.RuntimeCamelException;
import org.jgroups.raft.RaftHandle;
public abstract class JGroupsRaftClusterAbstractTest {
@@ -29,7 +30,7 @@ public abstract class JGroupsRaftClusterAbstractTest {
attempts--;
}
if (attempts <= 0) {
- throw new RuntimeException("No leader in time!");
+ throw new RuntimeCamelException("No leader in time!");
}
}
}
diff --git
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedDeadLetterChannelHandlerRollbackOnExceptionTest.java
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedDeadLetterChannelHandlerRollbackOnExceptionTest.java
index f960d7f..c174930 100644
---
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedDeadLetterChannelHandlerRollbackOnExceptionTest.java
+++
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedDeadLetterChannelHandlerRollbackOnExceptionTest.java
@@ -21,6 +21,7 @@ import javax.jms.ConnectionFactory;
import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
import org.apache.camel.Handler;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.jms.CamelJmsTestHelper;
import org.apache.camel.component.jms.JmsComponent;
@@ -35,7 +36,7 @@ public class
JmsTransactedDeadLetterChannelHandlerRollbackOnExceptionTest extend
public static class BadErrorHandler {
@Handler
public void onException(Exchange exchange, Exception exception) throws
Exception {
- throw new RuntimeException("error in errorhandler");
+ throw new RuntimeCamelException("error in errorhandler");
}
}
@@ -58,7 +59,7 @@ public class
JmsTransactedDeadLetterChannelHandlerRollbackOnExceptionTest extend
from(testingEndpoint)
.log("Incoming JMS message ${body}")
- .throwException(new RuntimeException("bad error"));
+ .throwException(new RuntimeCamelException("bad
error"));
}
};
}
diff --git
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedOnExceptionRollbackOnExceptionTest.java
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedOnExceptionRollbackOnExceptionTest.java
index f537a84..cb0adab 100644
---
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedOnExceptionRollbackOnExceptionTest.java
+++
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsTransactedOnExceptionRollbackOnExceptionTest.java
@@ -21,6 +21,7 @@ import javax.jms.ConnectionFactory;
import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
import org.apache.camel.Handler;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.jms.CamelJmsTestHelper;
import org.apache.camel.component.jms.JmsComponent;
@@ -35,7 +36,7 @@ public class JmsTransactedOnExceptionRollbackOnExceptionTest
extends CamelTestSu
public static class BadErrorHandler {
@Handler
public void onException(Exchange exchange, Exception exception) throws
Exception {
- throw new RuntimeException("error in errorhandler");
+ throw new RuntimeCamelException("error in errorhandler");
}
}
@@ -52,7 +53,7 @@ public class JmsTransactedOnExceptionRollbackOnExceptionTest
extends CamelTestSu
from(testingEndpoint)
.log("Incoming JMS message ${body}")
- .throwException(new RuntimeException("bad error"));
+ .throwException(new RuntimeCamelException("bad
error"));
}
};
}
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 d862fce..9fa4d2b 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
@@ -34,6 +34,7 @@ import java.util.stream.Stream;
import io.fabric8.kubernetes.api.model.ConfigMapBuilder;
import io.fabric8.kubernetes.api.model.coordination.v1.LeaseBuilder;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.cluster.CamelPreemptiveClusterService;
import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import
org.apache.camel.component.kubernetes.cluster.utils.ConfigMapLockSimulator;
@@ -445,7 +446,7 @@ public class KubernetesClusterServiceTest extends
CamelTestSupport {
try {
context().addService(member);
} catch (Exception ex) {
- throw new RuntimeException(ex);
+ throw new RuntimeCamelException(ex);
}
clusterServices.put(name, member);
@@ -455,7 +456,7 @@ public class KubernetesClusterServiceTest extends
CamelTestSupport {
try {
member.getView(namespace).addEventListener(recorder);
} catch (Exception ex) {
- throw new RuntimeException(ex);
+ throw new RuntimeCamelException(ex);
}
for (String pod : this.lockServers.keySet()) {
diff --git
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LeaderRecorder.java
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LeaderRecorder.java
index db6483e..f2330d6 100644
---
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LeaderRecorder.java
+++
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LeaderRecorder.java
@@ -25,6 +25,7 @@ import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.TimeUnit;
import java.util.function.Predicate;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.cluster.CamelClusterEventListener;
import org.apache.camel.cluster.CamelClusterMember;
import org.apache.camel.cluster.CamelClusterView;
@@ -79,7 +80,7 @@ public class LeaderRecorder implements
CamelClusterEventListener.Leadership {
try {
Thread.sleep(millis);
} catch (InterruptedException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
diff --git
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LockTestServer.java
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LockTestServer.java
index 1a5bd7a..7a1fb96 100644
---
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LockTestServer.java
+++
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LockTestServer.java
@@ -34,6 +34,7 @@ import
io.fabric8.kubernetes.client.server.mock.KubernetesMockServer;
import io.fabric8.mockwebserver.utils.ResponseProvider;
import okhttp3.Headers;
import okhttp3.mockwebserver.RecordedRequest;
+import org.apache.camel.RuntimeCamelException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -272,7 +273,7 @@ public class LockTestServer<T extends HasMetadata> extends
KubernetesMockServer
try {
Thread.sleep(delayRequests);
} catch (InterruptedException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
}
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 d7e0c96..8cbca28 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
@@ -24,6 +24,7 @@ import java.util.TreeSet;
import org.apache.camel.Exchange;
import org.apache.camel.Header;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.model.SagaPropagation;
import org.junit.jupiter.api.Test;
@@ -143,7 +144,7 @@ public class LRACreditIT extends AbstractLRATestSupport {
.choice()
.when(header("fail").isEqualTo(true))
.process(x -> {
- throw new RuntimeException("fail");
+ throw new RuntimeCamelException("fail");
})
.end();
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 81e5183..46fde72 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
@@ -18,6 +18,7 @@ package org.apache.camel.service.lra;
import java.util.concurrent.atomic.AtomicInteger;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.junit.jupiter.api.Test;
@@ -70,7 +71,7 @@ public class LRAFailuresIT extends AbstractLRATestSupport {
.saga()
.compensation("direct:compensate")
.process(x -> {
- throw new RuntimeException("fail");
+ throw new RuntimeCamelException("fail");
});
from("direct:saga-complete")
@@ -82,7 +83,7 @@ public class LRAFailuresIT extends AbstractLRATestSupport {
.process(x -> {
int current = maxFailures.decrementAndGet();
if (current >= 0) {
- throw new RuntimeException("compensation
failure");
+ throw new RuntimeCamelException("compensation
failure");
}
})
.to("mock:compensate");
@@ -91,7 +92,7 @@ public class LRAFailuresIT extends AbstractLRATestSupport {
.process(x -> {
int current = maxFailures.decrementAndGet();
if (current >= 0) {
- throw new RuntimeException("completion
failure");
+ throw new RuntimeCamelException("completion
failure");
}
})
.to("mock:complete");
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 84ea380..11cbb5d 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
@@ -80,7 +80,7 @@ public class LRAOptionsIT extends AbstractLRATestSupport {
.choice()
.when(body().isEqualTo("compensate"))
.process(ex -> {
- throw new RuntimeException("forced compensate");
+ throw new RuntimeCamelException("forced
compensate");
})
.end()
.setHeader("myname", constant("TryToOverride"))
diff --git
a/components/camel-lumberjack/src/main/java/org/apache/camel/component/lumberjack/io/LumberjackFrameDecoder.java
b/components/camel-lumberjack/src/main/java/org/apache/camel/component/lumberjack/io/LumberjackFrameDecoder.java
index b27ca86..bfa5fbd 100644
---
a/components/camel-lumberjack/src/main/java/org/apache/camel/component/lumberjack/io/LumberjackFrameDecoder.java
+++
b/components/camel-lumberjack/src/main/java/org/apache/camel/component/lumberjack/io/LumberjackFrameDecoder.java
@@ -29,6 +29,7 @@ import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufOutputStream;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ByteToMessageDecoder;
+import org.apache.camel.RuntimeCamelException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -98,7 +99,7 @@ final class LumberjackFrameDecoder extends
ByteToMessageDecoder {
frameDecoded = handleCompressedFrame(ctx, in, out);
break;
default:
- throw new RuntimeException("Unsupported frame type=" +
frameType);
+ throw new RuntimeCamelException("Unsupported frame type="
+ frameType);
}
} finally {
if (!frameDecoded) {
@@ -237,7 +238,7 @@ final class LumberjackFrameDecoder extends
ByteToMessageDecoder {
private void verifyVersion(byte version) {
if (this.window == null || this.window.getVersion() == -1) {
if (version != VERSION_V1 && version != VERSION_V2) {
- throw new RuntimeException("Unsupported frame version=" +
version);
+ throw new RuntimeCamelException("Unsupported frame version=" +
version);
}
LOG.debug("Lumberjack protocol version is {}", (char) version);
} else if (window.getVersion() != version) {
diff --git
a/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackDisconnectionTest.java
b/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackDisconnectionTest.java
index d070809..7b29857 100644
---
a/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackDisconnectionTest.java
+++
b/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackDisconnectionTest.java
@@ -22,6 +22,7 @@ import java.util.Map;
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.test.AvailablePortFinder;
@@ -79,7 +80,7 @@ public class LumberjackDisconnectionTest extends
CamelTestSupport {
public void process(Exchange exchange) throws Exception {
count++;
if (count == 4) {
- throw new RuntimeException("Ooops");
+ throw new RuntimeCamelException("Ooops");
}
}
}
diff --git
a/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackUtil.java
b/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackUtil.java
index 721c57f..ab9171b 100644
---
a/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackUtil.java
+++
b/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackUtil.java
@@ -35,6 +35,7 @@ import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.ssl.SslHandler;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.support.jsse.SSLContextParameters;
import static io.netty.buffer.Unpooled.wrappedBuffer;
@@ -106,7 +107,7 @@ final class LumberjackUtil {
}
return wrappedBuffer(output.toByteArray());
} catch (IOException e) {
- throw new RuntimeException("Cannot read sample data", e);
+ throw new RuntimeCamelException("Cannot read sample data", e);
}
}
}
diff --git
a/components/camel-oaipmh/src/test/java/org/apache/camel/oaipmh/utils/MockOaipmhServer.java
b/components/camel-oaipmh/src/test/java/org/apache/camel/oaipmh/utils/MockOaipmhServer.java
index eed6792..c8cf812 100644
---
a/components/camel-oaipmh/src/test/java/org/apache/camel/oaipmh/utils/MockOaipmhServer.java
+++
b/components/camel-oaipmh/src/test/java/org/apache/camel/oaipmh/utils/MockOaipmhServer.java
@@ -32,6 +32,7 @@ import com.github.tomakehurst.wiremock.extension.Parameters;
import com.github.tomakehurst.wiremock.extension.ResponseDefinitionTransformer;
import com.github.tomakehurst.wiremock.http.Request;
import com.github.tomakehurst.wiremock.http.ResponseDefinition;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.test.AvailablePortFinder;
import org.apache.commons.codec.digest.DigestUtils;
import org.apache.commons.io.IOUtils;
@@ -81,7 +82,7 @@ public final class MockOaipmhServer {
responseCache = Collections.unmodifiableMap(cache);
}
} catch (IOException ioex) {
- throw new RuntimeException("An issue occured while initializing
the OAI-PMH mock server reponse cache", ioex);
+ throw new RuntimeCamelException("An issue occured while
initializing the OAI-PMH mock server reponse cache", ioex);
}
return responseCache;
}
diff --git
a/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppConnectionFactory.java
b/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppConnectionFactory.java
index f1b5a8e..71b6199 100644
---
a/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppConnectionFactory.java
+++
b/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppConnectionFactory.java
@@ -181,7 +181,7 @@ public final class SmppConnectionFactory implements
ConnectionFactory {
throw re;
} catch (Exception e) {
closeSocket(socket);
- throw new RuntimeException("SmppConnectionFactory: " +
e.getMessage(), e);
+ throw new RuntimeCamelException("SmppConnectionFactory: " +
e.getMessage(), e);
}
}
diff --git
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerBlockObservableMockTest.java
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerBlockObservableMockTest.java
index 8eb6103..926b576 100644
---
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerBlockObservableMockTest.java
+++
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerBlockObservableMockTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.web3j;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;
@@ -65,7 +66,7 @@ public class Web3jConsumerBlockObservableMockTest extends
Web3jMockTestSupport {
Mockito.when(observable.subscribe(any(), any(), any())).thenAnswer(new
Answer() {
public Subscription answer(InvocationOnMock invocation) {
Object[] args = invocation.getArguments();
- ((Action1<Throwable>) args[1]).call(new
RuntimeException("Error"));
+ ((Action1<Throwable>) args[1]).call(new
RuntimeCamelException("Error"));
return subscription;
}
});
diff --git
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestAndSubscribeToNewBlocksObservableMockTest.java
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestAndSubscribeToNewBlocksObservableMockTest.java
index cb8ffa8..94e5e92 100644
---
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestAndSubscribeToNewBlocksObservableMockTest.java
+++
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestAndSubscribeToNewBlocksObservableMockTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.web3j;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;
@@ -68,7 +69,7 @@ public class
Web3jConsumerCatchUpToLatestAndSubscribeToNewBlocksObservableMockTe
Mockito.when(observable.subscribe(any(), any(), any())).thenAnswer(new
Answer() {
public Subscription answer(InvocationOnMock invocation) {
Object[] args = invocation.getArguments();
- ((Action1<Throwable>) args[1]).call(new
RuntimeException("Error"));
+ ((Action1<Throwable>) args[1]).call(new
RuntimeCamelException("Error"));
return subscription;
}
});
diff --git
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestAndSubscribeToNewTransactionsObservableMockTest.java
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestAndSubscribeToNewTransactionsObservableMockTest.java
index 2ab2dd9..0242902 100644
---
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestAndSubscribeToNewTransactionsObservableMockTest.java
+++
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestAndSubscribeToNewTransactionsObservableMockTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.web3j;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;
@@ -68,7 +69,7 @@ public class
Web3jConsumerCatchUpToLatestAndSubscribeToNewTransactionsObservable
Mockito.when(observable.subscribe(any(), any(), any())).thenAnswer(new
Answer() {
public Subscription answer(InvocationOnMock invocation) {
Object[] args = invocation.getArguments();
- ((Action1<Throwable>) args[1]).call(new
RuntimeException("Error"));
+ ((Action1<Throwable>) args[1]).call(new
RuntimeCamelException("Error"));
return subscription;
}
});
diff --git
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestBlocksObservableMockTest.java
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestBlocksObservableMockTest.java
index 7594f778..f019377 100644
---
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestBlocksObservableMockTest.java
+++
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestBlocksObservableMockTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.web3j;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;
@@ -68,7 +69,7 @@ public class
Web3jConsumerCatchUpToLatestBlocksObservableMockTest extends Web3jM
Mockito.when(observable.subscribe(any(), any(), any())).thenAnswer(new
Answer() {
public Subscription answer(InvocationOnMock invocation) {
Object[] args = invocation.getArguments();
- ((Action1<Throwable>) args[1]).call(new
RuntimeException("Error"));
+ ((Action1<Throwable>) args[1]).call(new
RuntimeCamelException("Error"));
return subscription;
}
});
diff --git
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestTransactionsObservableMockTest.java
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestTransactionsObservableMockTest.java
index 928085a..a8c16f0 100644
---
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestTransactionsObservableMockTest.java
+++
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerCatchUpToLatestTransactionsObservableMockTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.web3j;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;
@@ -66,7 +67,7 @@ public class
Web3jConsumerCatchUpToLatestTransactionsObservableMockTest extends
Mockito.when(observable.subscribe(any(), any(), any())).thenAnswer(new
Answer() {
public Subscription answer(InvocationOnMock invocation) {
Object[] args = invocation.getArguments();
- ((Action1<Throwable>) args[1]).call(new
RuntimeException("Error"));
+ ((Action1<Throwable>) args[1]).call(new
RuntimeCamelException("Error"));
return subscription;
}
});
diff --git
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerEthBlockHashObservableMockTest.java
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerEthBlockHashObservableMockTest.java
index a07d0e4..2a6c506 100644
---
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerEthBlockHashObservableMockTest.java
+++
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerEthBlockHashObservableMockTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.web3j;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;
@@ -64,7 +65,7 @@ public class Web3jConsumerEthBlockHashObservableMockTest
extends Web3jMockTestSu
Mockito.when(observable.subscribe(any(), any(), any())).thenAnswer(new
Answer() {
public Subscription answer(InvocationOnMock invocation) {
Object[] args = invocation.getArguments();
- ((Action1<Throwable>) args[1]).call(new
RuntimeException("Error"));
+ ((Action1<Throwable>) args[1]).call(new
RuntimeCamelException("Error"));
return subscription;
}
});
diff --git
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerEthLogObservableMockTest.java
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerEthLogObservableMockTest.java
index 579ce08..96e4f36 100644
---
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerEthLogObservableMockTest.java
+++
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerEthLogObservableMockTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.web3j;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;
@@ -66,7 +67,7 @@ public class Web3jConsumerEthLogObservableMockTest extends
Web3jMockTestSupport
Mockito.when(observable.subscribe(any(), any(), any())).thenAnswer(new
Answer() {
public Subscription answer(InvocationOnMock invocation) {
Object[] args = invocation.getArguments();
- ((Action1<Throwable>) args[1]).call(new
RuntimeException("Error"));
+ ((Action1<Throwable>) args[1]).call(new
RuntimeCamelException("Error"));
return subscription;
}
});
diff --git
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerEthPendingTransactionHashObservableMockTest.java
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerEthPendingTransactionHashObservableMockTest.java
index db771ee..4e881ab 100644
---
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerEthPendingTransactionHashObservableMockTest.java
+++
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerEthPendingTransactionHashObservableMockTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.web3j;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;
@@ -64,7 +65,7 @@ public class
Web3jConsumerEthPendingTransactionHashObservableMockTest extends We
Mockito.when(observable.subscribe(any(), any(), any())).thenAnswer(new
Answer() {
public Subscription answer(InvocationOnMock invocation) {
Object[] args = invocation.getArguments();
- ((Action1<Throwable>) args[1]).call(new
RuntimeException("Error"));
+ ((Action1<Throwable>) args[1]).call(new
RuntimeCamelException("Error"));
return subscription;
}
});
diff --git
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerPendingTransactionObservableMockTest.java
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerPendingTransactionObservableMockTest.java
index 40eeb3c..56b45be 100644
---
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerPendingTransactionObservableMockTest.java
+++
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerPendingTransactionObservableMockTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.web3j;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;
@@ -65,7 +66,7 @@ public class
Web3jConsumerPendingTransactionObservableMockTest extends Web3jMock
Mockito.when(observable.subscribe(any(), any(), any())).thenAnswer(new
Answer() {
public Subscription answer(InvocationOnMock invocation) {
Object[] args = invocation.getArguments();
- ((Action1<Throwable>) args[1]).call(new
RuntimeException("Error"));
+ ((Action1<Throwable>) args[1]).call(new
RuntimeCamelException("Error"));
return subscription;
}
});
diff --git
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerReplyBlocksObservableMockTest.java
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerReplyBlocksObservableMockTest.java
index d4d1c44..7c5b408 100644
---
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerReplyBlocksObservableMockTest.java
+++
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerReplyBlocksObservableMockTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.web3j;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;
@@ -68,7 +69,7 @@ public class Web3jConsumerReplyBlocksObservableMockTest
extends Web3jMockTestSup
Mockito.when(observable.subscribe(any(), any(), any())).thenAnswer(new
Answer() {
public Subscription answer(InvocationOnMock invocation) {
Object[] args = invocation.getArguments();
- ((Action1<Throwable>) args[1]).call(new
RuntimeException("Error"));
+ ((Action1<Throwable>) args[1]).call(new
RuntimeCamelException("Error"));
return subscription;
}
});
diff --git
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerReplyTransactionsObservableMockTest.java
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerReplyTransactionsObservableMockTest.java
index 8934719..206d5b5 100644
---
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerReplyTransactionsObservableMockTest.java
+++
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerReplyTransactionsObservableMockTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.web3j;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;
@@ -68,7 +69,7 @@ public class Web3jConsumerReplyTransactionsObservableMockTest
extends Web3jMockT
Mockito.when(observable.subscribe(any(), any(), any())).thenAnswer(new
Answer() {
public Subscription answer(InvocationOnMock invocation) {
Object[] args = invocation.getArguments();
- ((Action1<Throwable>) args[1]).call(new
RuntimeException("Error"));
+ ((Action1<Throwable>) args[1]).call(new
RuntimeCamelException("Error"));
return subscription;
}
});
diff --git
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerTransactionObservableMockTest.java
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerTransactionObservableMockTest.java
index 9de7f7b..1b1dd68 100644
---
a/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerTransactionObservableMockTest.java
+++
b/components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerTransactionObservableMockTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.web3j;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;
@@ -65,7 +66,7 @@ public class Web3jConsumerTransactionObservableMockTest
extends Web3jMockTestSup
Mockito.when(observable.subscribe(any(), any(), any())).thenAnswer(new
Answer() {
public Subscription answer(InvocationOnMock invocation) {
Object[] args = invocation.getArguments();
- ((Action1<Throwable>) args[1]).call(new
RuntimeException("Error"));
+ ((Action1<Throwable>) args[1]).call(new
RuntimeCamelException("Error"));
return subscription;
}
});
diff --git
a/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/SignatureAlgorithmTest.java
b/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/SignatureAlgorithmTest.java
index b6ff351..56c5bf5f 100644
---
a/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/SignatureAlgorithmTest.java
+++
b/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/SignatureAlgorithmTest.java
@@ -56,6 +56,7 @@ import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
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.xmlsecurity.api.KeyAccessor;
@@ -486,7 +487,7 @@ public class SignatureAlgorithmTest extends
CamelTestSupport {
try {
keyGen = KeyPairGenerator.getInstance(algorithm);
} catch (NoSuchAlgorithmException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
keyGen.initialize(keylength, new SecureRandom());
return keyGen.generateKeyPair();
diff --git
a/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/SignatureDigestMethodTest.java
b/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/SignatureDigestMethodTest.java
index 4c3703d..ea5c509 100644
---
a/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/SignatureDigestMethodTest.java
+++
b/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/SignatureDigestMethodTest.java
@@ -55,6 +55,7 @@ import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
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.xmlsecurity.api.KeyAccessor;
@@ -378,7 +379,7 @@ public class SignatureDigestMethodTest extends
CamelTestSupport {
try {
keyGen = KeyPairGenerator.getInstance(algorithm);
} catch (NoSuchAlgorithmException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
keyGen.initialize(keylength, new SecureRandom());
return keyGen.generateKeyPair();
diff --git
a/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/XmlSignatureTest.java
b/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/XmlSignatureTest.java
index 6b2e143..7b9bf7e 100644
---
a/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/XmlSignatureTest.java
+++
b/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/XmlSignatureTest.java
@@ -73,6 +73,7 @@ import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
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.xmlsecurity.api.KeyAccessor;
@@ -1464,7 +1465,7 @@ public class XmlSignatureTest extends CamelTestSupport {
try {
keyGen = KeyPairGenerator.getInstance(algorithm);
} catch (NoSuchAlgorithmException e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
keyGen.initialize(keylength, new SecureRandom());
return keyGen.generateKeyPair();
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperClusteredRoutePolicyFactoryMain.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperClusteredRoutePolicyFactoryMain.java
index a45eea9..b077a39 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperClusteredRoutePolicyFactoryMain.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperClusteredRoutePolicyFactoryMain.java
@@ -19,6 +19,7 @@ package org.apache.camel.component.zookeeper.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;
@@ -47,7 +48,7 @@ public final class ZooKeeperClusteredRoutePolicyFactoryMain {
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-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperMasterMain.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperMasterMain.java
index f30242f..f1d8a3f 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperMasterMain.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperMasterMain.java
@@ -20,6 +20,7 @@ import java.util.UUID;
import java.util.concurrent.ThreadLocalRandom;
import org.apache.camel.CamelContext;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.engine.ExplicitCamelContextNameStrategy;
import org.apache.camel.main.BaseMainSupport;
@@ -47,7 +48,7 @@ public final class ZooKeeperMasterMain {
context.setNameStrategy(new
ExplicitCamelContextNameStrategy("camel-" + nodeId));
context.addService(service);
} catch (Exception e) {
- throw new RuntimeException(e);
+ throw new RuntimeCamelException(e);
}
}
});
