This is an automated email from the ASF dual-hosted git repository.
bvahdat 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 0b2b8a746b1 fix the misspelled kabooms
0b2b8a746b1 is described below
commit 0b2b8a746b12d5aadc45d3af28602d09eabb0609
Author: Babak Vahdat <bvah...@apache.org>
AuthorDate: Mon Dec 26 09:42:41 2022 +0100
fix the misspelled kabooms
---
.../component/jms/JmsDeadLetterQueueTest.java | 10 +++++-----
...msDeadLetterQueueUsingTransferExchangeTest.java | 10 +++++-----
...OnCompletionAndInterceptAndOnExceptionTest.java | 6 +++---
.../camel/component/jms/JmsOnCompletionTest.java | 6 +++---
.../component/jms/JmsTransferExceptionTest.java | 4 ++--
.../component/jms/tx/RouteIdTransactedTest.java | 4 ++--
.../file/FileConsumerDeleteAndFailureTest.java | 4 ++--
.../file/FileConsumerDeleteAndMoveFailedTest.java | 2 +-
.../file/FileConsumerMoveAndMoveFailureTest.java | 6 +++---
.../FileConsumerMoveFailureOnCompletionTest.java | 10 +++++-----
.../file/FileConsumerMoveFailureTest.java | 6 +++---
.../apache/camel/impl/ExpressionAdapterTest.java | 4 ++--
.../apache/camel/impl/ExpressionSupportTest.java | 4 ++--
.../OnExceptionBeforeErrorHandlerIssueTest.java | 8 ++++----
.../RecipientListErrorHandlingIssueTest.java | 12 ++++++------
.../model/RouteConfigurationOnCompletionTest.java | 6 +++---
.../DefaultErrorHandlerExplicitConfiguredTest.java | 2 +-
.../DefaultErrorHandlerOnExceptionTest.java | 4 ++--
.../camel/processor/DefaultErrorHandlerTest.java | 4 ++--
.../processor/ErrorHandlerWrappedEachNodeTest.java | 22 +++++++++++-----------
...letionAndInterceptAndOnExceptionGlobalTest.java | 8 ++++----
.../OnCompletionAndInterceptGlobalTest.java | 8 ++++----
.../processor/OnCompletionAndInterceptTest.java | 8 ++++----
.../camel/processor/OnCompletionAsyncTest.java | 20 ++++++++++----------
.../camel/processor/OnCompletionFailAndOkTest.java | 6 +++---
.../camel/processor/OnCompletionGlobalTest.java | 8 ++++----
.../OnCompletionMoreGlobalRouteCompletionTest.java | 12 ++++++------
.../processor/OnCompletionMoreGlobalTest.java | 8 ++++----
.../processor/OnCompletionOnCompleteOnlyTest.java | 4 ++--
...ompletionRouteScopeOverrideGlobalScopeTest.java | 8 ++++----
.../apache/camel/processor/OnCompletionTest.java | 8 ++++----
.../processor/OnCompletionUseOriginalBodyTest.java | 4 ++--
.../org/apache/camel/processor/RouteIdTest.java | 4 ++--
.../ManagedRouteWithOnExceptionTest.java | 10 +++++-----
.../LoadRouteFromXmlWithOnExceptionTest.java | 6 +++---
35 files changed, 128 insertions(+), 128 deletions(-)
diff --git
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueTest.java
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueTest.java
index 4df5a232708..615d7caf400 100644
---
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueTest.java
+++
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueTest.java
@@ -43,11 +43,11 @@ public class JmsDeadLetterQueueTest extends AbstractJMSTest
{
}
@Test
- public void testKabom() throws Exception {
+ public void testKaboom() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:dead");
- mock.expectedBodiesReceived("Kabom");
+ mock.expectedBodiesReceived("Kaboom");
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
MockEndpoint.assertIsSatisfied(context);
@@ -69,8 +69,8 @@ public class JmsDeadLetterQueueTest extends AbstractJMSTest {
from("direct:start").process(exchange -> {
String body = exchange.getIn().getBody(String.class);
- if ("Kabom".equals(body)) {
- throw new IllegalArgumentException("Kabom");
+ if ("Kaboom".equals(body)) {
+ throw new IllegalArgumentException("Kaboom");
}
}).to("mock:result");
diff --git
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueUsingTransferExchangeTest.java
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueUsingTransferExchangeTest.java
index 7cbd2254f53..7d14b2f8a16 100644
---
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueUsingTransferExchangeTest.java
+++
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeadLetterQueueUsingTransferExchangeTest.java
@@ -40,11 +40,11 @@ public class JmsDeadLetterQueueUsingTransferExchangeTest
extends AbstractJMSTest
}
@Test
- public void testKabom() throws Exception {
+ public void testKaboom() throws Exception {
MockEndpoint mock =
getMockEndpoint("mock:JmsDeadLetterQueueUsingTransferExchangeTest.dead");
- mock.expectedBodiesReceived("Kabom");
+ mock.expectedBodiesReceived("Kaboom");
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
MockEndpoint.assertIsSatisfied(context);
}
@@ -63,8 +63,8 @@ public class JmsDeadLetterQueueUsingTransferExchangeTest
extends AbstractJMSTest
from("direct:start").process(exchange -> {
String body = exchange.getIn().getBody(String.class);
- if ("Kabom".equals(body)) {
- throw new IllegalArgumentException("Kabom");
+ if ("Kaboom".equals(body)) {
+ throw new IllegalArgumentException("Kaboom");
}
}).to("mock:result");
diff --git
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionAndInterceptAndOnExceptionTest.java
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionAndInterceptAndOnExceptionTest.java
index da24662aba4..a765ac333f4 100644
---
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionAndInterceptAndOnExceptionTest.java
+++
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionAndInterceptAndOnExceptionTest.java
@@ -49,7 +49,7 @@ public class JmsOnCompletionAndInterceptAndOnExceptionTest
extends AbstractJMSTe
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedMessageCount(0);
-
template.sendBody("activemq:queue:JmsOnCompletionAndInterceptAndOnExceptionTest.start",
"Kabom");
+
template.sendBody("activemq:queue:JmsOnCompletionAndInterceptAndOnExceptionTest.start",
"Kaboom");
MockEndpoint.assertIsSatisfied(context);
}
@@ -86,8 +86,8 @@ public class JmsOnCompletionAndInterceptAndOnExceptionTest
extends AbstractJMSTe
@Override
public void process(Exchange exchange) {
- if ("Kabom".equals(exchange.getIn().getBody())) {
- throw new IllegalArgumentException("Kabom");
+ if ("Kaboom".equals(exchange.getIn().getBody())) {
+ throw new IllegalArgumentException("Kaboom");
}
exchange.getIn().setBody("Bye World");
}
diff --git
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionTest.java
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionTest.java
index 015da4295ad..0fa86818d12 100644
---
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionTest.java
+++
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsOnCompletionTest.java
@@ -48,7 +48,7 @@ public class JmsOnCompletionTest extends AbstractJMSTest {
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedMessageCount(0);
- template.sendBody("activemq:queue:JmsOnCompletionTest.start", "Kabom");
+ template.sendBody("activemq:queue:JmsOnCompletionTest.start",
"Kaboom");
MockEndpoint.assertIsSatisfied(context);
}
@@ -82,8 +82,8 @@ public class JmsOnCompletionTest extends AbstractJMSTest {
@Override
public void process(Exchange exchange) {
- if ("Kabom".equals(exchange.getIn().getBody())) {
- throw new IllegalArgumentException("Kabom");
+ if ("Kaboom".equals(exchange.getIn().getBody())) {
+ throw new IllegalArgumentException("Kaboom");
}
exchange.getIn().setBody("Bye World");
}
diff --git
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExceptionTest.java
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExceptionTest.java
index 1f94faa35c1..4eab9f6488f 100644
---
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExceptionTest.java
+++
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTransferExceptionTest.java
@@ -54,7 +54,7 @@ public class JmsTransferExceptionTest extends AbstractJMSTest
{
// then we expect our producer template to throw
// an exception with the remote exception as cause
String uri = getUri();
- RuntimeCamelException e = assertThrows(RuntimeCamelException.class, ()
-> template.requestBody(uri, "Kabom"),
+ RuntimeCamelException e = assertThrows(RuntimeCamelException.class, ()
-> template.requestBody(uri, "Kaboom"),
"Should have thrown an exception");
assertEquals("Boom", e.getCause().getMessage());
@@ -81,7 +81,7 @@ public class JmsTransferExceptionTest extends AbstractJMSTest
{
counter++;
String body =
exchange.getIn().getBody(String.class);
- if (body.equals("Kabom")) {
+ if (body.equals("Kaboom")) {
throw new IllegalArgumentException("Boom");
}
exchange.getMessage().setBody("Bye World");
diff --git
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/RouteIdTransactedTest.java
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/RouteIdTransactedTest.java
index e270d8afc6f..315ad80c10d 100644
---
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/RouteIdTransactedTest.java
+++
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/RouteIdTransactedTest.java
@@ -50,7 +50,7 @@ public class RouteIdTransactedTest extends
CamelSpringTestSupport {
getMockEndpoint("mock:error").expectedMessageCount(1);
getMockEndpoint("mock:result").expectedMessageCount(0);
- template.sendBody("activemq:queue:RouteIdTransactedTest", "Kabom");
+ template.sendBody("activemq:queue:RouteIdTransactedTest", "Kaboom");
MockEndpoint.assertIsSatisfied(context);
@@ -67,7 +67,7 @@ public class RouteIdTransactedTest extends
CamelSpringTestSupport {
.onException(IllegalArgumentException.class).handled(true).to("log:bar").to("mock:error").end()
.transacted()
.choice()
- .when(body().contains("Kabom")).throwException(new
IllegalArgumentException("Damn"))
+ .when(body().contains("Kaboom")).throwException(new
IllegalArgumentException("Damn"))
.otherwise()
.to("mock:result")
.end();
diff --git
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerDeleteAndFailureTest.java
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerDeleteAndFailureTest.java
index 3f193617089..95edbad687c 100644
---
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerDeleteAndFailureTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerDeleteAndFailureTest.java
@@ -33,7 +33,7 @@ public class FileConsumerDeleteAndFailureTest extends
ContextTestSupport {
mock.expectedFileExists(testFile("error/bye.txt"));
template.sendBodyAndHeader(fileUri(), "Hello World",
Exchange.FILE_NAME, "hello.txt");
- template.sendBodyAndHeader(fileUri(), "Kabom", Exchange.FILE_NAME,
"bye.txt");
+ template.sendBodyAndHeader(fileUri(), "Kaboom", Exchange.FILE_NAME,
"bye.txt");
assertMockEndpointsSatisfied();
}
@@ -49,7 +49,7 @@ public class FileConsumerDeleteAndFailureTest extends
ContextTestSupport {
.process(new Processor() {
public void process(Exchange exchange) throws
Exception {
String body =
exchange.getIn().getBody(String.class);
- if (body != null && body.startsWith("Kabom")) {
+ if (body != null && body.startsWith("Kaboom"))
{
throw new
IllegalArgumentException("Forced");
}
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerDeleteAndMoveFailedTest.java
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerDeleteAndMoveFailedTest.java
index 35b5bab82dd..a7fe5a9eb2c 100644
---
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerDeleteAndMoveFailedTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerDeleteAndMoveFailedTest.java
@@ -31,7 +31,7 @@ public class FileConsumerDeleteAndMoveFailedTest extends
FileConsumerDeleteAndFa
.setBody(simple("${body} IS processed!")).process(new
Processor() {
public void process(Exchange exchange) throws
Exception {
String body =
exchange.getIn().getBody(String.class);
- if (body != null && body.startsWith("Kabom")) {
+ if (body != null && body.startsWith("Kaboom"))
{
throw new
IllegalArgumentException("Forced");
}
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerMoveAndMoveFailureTest.java
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerMoveAndMoveFailureTest.java
index d107d283521..c317d829aea 100644
---
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerMoveAndMoveFailureTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerMoveAndMoveFailureTest.java
@@ -31,10 +31,10 @@ public class FileConsumerMoveAndMoveFailureTest extends
ContextTestSupport {
mock.expectedBodiesReceived("Hello World");
mock.expectedFileExists(testFile("moved/hello.txt"), "Hello World");
- mock.expectedFileExists(testFile("error/bye-error.txt"), "Kabom");
+ mock.expectedFileExists(testFile("error/bye-error.txt"), "Kaboom");
template.sendBodyAndHeader(fileUri(), "Hello World",
Exchange.FILE_NAME, "hello.txt");
- template.sendBodyAndHeader(fileUri(), "Kabom", Exchange.FILE_NAME,
"bye.txt");
+ template.sendBodyAndHeader(fileUri(), "Kaboom", Exchange.FILE_NAME,
"bye.txt");
assertMockEndpointsSatisfied();
}
@@ -48,7 +48,7 @@ public class FileConsumerMoveAndMoveFailureTest extends
ContextTestSupport {
.process(new Processor() {
public void process(Exchange exchange) throws
Exception {
String body =
exchange.getIn().getBody(String.class);
- if ("Kabom".equals(body)) {
+ if ("Kaboom".equals(body)) {
throw new
IllegalArgumentException("Forced");
}
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerMoveFailureOnCompletionTest.java
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerMoveFailureOnCompletionTest.java
index ded5206df8b..472bb193621 100644
---
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerMoveFailureOnCompletionTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerMoveFailureOnCompletionTest.java
@@ -29,11 +29,11 @@ public class FileConsumerMoveFailureOnCompletionTest
extends ContextTestSupport
public void testMoveFailedRollbackOnly() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedMessageCount(0);
- mock.expectedFileExists(testFile("error/bye-error.txt"), "Kabom");
+ mock.expectedFileExists(testFile("error/bye-error.txt"), "Kaboom");
getMockEndpoint("mock:failed").expectedMessageCount(1);
- template.sendBodyAndHeader(fileUri(), "Kabom", Exchange.FILE_NAME,
"bye.txt");
+ template.sendBodyAndHeader(fileUri(), "Kaboom", Exchange.FILE_NAME,
"bye.txt");
assertMockEndpointsSatisfied();
}
@@ -43,12 +43,12 @@ public class FileConsumerMoveFailureOnCompletionTest
extends ContextTestSupport
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedBodiesReceived("Hello World");
mock.expectedFileExists(testFile(".camel/hello.txt"), "Hello World");
- mock.expectedFileExists(testFile("error/bye-error.txt"), "Kabom");
+ mock.expectedFileExists(testFile("error/bye-error.txt"), "Kaboom");
getMockEndpoint("mock:failed").expectedMessageCount(1);
template.sendBodyAndHeader(fileUri(), "Hello World",
Exchange.FILE_NAME, "hello.txt");
- template.sendBodyAndHeader(fileUri(), "Kabom", Exchange.FILE_NAME,
"bye.txt");
+ template.sendBodyAndHeader(fileUri(), "Kaboom", Exchange.FILE_NAME,
"bye.txt");
assertMockEndpointsSatisfied();
}
@@ -63,7 +63,7 @@ public class FileConsumerMoveFailureOnCompletionTest extends
ContextTestSupport
.process(new Processor() {
public void process(Exchange exchange) throws
Exception {
String body =
exchange.getIn().getBody(String.class);
- if ("Kabom".equals(body)) {
+ if ("Kaboom".equals(body)) {
throw new
IllegalArgumentException("Forced");
}
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerMoveFailureTest.java
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerMoveFailureTest.java
index 6a5140ab661..68f92945cc6 100644
---
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerMoveFailureTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerMoveFailureTest.java
@@ -31,10 +31,10 @@ public class FileConsumerMoveFailureTest extends
ContextTestSupport {
mock.expectedBodiesReceived("Hello World");
mock.expectedFileExists(testFile(".camel/hello.txt"), "Hello World");
- mock.expectedFileExists(testFile("error/bye-error.txt"), "Kabom");
+ mock.expectedFileExists(testFile("error/bye-error.txt"), "Kaboom");
template.sendBodyAndHeader(fileUri(), "Hello World",
Exchange.FILE_NAME, "hello.txt");
- template.sendBodyAndHeader(fileUri(), "Kabom", Exchange.FILE_NAME,
"bye.txt");
+ template.sendBodyAndHeader(fileUri(), "Kaboom", Exchange.FILE_NAME,
"bye.txt");
assertMockEndpointsSatisfied();
}
@@ -48,7 +48,7 @@ public class FileConsumerMoveFailureTest extends
ContextTestSupport {
.process(new Processor() {
public void process(Exchange exchange) throws
Exception {
String body =
exchange.getIn().getBody(String.class);
- if ("Kabom".equals(body)) {
+ if ("Kaboom".equals(body)) {
throw new
IllegalArgumentException("Forced");
}
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/impl/ExpressionAdapterTest.java
b/core/camel-core/src/test/java/org/apache/camel/impl/ExpressionAdapterTest.java
index c365ceeaba8..40c25bc80e4 100644
---
a/core/camel-core/src/test/java/org/apache/camel/impl/ExpressionAdapterTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/impl/ExpressionAdapterTest.java
@@ -38,7 +38,7 @@ public class ExpressionAdapterTest extends ContextTestSupport
{
@SuppressWarnings("unchecked")
public <T> T evaluate(Exchange exchange, Class<T> type) {
String in = exchange.getIn().getBody(String.class);
- if ("Kabom".equals(in)) {
+ if ("Kaboom".equals(in)) {
return null;
}
return (T) in;
@@ -60,7 +60,7 @@ public class ExpressionAdapterTest extends ContextTestSupport
{
MyExpression my = new MyExpression();
Exchange e = new DefaultExchange(context);
- e.getIn().setBody("Kabom");
+ e.getIn().setBody("Kaboom");
try {
my.assertMatches("damn", e);
fail("Should have thrown exception");
diff --git
a/core/camel-core/src/test/java/org/apache/camel/impl/ExpressionSupportTest.java
b/core/camel-core/src/test/java/org/apache/camel/impl/ExpressionSupportTest.java
index d01216ab412..672165b48e3 100644
---
a/core/camel-core/src/test/java/org/apache/camel/impl/ExpressionSupportTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/impl/ExpressionSupportTest.java
@@ -38,7 +38,7 @@ public class ExpressionSupportTest extends ContextTestSupport
{
@SuppressWarnings("unchecked")
public <T> T evaluate(Exchange exchange, Class<T> type) {
String in = exchange.getIn().getBody(String.class);
- if ("Kabom".equals(in)) {
+ if ("Kaboom".equals(in)) {
return null;
}
return (T) in;
@@ -60,7 +60,7 @@ public class ExpressionSupportTest extends ContextTestSupport
{
MyExpression my = new MyExpression();
Exchange e = new DefaultExchange(context);
- e.getIn().setBody("Kabom");
+ e.getIn().setBody("Kaboom");
try {
my.assertMatches("damn", e);
fail("Should have thrown exception");
diff --git
a/core/camel-core/src/test/java/org/apache/camel/issues/OnExceptionBeforeErrorHandlerIssueTest.java
b/core/camel-core/src/test/java/org/apache/camel/issues/OnExceptionBeforeErrorHandlerIssueTest.java
index ee46ecb2ecf..f2027d2506a 100644
---
a/core/camel-core/src/test/java/org/apache/camel/issues/OnExceptionBeforeErrorHandlerIssueTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/issues/OnExceptionBeforeErrorHandlerIssueTest.java
@@ -38,14 +38,14 @@ public class OnExceptionBeforeErrorHandlerIssueTest extends
ContextTestSupport {
}
@Test
- public void testKabom() throws Exception {
+ public void testKaboom() throws Exception {
context.getRouteController().startRoute("foo");
getMockEndpoint("mock:error").expectedMessageCount(0);
getMockEndpoint("mock:dead").expectedMessageCount(1);
getMockEndpoint("mock:result").expectedMessageCount(0);
- template.sendBody("direct:start", "kabom");
+ template.sendBody("direct:start", "kaboom");
assertMockEndpointsSatisfied();
}
@@ -80,8 +80,8 @@ public class OnExceptionBeforeErrorHandlerIssueTest extends
ContextTestSupport {
String body = exchange.getIn().getBody(String.class);
if ("illegal".equals(body)) {
throw new IllegalArgumentException("I cannot do
this");
- } else if ("kabom".equals(body)) {
- throw new RuntimeException("Kabom");
+ } else if ("kaboom".equals(body)) {
+ throw new RuntimeException("Kaboom");
}
}
}).to("mock:result");
diff --git
a/core/camel-core/src/test/java/org/apache/camel/issues/RecipientListErrorHandlingIssueTest.java
b/core/camel-core/src/test/java/org/apache/camel/issues/RecipientListErrorHandlingIssueTest.java
index 58f56defd66..92e0826a871 100644
---
a/core/camel-core/src/test/java/org/apache/camel/issues/RecipientListErrorHandlingIssueTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/issues/RecipientListErrorHandlingIssueTest.java
@@ -46,16 +46,16 @@ public class RecipientListErrorHandlingIssueTest extends
ContextTestSupport {
from("direct:start").recipientList(header("foo"));
from("direct:foo").setBody(constant("Bye
World")).to("mock:foo");
- from("direct:kabom").throwException(new
IllegalArgumentException("Damn"));
+ from("direct:kaboom").throwException(new
IllegalArgumentException("Damn"));
}
});
context.start();
getMockEndpoint("mock:foo").expectedMessageCount(1);
getMockEndpoint("mock:error").expectedMessageCount(1);
-
getMockEndpoint("mock:error").message(0).header("target").isEqualTo("direct://kabom");
+
getMockEndpoint("mock:error").message(0).header("target").isEqualTo("direct://kaboom");
- String foo = "direct:foo,direct:kabom";
+ String foo = "direct:foo,direct:kaboom";
template.sendBodyAndHeader("direct:start", "Hello World", "foo", foo);
assertMockEndpointsSatisfied();
@@ -71,7 +71,7 @@ public class RecipientListErrorHandlingIssueTest extends
ContextTestSupport {
from("direct:start").recipientList(header("foo"));
from("direct:foo").setBody(constant("Bye
World")).to("mock:foo");
- from("direct:kabom").throwException(new
IllegalArgumentException("Damn"));
+ from("direct:kaboom").throwException(new
IllegalArgumentException("Damn"));
}
});
context.start();
@@ -79,9 +79,9 @@ public class RecipientListErrorHandlingIssueTest extends
ContextTestSupport {
getMockEndpoint("mock:foo").expectedMessageCount(1);
getMockEndpoint("mock:foo").message(0).header(Exchange.TO_ENDPOINT).isEqualTo("mock://foo");
getMockEndpoint("mock:error").expectedMessageCount(1);
-
getMockEndpoint("mock:error").message(0).header(Exchange.FAILURE_ENDPOINT).isEqualTo("direct://kabom");
+
getMockEndpoint("mock:error").message(0).header(Exchange.FAILURE_ENDPOINT).isEqualTo("direct://kaboom");
- String foo = "direct:foo,direct:kabom";
+ String foo = "direct:foo,direct:kaboom";
template.sendBodyAndHeader("direct:start", "Hello World", "foo", foo);
assertMockEndpointsSatisfied();
diff --git
a/core/camel-core/src/test/java/org/apache/camel/model/RouteConfigurationOnCompletionTest.java
b/core/camel-core/src/test/java/org/apache/camel/model/RouteConfigurationOnCompletionTest.java
index a589ad5baf9..e740dd289f2 100644
---
a/core/camel-core/src/test/java/org/apache/camel/model/RouteConfigurationOnCompletionTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/model/RouteConfigurationOnCompletionTest.java
@@ -59,7 +59,7 @@ public class RouteConfigurationOnCompletionTest extends
ContextTestSupport {
getMockEndpoint("mock:result").expectedMessageCount(0);
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should have thrown exception");
} catch (Exception e) {
// expected
@@ -71,12 +71,12 @@ public class RouteConfigurationOnCompletionTest extends
ContextTestSupport {
@Test
public void testOkAndFail() throws Exception {
getMockEndpoint("mock:ok").expectedBodiesReceived("Bye World");
- getMockEndpoint("mock:fail").expectedBodiesReceived("Kabom");
+ getMockEndpoint("mock:fail").expectedBodiesReceived("Kaboom");
getMockEndpoint("mock:result").expectedBodiesReceived("Bye World");
template.sendBody("direct:start", "Hello World");
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should throw exception");
} catch (Exception e) {
// expected
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/DefaultErrorHandlerExplicitConfiguredTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/DefaultErrorHandlerExplicitConfiguredTest.java
index ee866c18a13..1a388012c54 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/DefaultErrorHandlerExplicitConfiguredTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/DefaultErrorHandlerExplicitConfiguredTest.java
@@ -36,7 +36,7 @@ public class DefaultErrorHandlerExplicitConfiguredTest
extends DefaultErrorHandl
from("direct:start").process(new Processor() {
public void process(Exchange exchange) throws Exception {
String body = exchange.getIn().getBody(String.class);
- if ("Kabom".equals(body)) {
+ if ("Kaboom".equals(body)) {
throw new IllegalArgumentException("Boom");
}
exchange.getIn().setBody("Bye World");
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/DefaultErrorHandlerOnExceptionTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/DefaultErrorHandlerOnExceptionTest.java
index b43b8acebd3..6a057f31f21 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/DefaultErrorHandlerOnExceptionTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/DefaultErrorHandlerOnExceptionTest.java
@@ -43,7 +43,7 @@ public class DefaultErrorHandlerOnExceptionTest extends
ContextTestSupport {
MockEndpoint mock = getMockEndpoint("mock:boom");
mock.expectedMessageCount(1);
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
assertMockEndpointsSatisfied();
}
@@ -58,7 +58,7 @@ public class DefaultErrorHandlerOnExceptionTest extends
ContextTestSupport {
from("direct:start").process(new Processor() {
public void process(Exchange exchange) throws Exception {
String body = exchange.getIn().getBody(String.class);
- if ("Kabom".equals(body)) {
+ if ("Kaboom".equals(body)) {
throw new IllegalArgumentException("Boom");
}
exchange.getIn().setBody("Bye World");
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/DefaultErrorHandlerTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/DefaultErrorHandlerTest.java
index 3338e5b251c..cda35f97468 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/DefaultErrorHandlerTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/DefaultErrorHandlerTest.java
@@ -69,7 +69,7 @@ public class DefaultErrorHandlerTest extends
ContextTestSupport {
mock.expectedMessageCount(0);
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should have thrown a RuntimeCamelException");
} catch (RuntimeCamelException e) {
// expected
@@ -89,7 +89,7 @@ public class DefaultErrorHandlerTest extends
ContextTestSupport {
from("direct:start").process(new Processor() {
public void process(Exchange exchange) throws Exception {
String body = exchange.getIn().getBody(String.class);
- if ("Kabom".equals(body)) {
+ if ("Kaboom".equals(body)) {
throw new IllegalArgumentException("Boom");
}
exchange.getIn().setBody("Bye World");
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/ErrorHandlerWrappedEachNodeTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/ErrorHandlerWrappedEachNodeTest.java
index e490e2d2c20..e6f7d8b85ba 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/ErrorHandlerWrappedEachNodeTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/ErrorHandlerWrappedEachNodeTest.java
@@ -29,25 +29,25 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
*/
public class ErrorHandlerWrappedEachNodeTest extends ContextTestSupport {
- private static int kabom;
+ private static int kaboom;
private static int hi;
@Test
- public void testKabom() throws Exception {
- kabom = 0;
+ public void testKaboom() throws Exception {
+ kaboom = 0;
hi = 0;
MockEndpoint result = getMockEndpoint("mock:result");
- result.expectedBodiesReceived("Hi Kabom");
+ result.expectedBodiesReceived("Hi Kaboom");
getMockEndpoint("mock:error").expectedMessageCount(0);
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
assertMockEndpointsSatisfied();
- // we invoke kabom 3 times
- assertEquals(3, kabom);
+ // we invoke kaboom 3 times
+ assertEquals(3, kaboom);
// but hi is only invoke 1 time
assertEquals(1, hi);
}
@@ -60,7 +60,7 @@ public class ErrorHandlerWrappedEachNodeTest extends
ContextTestSupport {
// use dead letter channel that supports redeliveries
errorHandler(deadLetterChannel("mock:error").maximumRedeliveries(3).redeliveryDelay(0).logStackTrace(false));
- from("direct:start").pipeline("bean:foo?method=hi",
"bean:foo?method=kabom").to("mock:result");
+ from("direct:start").pipeline("bean:foo?method=hi",
"bean:foo?method=kaboom").to("mock:result");
}
};
}
@@ -74,9 +74,9 @@ public class ErrorHandlerWrappedEachNodeTest extends
ContextTestSupport {
public static final class MyFooBean {
- public void kabom() throws Exception {
- if (kabom++ < 2) {
- throw new IllegalArgumentException("Kabom");
+ public void kaboom() throws Exception {
+ if (kaboom++ < 2) {
+ throw new IllegalArgumentException("Kaboom");
}
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAndInterceptAndOnExceptionGlobalTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAndInterceptAndOnExceptionGlobalTest.java
index 1e0ee72b7ea..72bd7f6d3af 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAndInterceptAndOnExceptionGlobalTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAndInterceptAndOnExceptionGlobalTest.java
@@ -55,10 +55,10 @@ public class
OnCompletionAndInterceptAndOnExceptionGlobalTest extends ContextTes
mock.expectedMessageCount(0);
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should throw exception");
} catch (CamelExecutionException e) {
- assertEquals("Kabom", e.getCause().getMessage());
+ assertEquals("Kaboom", e.getCause().getMessage());
}
assertMockEndpointsSatisfied();
@@ -92,8 +92,8 @@ public class OnCompletionAndInterceptAndOnExceptionGlobalTest
extends ContextTes
@Override
public void process(Exchange exchange) throws Exception {
- if ("Kabom".equals(exchange.getIn().getBody())) {
- throw new IllegalArgumentException("Kabom");
+ if ("Kaboom".equals(exchange.getIn().getBody())) {
+ throw new IllegalArgumentException("Kaboom");
}
exchange.getIn().setBody("Bye World");
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAndInterceptGlobalTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAndInterceptGlobalTest.java
index 4a06b890613..e9b2617c6fb 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAndInterceptGlobalTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAndInterceptGlobalTest.java
@@ -53,10 +53,10 @@ public class OnCompletionAndInterceptGlobalTest extends
ContextTestSupport {
mock.expectedMessageCount(0);
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should throw exception");
} catch (CamelExecutionException e) {
- assertEquals("Kabom", e.getCause().getMessage());
+ assertEquals("Kaboom", e.getCause().getMessage());
}
assertMockEndpointsSatisfied();
@@ -87,8 +87,8 @@ public class OnCompletionAndInterceptGlobalTest extends
ContextTestSupport {
@Override
public void process(Exchange exchange) throws Exception {
- if ("Kabom".equals(exchange.getIn().getBody())) {
- throw new IllegalArgumentException("Kabom");
+ if ("Kaboom".equals(exchange.getIn().getBody())) {
+ throw new IllegalArgumentException("Kaboom");
}
exchange.getIn().setBody("Bye World");
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAndInterceptTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAndInterceptTest.java
index 09071639918..b5c9ca67baa 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAndInterceptTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAndInterceptTest.java
@@ -53,10 +53,10 @@ public class OnCompletionAndInterceptTest extends
ContextTestSupport {
mock.expectedMessageCount(0);
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should throw exception");
} catch (CamelExecutionException e) {
- assertEquals("Kabom", e.getCause().getMessage());
+ assertEquals("Kaboom", e.getCause().getMessage());
}
assertMockEndpointsSatisfied();
@@ -84,8 +84,8 @@ public class OnCompletionAndInterceptTest extends
ContextTestSupport {
@Override
public void process(Exchange exchange) throws Exception {
- if ("Kabom".equals(exchange.getIn().getBody())) {
- throw new IllegalArgumentException("Kabom");
+ if ("Kaboom".equals(exchange.getIn().getBody())) {
+ throw new IllegalArgumentException("Kaboom");
}
exchange.getIn().setBody("Bye World");
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAsyncTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAsyncTest.java
index f28682f960a..c998c52fe9f 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAsyncTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionAsyncTest.java
@@ -73,18 +73,18 @@ public class OnCompletionAsyncTest extends
ContextTestSupport {
});
context.start();
- getMockEndpoint("mock:before").expectedBodiesReceived("Kabom");
+ getMockEndpoint("mock:before").expectedBodiesReceived("Kaboom");
getMockEndpoint("mock:before").expectedPropertyReceived(Exchange.ON_COMPLETION,
true);
-
getMockEndpoint("mock:after").expectedBodiesReceived("OnComplete:Kabom");
+
getMockEndpoint("mock:after").expectedBodiesReceived("OnComplete:Kaboom");
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedMessageCount(0);
try {
- template.requestBody("direct:start", "Kabom");
+ template.requestBody("direct:start", "Kaboom");
fail("Should throw exception");
} catch (CamelExecutionException e) {
- assertEquals("Kabom", e.getCause().getMessage());
+ assertEquals("Kaboom", e.getCause().getMessage());
}
assertMockEndpointsSatisfied();
@@ -129,18 +129,18 @@ public class OnCompletionAsyncTest extends
ContextTestSupport {
});
context.start();
- getMockEndpoint("mock:before").expectedBodiesReceived("Kabom");
+ getMockEndpoint("mock:before").expectedBodiesReceived("Kaboom");
getMockEndpoint("mock:before").expectedPropertyReceived(Exchange.ON_COMPLETION,
true);
-
getMockEndpoint("mock:after").expectedBodiesReceived("OnComplete:Kabom");
+
getMockEndpoint("mock:after").expectedBodiesReceived("OnComplete:Kaboom");
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedMessageCount(0);
try {
- template.requestBody("direct:start", "Kabom");
+ template.requestBody("direct:start", "Kaboom");
fail("Should throw exception");
} catch (CamelExecutionException e) {
- assertEquals("Kabom", e.getCause().getMessage());
+ assertEquals("Kaboom", e.getCause().getMessage());
}
assertMockEndpointsSatisfied();
@@ -181,8 +181,8 @@ public class OnCompletionAsyncTest extends
ContextTestSupport {
@Override
public void process(Exchange exchange) throws Exception {
- if (exchange.getIn().getBody(String.class).contains("Kabom")) {
- throw new IllegalArgumentException("Kabom");
+ if (exchange.getIn().getBody(String.class).contains("Kaboom")) {
+ throw new IllegalArgumentException("Kaboom");
}
exchange.getIn().setBody("Bye World");
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionFailAndOkTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionFailAndOkTest.java
index 2b8ba82e807..4786e60f6a0 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionFailAndOkTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionFailAndOkTest.java
@@ -42,7 +42,7 @@ public class OnCompletionFailAndOkTest extends
ContextTestSupport {
getMockEndpoint("mock:result").expectedMessageCount(0);
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should throw exception");
} catch (Exception e) {
// expected
@@ -54,12 +54,12 @@ public class OnCompletionFailAndOkTest extends
ContextTestSupport {
@Test
public void testOkAndFail() throws Exception {
getMockEndpoint("mock:ok").expectedBodiesReceived("Bye World");
- getMockEndpoint("mock:fail").expectedBodiesReceived("Kabom");
+ getMockEndpoint("mock:fail").expectedBodiesReceived("Kaboom");
getMockEndpoint("mock:result").expectedBodiesReceived("Bye World");
template.sendBody("direct:start", "Hello World");
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should throw exception");
} catch (Exception e) {
// expected
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionGlobalTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionGlobalTest.java
index bf4e281cace..281c02fbeda 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionGlobalTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionGlobalTest.java
@@ -51,10 +51,10 @@ public class OnCompletionGlobalTest extends
ContextTestSupport {
mock.expectedMessageCount(0);
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should throw exception");
} catch (CamelExecutionException e) {
- assertEquals("Kabom", e.getCause().getMessage());
+ assertEquals("Kaboom", e.getCause().getMessage());
}
assertMockEndpointsSatisfied();
@@ -83,8 +83,8 @@ public class OnCompletionGlobalTest extends
ContextTestSupport {
@Override
public void process(Exchange exchange) throws Exception {
- if ("Kabom".equals(exchange.getIn().getBody())) {
- throw new IllegalArgumentException("Kabom");
+ if ("Kaboom".equals(exchange.getIn().getBody())) {
+ throw new IllegalArgumentException("Kaboom");
}
exchange.getIn().setBody("Bye World");
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionMoreGlobalRouteCompletionTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionMoreGlobalRouteCompletionTest.java
index 54084ca3899..dc4e1bbd888 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionMoreGlobalRouteCompletionTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionMoreGlobalRouteCompletionTest.java
@@ -57,10 +57,10 @@ public class OnCompletionMoreGlobalRouteCompletionTest
extends ContextTestSuppor
mock.expectedMessageCount(0);
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should throw exception");
} catch (CamelExecutionException e) {
- assertEquals("Kabom", e.getCause().getMessage());
+ assertEquals("Kaboom", e.getCause().getMessage());
}
assertMockEndpointsSatisfied();
@@ -100,10 +100,10 @@ public class OnCompletionMoreGlobalRouteCompletionTest
extends ContextTestSuppor
mock.expectedMessageCount(0);
try {
- template.sendBody("direct:other", "Kabom");
+ template.sendBody("direct:other", "Kaboom");
fail("Should throw exception");
} catch (CamelExecutionException e) {
- assertEquals("Kabom", e.getCause().getMessage());
+ assertEquals("Kaboom", e.getCause().getMessage());
}
assertMockEndpointsSatisfied();
@@ -142,8 +142,8 @@ public class OnCompletionMoreGlobalRouteCompletionTest
extends ContextTestSuppor
@Override
public void process(Exchange exchange) throws Exception {
- if ("Kabom".equals(exchange.getIn().getBody())) {
- throw new IllegalArgumentException("Kabom");
+ if ("Kaboom".equals(exchange.getIn().getBody())) {
+ throw new IllegalArgumentException("Kaboom");
}
exchange.getIn().setBody("Bye World");
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionMoreGlobalTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionMoreGlobalTest.java
index a354c537cf8..834e3a00482 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionMoreGlobalTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionMoreGlobalTest.java
@@ -57,10 +57,10 @@ public class OnCompletionMoreGlobalTest extends
ContextTestSupport {
mock.expectedMessageCount(0);
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should throw exception");
} catch (CamelExecutionException e) {
- assertEquals("Kabom", e.getCause().getMessage());
+ assertEquals("Kaboom", e.getCause().getMessage());
}
assertMockEndpointsSatisfied();
@@ -95,8 +95,8 @@ public class OnCompletionMoreGlobalTest extends
ContextTestSupport {
@Override
public void process(Exchange exchange) throws Exception {
- if ("Kabom".equals(exchange.getIn().getBody())) {
- throw new IllegalArgumentException("Kabom");
+ if ("Kaboom".equals(exchange.getIn().getBody())) {
+ throw new IllegalArgumentException("Kaboom");
}
exchange.getIn().setBody("Bye World");
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionOnCompleteOnlyTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionOnCompleteOnlyTest.java
index 03a7fedce2c..90b980f1a46 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionOnCompleteOnlyTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionOnCompleteOnlyTest.java
@@ -36,10 +36,10 @@ public class OnCompletionOnCompleteOnlyTest extends
OnCompletionTest {
mock.expectedMessageCount(0);
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should throw exception");
} catch (CamelExecutionException e) {
- assertEquals("Kabom", e.getCause().getMessage());
+ assertEquals("Kaboom", e.getCause().getMessage());
}
assertMockEndpointsSatisfied();
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionRouteScopeOverrideGlobalScopeTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionRouteScopeOverrideGlobalScopeTest.java
index 8c7750f8f5b..ee09c35e8d4 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionRouteScopeOverrideGlobalScopeTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionRouteScopeOverrideGlobalScopeTest.java
@@ -53,10 +53,10 @@ public class OnCompletionRouteScopeOverrideGlobalScopeTest
extends ContextTestSu
mock.expectedMessageCount(0);
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should throw exception");
} catch (CamelExecutionException e) {
- assertEquals("Kabom", e.getCause().getMessage());
+ assertEquals("Kaboom", e.getCause().getMessage());
}
assertMockEndpointsSatisfied();
@@ -90,8 +90,8 @@ public class OnCompletionRouteScopeOverrideGlobalScopeTest
extends ContextTestSu
@Override
public void process(Exchange exchange) throws Exception {
- if ("Kabom".equals(exchange.getIn().getBody())) {
- throw new IllegalArgumentException("Kabom");
+ if ("Kaboom".equals(exchange.getIn().getBody())) {
+ throw new IllegalArgumentException("Kaboom");
}
exchange.getIn().setBody("Bye World");
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionTest.java
index 1c9c7267684..7094cdd4932 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionTest.java
@@ -53,10 +53,10 @@ public class OnCompletionTest extends ContextTestSupport {
mock.expectedMessageCount(0);
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should throw exception");
} catch (CamelExecutionException e) {
- assertEquals("Kabom", e.getCause().getMessage());
+ assertEquals("Kaboom", e.getCause().getMessage());
}
assertMockEndpointsSatisfied();
@@ -89,8 +89,8 @@ public class OnCompletionTest extends ContextTestSupport {
@Override
public void process(Exchange exchange) throws Exception {
- if ("Kabom".equals(exchange.getIn().getBody())) {
- throw new IllegalArgumentException("Kabom");
+ if ("Kaboom".equals(exchange.getIn().getBody())) {
+ throw new IllegalArgumentException("Kaboom");
}
exchange.getIn().setBody("Bye World");
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionUseOriginalBodyTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionUseOriginalBodyTest.java
index 6dd01d761de..4ea510d0734 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionUseOriginalBodyTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/OnCompletionUseOriginalBodyTest.java
@@ -62,8 +62,8 @@ public class OnCompletionUseOriginalBodyTest extends
ContextTestSupport {
@Override
public void process(Exchange exchange) throws Exception {
- if (exchange.getIn().getBody(String.class).contains("Kabom")) {
- throw new IllegalArgumentException("Kabom");
+ if (exchange.getIn().getBody(String.class).contains("Kaboom")) {
+ throw new IllegalArgumentException("Kaboom");
}
exchange.getIn().setBody("Bye World");
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/RouteIdTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/RouteIdTest.java
index 1f61f2a4f3d..f3feb475984 100644
--- a/core/camel-core/src/test/java/org/apache/camel/processor/RouteIdTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/processor/RouteIdTest.java
@@ -44,7 +44,7 @@ public class RouteIdTest extends ContextTestSupport {
getMockEndpoint("mock:error").expectedMessageCount(1);
getMockEndpoint("mock:result").expectedMessageCount(0);
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
assertMockEndpointsSatisfied();
@@ -60,7 +60,7 @@ public class RouteIdTest extends ContextTestSupport {
onException(Exception.class).handled(true).to("mock:error").end();
from("direct:start").onException(IOException.class).redeliveryDelay(0).maximumRedeliveries(5).end()
-
.routeId("myCoolRoute").choice().when(body().contains("Kabom"))
+
.routeId("myCoolRoute").choice().when(body().contains("Kaboom"))
.throwException(new
IllegalArgumentException("Damn")).otherwise().to("mock:result").end();
}
};
diff --git
a/core/camel-management/src/test/java/org/apache/camel/management/ManagedRouteWithOnExceptionTest.java
b/core/camel-management/src/test/java/org/apache/camel/management/ManagedRouteWithOnExceptionTest.java
index 79338c7820b..87ba2a21495 100644
---
a/core/camel-management/src/test/java/org/apache/camel/management/ManagedRouteWithOnExceptionTest.java
+++
b/core/camel-management/src/test/java/org/apache/camel/management/ManagedRouteWithOnExceptionTest.java
@@ -38,12 +38,12 @@ public class ManagedRouteWithOnExceptionTest extends
ManagementTestSupport {
}
@Test
- public void testShouldBeInstrumentedKabom() throws Exception {
+ public void testShouldBeInstrumentedKaboom() throws Exception {
getMockEndpoint("mock:error").expectedMessageCount(1);
getMockEndpoint("mock:result").expectedMessageCount(0);
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should have thrown an exception");
} catch (CamelExecutionException e) {
// expected
@@ -53,13 +53,13 @@ public class ManagedRouteWithOnExceptionTest extends
ManagementTestSupport {
}
@Test
- public void testShouldBeInstrumentedOkAndKabom() throws Exception {
+ public void testShouldBeInstrumentedOkAndKaboom() throws Exception {
getMockEndpoint("mock:error").expectedMessageCount(1);
getMockEndpoint("mock:result").expectedMessageCount(1);
template.sendBody("direct:start", "Hello World");
try {
- template.sendBody("direct:start", "Kabom");
+ template.sendBody("direct:start", "Kaboom");
fail("Should have thrown an exception");
} catch (CamelExecutionException e) {
// expected
@@ -79,7 +79,7 @@ public class ManagedRouteWithOnExceptionTest extends
ManagementTestSupport {
.end()
.delay(100)
.choice()
- .when(body().isEqualTo("Kabom")).throwException(new
IllegalArgumentException("Kabom"))
+ .when(body().isEqualTo("Kaboom")).throwException(new
IllegalArgumentException("Kaboom"))
.otherwise().to("mock:result")
.end();
}
diff --git
a/dsl/camel-xml-jaxb-dsl-test/definition/src/test/java/org/apache/camel/dsl/xml/jaxb/definition/LoadRouteFromXmlWithOnExceptionTest.java
b/dsl/camel-xml-jaxb-dsl-test/definition/src/test/java/org/apache/camel/dsl/xml/jaxb/definition/LoadRouteFromXmlWithOnExceptionTest.java
index 7504a2e3f1d..90d9f4adfcf 100644
---
a/dsl/camel-xml-jaxb-dsl-test/definition/src/test/java/org/apache/camel/dsl/xml/jaxb/definition/LoadRouteFromXmlWithOnExceptionTest.java
+++
b/dsl/camel-xml-jaxb-dsl-test/definition/src/test/java/org/apache/camel/dsl/xml/jaxb/definition/LoadRouteFromXmlWithOnExceptionTest.java
@@ -56,10 +56,10 @@ public class LoadRouteFromXmlWithOnExceptionTest extends
ContextTestSupport {
// test that loaded route works
getMockEndpoint("mock:bar").expectedBodiesReceived("Bye World");
- getMockEndpoint("mock:error").expectedBodiesReceived("Kabom");
+ getMockEndpoint("mock:error").expectedBodiesReceived("Kaboom");
template.sendBody("direct:bar", "Bye World");
- template.sendBody("direct:bar", "Kabom");
+ template.sendBody("direct:bar", "Kaboom");
assertMockEndpointsSatisfied();
}
@@ -69,7 +69,7 @@ public class LoadRouteFromXmlWithOnExceptionTest extends
ContextTestSupport {
@Override
public void process(Exchange exchange) throws Exception {
String body = exchange.getIn().getBody(String.class);
- if ("Kabom".equals(body)) {
+ if ("Kaboom".equals(body)) {
throw new IllegalArgumentException("Damn");
}
}
