This is an automated email from the ASF dual-hosted git repository. bvahdat pushed a commit to branch kaboom in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/kaboom by this push: new d93954c067d fix the misspelled kabooms d93954c067d is described below commit d93954c067d773443b0ede0fc35e84e162a25acd 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"); } }