From a5b941caae7796c3342b8f253c3cbe3e83baae56 Mon Sep 17 00:00:00 2001 From: Suraj misra Date: Tue, 18 Aug 2026 14:10:24 +0530 Subject: [PATCH] CAMEL-21313: Refactor camel-clickup tests for clarity and consistency - Drop unnecessary public modifier from test classes and methods - Migrate JUnit assertions to AssertJ - Replace string concatenation in route URIs with fromF() - Flatten anonymous code blocks in registration tests - Remove try/catch wrappers, let exceptions propagate naturally - Extract shared constants and waitForClickUpMockAPI() to ClickUpTestSupport - Extract addWebhookRoute() helper in registration tests Co-authored-by: Cursor --- .../clickup/ClickUpConfigurationTest.java | 30 +++--- .../clickup/ClickUpWebhookCallTest.java | 45 ++++----- ...pWebhookRegistrationAlreadyExistsTest.java | 99 +++++++------------ .../ClickUpWebhookRegistrationTest.java | 86 +++++----------- .../clickup/util/ClickUpTestSupport.java | 28 +++++- 5 files changed, 114 insertions(+), 174 deletions(-) diff --git a/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpConfigurationTest.java b/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpConfigurationTest.java index 529ec7922bfcb..dcf85b601021a 100644 --- a/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpConfigurationTest.java +++ b/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpConfigurationTest.java @@ -24,37 +24,33 @@ import org.apache.camel.component.clickup.util.ClickUpTestSupport; import org.junit.jupiter.api.Test; -import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.assertj.core.api.Assertions.assertThat; -public class ClickUpConfigurationTest extends ClickUpTestSupport { +class ClickUpConfigurationTest extends ClickUpTestSupport { - private final static Long WORKSPACE_ID = 12345L; - private final static String BASE_URL = "https://mock-api.clickup.com"; - private final static String AUTHORIZATION_TOKEN = "mock-authorization-token"; - private final static String WEBHOOK_SECRET = "mock-webhook-secret"; - private final static Set EVENTS = new HashSet<>(Arrays.asList("taskTimeTrackedUpdated")); + private static final String BASE_URL = "https://mock-api.clickup.com"; + private static final Set EVENTS = new HashSet<>(Arrays.asList("taskTimeTrackedUpdated")); @Test - public void testClickUpConfiguration() { + void testClickUpConfiguration() { ClickUpEndpoint endpoint = (ClickUpEndpoint) context().getEndpoints().stream() .filter(e -> e instanceof ClickUpEndpoint).findAny().get(); ClickUpConfiguration config = endpoint.getConfiguration(); - assertEquals(WORKSPACE_ID, config.getWorkspaceId()); - assertEquals(BASE_URL, config.getBaseUrl()); - assertEquals(AUTHORIZATION_TOKEN, config.getAuthorizationToken()); - assertEquals(WEBHOOK_SECRET, config.getWebhookSecret()); - assertEquals(EVENTS, config.getEvents()); + assertThat(config.getWorkspaceId()).isEqualTo(WORKSPACE_ID); + assertThat(config.getBaseUrl()).isEqualTo(BASE_URL); + assertThat(config.getAuthorizationToken()).isEqualTo(AUTHORIZATION_TOKEN); + assertThat(config.getWebhookSecret()).isEqualTo(WEBHOOK_SECRET); + assertThat(config.getEvents()).isEqualTo(EVENTS); } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override public void configure() { - from("webhook:clickup:" + WORKSPACE_ID + "?baseUrl=" + BASE_URL + "&authorizationToken=" + AUTHORIZATION_TOKEN - + "&webhookSecret=" + WEBHOOK_SECRET + "&events=" + String.join(",", EVENTS) - + "&webhookAutoRegister=false") + fromF("webhook:clickup:%s?baseUrl=%s&authorizationToken=%s&webhookSecret=%s&events=%s&webhookAutoRegister=false", + WORKSPACE_ID, BASE_URL, AUTHORIZATION_TOKEN, WEBHOOK_SECRET, String.join(",", EVENTS)) .log("Received: ${body}"); } }; diff --git a/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpWebhookCallTest.java b/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpWebhookCallTest.java index baddae18e7132..e59c935a047f3 100644 --- a/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpWebhookCallTest.java +++ b/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpWebhookCallTest.java @@ -17,7 +17,10 @@ package org.apache.camel.component.clickup; import java.io.InputStream; -import java.util.*; +import java.util.HashMap; +import java.util.HashSet; +import java.util.Map; +import java.util.Set; import org.apache.camel.Exchange; import org.apache.camel.RoutesBuilder; @@ -28,45 +31,35 @@ import org.apache.camel.component.webhook.WebhookConfiguration; import org.apache.camel.component.webhook.WebhookEndpoint; import org.junit.jupiter.api.Test; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -public class ClickUpWebhookCallTest extends ClickUpTestSupport { +import static java.util.List.of; - private final static Logger LOGGER = LoggerFactory.getLogger(ClickUpWebhookCallTest.class); +class ClickUpWebhookCallTest extends ClickUpTestSupport { - private final static Long WORKSPACE_ID = 12345L; - private final static String AUTHORIZATION_TOKEN = "mock-authorization-token"; - private final static String WEBHOOK_SECRET = "mock-webhook-secret"; - private final static Set EVENTS = new HashSet<>(List.of("taskTimeTrackedUpdated")); - - public static final String MESSAGES_EVENTS_TIME_TRACKING_CREATED_FILENAME = "messages/events/time-tracking-created.json"; - public static final String MESSAGES_EVENTS_TIME_TRACKING_CREATED_SIGNATURE + private static final Set EVENTS = new HashSet<>(of("taskTimeTrackedUpdated")); + private static final String TIME_TRACKING_CREATED_RESOURCE = "messages/events/time-tracking-created.json"; + private static final String TIME_TRACKING_CREATED_SIGNATURE = "ac99f10017e28db6839941c184964890ec3262b1d6b1756d33ff53d972d5a361"; @Test - public void testWebhookCall() throws Exception { + void testWebhookCall() throws Exception { WebhookConfiguration config = ((WebhookEndpoint) context().getRoute("webhook").getConsumer().getEndpoint()).getConfiguration(); String url = config.computeFullExternalUrl(); - LOGGER.info("Webhook external url: {}", url); - - try (InputStream content - = getClass().getClassLoader().getResourceAsStream(MESSAGES_EVENTS_TIME_TRACKING_CREATED_FILENAME)) { - LOGGER.info("message content: {}", content); - - MockEndpoint mock = getMockEndpoint("mock:endpoint"); - mock.expectedMessageCount(1); - mock.expectedMessagesMatches(exchange -> exchange.getIn().getBody() instanceof TaskTimeTrackedUpdatedEvent); + MockEndpoint mock = getMockEndpoint("mock:endpoint"); + mock.expectedMessageCount(1); + mock.expectedMessagesMatches(exchange -> exchange.getIn().getBody() instanceof TaskTimeTrackedUpdatedEvent); + try (InputStream content = getClass().getClassLoader().getResourceAsStream(TIME_TRACKING_CREATED_RESOURCE)) { Map headers = new HashMap<>(); headers.put(Exchange.HTTP_METHOD, "POST"); headers.put(Exchange.CONTENT_TYPE, "application/json"); - headers.put("x-signature", MESSAGES_EVENTS_TIME_TRACKING_CREATED_SIGNATURE); + headers.put("x-signature", TIME_TRACKING_CREATED_SIGNATURE); template().sendBodyAndHeaders("netty-http:" + url, content, headers); - mock.assertIsSatisfied(); } + + mock.assertIsSatisfied(); } @Override @@ -78,8 +71,8 @@ public void configure() { .host("localhost") .port(port.getPort()); - from("webhook:clickup:" + WORKSPACE_ID + "?authorizationToken=" + AUTHORIZATION_TOKEN + "&webhookSecret=" - + WEBHOOK_SECRET + "&events=" + String.join(",", EVENTS) + "&webhookAutoRegister=false") + fromF("webhook:clickup:%s?authorizationToken=%s&webhookSecret=%s&events=%s&webhookAutoRegister=false", + WORKSPACE_ID, AUTHORIZATION_TOKEN, WEBHOOK_SECRET, String.join(",", EVENTS)) .id("webhook") .to("mock:endpoint"); } diff --git a/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpWebhookRegistrationAlreadyExistsTest.java b/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpWebhookRegistrationAlreadyExistsTest.java index c198153205f4a..085b2c6951890 100644 --- a/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpWebhookRegistrationAlreadyExistsTest.java +++ b/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpWebhookRegistrationAlreadyExistsTest.java @@ -18,16 +18,11 @@ import java.io.IOException; import java.io.InputStream; -import java.net.URI; import java.net.UnknownHostException; -import java.net.http.HttpClient; -import java.net.http.HttpRequest; -import java.net.http.HttpResponse; import java.util.HashSet; import java.util.List; import java.util.Optional; import java.util.Set; -import java.util.concurrent.TimeUnit; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; @@ -42,98 +37,70 @@ import org.apache.camel.component.webhook.WebhookEndpoint; import org.apache.camel.impl.DefaultCamelContext; import org.apache.camel.test.junit6.TestExecutionConfiguration; -import org.awaitility.Awaitility; import org.junit.jupiter.api.Test; -import static org.junit.jupiter.api.Assertions.*; +import static org.assertj.core.api.Assertions.assertThat; -public class ClickUpWebhookRegistrationAlreadyExistsTest extends ClickUpTestSupport { - - private final static Long WORKSPACE_ID = 12345L; - private final static String AUTHORIZATION_TOKEN = "mock-authorization-token"; - private final static String WEBHOOK_SECRET = "mock-webhook-secret"; - private final static Set EVENTS = new HashSet<>(List.of("taskTimeTrackedUpdated")); +class ClickUpWebhookRegistrationAlreadyExistsTest extends ClickUpTestSupport { + private static final Set EVENTS = new HashSet<>(List.of("taskTimeTrackedUpdated")); private static final ObjectMapper MAPPER = new ObjectMapper(); - public static final String WEBHOOK_ALREADY_EXISTS_JSON = "messages/webhook-already-exists.json"; - public static final String WEBHOOKS = "messages/webhooks.json"; + private static final String WEBHOOK_ALREADY_EXISTS_JSON = "messages/webhook-already-exists.json"; + private static final String WEBHOOKS = "messages/webhooks.json"; @Override public void configureTest(TestExecutionConfiguration testExecutionConfiguration) { super.configureTest(testExecutionConfiguration); - testExecutionConfiguration.withUseRouteBuilder(false); } @Test - public void testAutomaticRegistrationWhenWebhookConfigurationAlreadyExists() throws Exception { - final ClickUpMockRoutes.MockProcessor creationMockProcessor + void testAutomaticRegistrationWhenWebhookConfigurationAlreadyExists() throws Exception { + ClickUpMockRoutes.MockProcessor creationMockProcessor = getMockRoutes().getMock("POST", "team/" + WORKSPACE_ID + "/webhook"); creationMockProcessor.clearRecordedMessages(); - final ClickUpMockRoutes.MockProcessor readMockProcessor + ClickUpMockRoutes.MockProcessor readMockProcessor = getMockRoutes().getMock("GET", "team/" + WORKSPACE_ID + "/webhook"); readMockProcessor.clearRecordedMessages(); - try (final DefaultCamelContext mockContext = new DefaultCamelContext()) { + try (DefaultCamelContext mockContext = new DefaultCamelContext()) { mockContext.addRoutes(getMockRoutes()); mockContext.start(); - /* Make sure the ClickUp mock API is up and running */ - Awaitility.await() - .atMost(5, TimeUnit.SECONDS) - .until(() -> { - HttpClient client = HttpClient.newBuilder().build(); - HttpRequest request = HttpRequest.newBuilder() - .uri(URI.create("http://localhost:" + port + "/clickup-api-mock/health")).GET().build(); - - final HttpResponse response = client.send(request, HttpResponse.BodyHandlers.ofString()); - return response.statusCode() == 200; - }); - - context().addRoutes(new RouteBuilder() { - @Override - public void configure() { - String apiMockBaseUrl = "http://localhost:" + port + "/clickup-api-mock"; - - from("webhook:clickup:" + WORKSPACE_ID + "?authorizationToken=" + AUTHORIZATION_TOKEN + "&webhookSecret=" - + WEBHOOK_SECRET + "&events=" + String.join(",", EVENTS) + "&webhookAutoRegister=true&baseUrl=" - + apiMockBaseUrl) - .id("webhook") - .to("mock:endpoint"); - } - }); + waitForClickUpMockAPI(); + addWebhookRoute(); context().start(); - { - final List creationRecordedMessages = creationMockProcessor.awaitRecordedMessages(1, 5000); - assertEquals(1, creationRecordedMessages.size()); - String webhookCreationMessage = creationRecordedMessages.get(0); + List creationRecordedMessages = creationMockProcessor.awaitRecordedMessages(1, 5000); + assertThat(creationRecordedMessages).hasSize(1); - try { - WebhookCreationCommand command = MAPPER.readValue(webhookCreationMessage, WebhookCreationCommand.class); + WebhookCreationCommand command = MAPPER.readValue(creationRecordedMessages.get(0), WebhookCreationCommand.class); + assertThat(command).isNotNull(); + creationMockProcessor.clearRecordedMessages(); - assertInstanceOf(WebhookCreationCommand.class, command); - } catch (IOException e) { - fail(e); - } + List readRecordedMessages = readMockProcessor.awaitRecordedMessages(1, 5000); + assertThat(readRecordedMessages).hasSize(1); + assertThat(readRecordedMessages.get(0)).isEmpty(); + readMockProcessor.clearRecordedMessages(); - creationMockProcessor.clearRecordedMessages(); - } - - { - final List readRecordedMessages = readMockProcessor.awaitRecordedMessages(1, 5000); - assertEquals(1, readRecordedMessages.size()); - String webhookReadMessage = readRecordedMessages.get(0); + context().stop(); + } + } - assertEquals("", webhookReadMessage); + private void addWebhookRoute() throws Exception { + context().addRoutes(new RouteBuilder() { + @Override + public void configure() { + String apiMockBaseUrl = "http://localhost:" + port + "/clickup-api-mock"; - readMockProcessor.clearRecordedMessages(); + fromF("webhook:clickup:%s?authorizationToken=%s&webhookSecret=%s&events=%s&webhookAutoRegister=true&baseUrl=%s", + WORKSPACE_ID, AUTHORIZATION_TOKEN, WEBHOOK_SECRET, String.join(",", EVENTS), apiMockBaseUrl) + .id("webhook") + .to("mock:endpoint"); } - - context().stop(); - } + }); } @Override diff --git a/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpWebhookRegistrationTest.java b/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpWebhookRegistrationTest.java index f7d2ead33a0ee..2c1225ce3790a 100644 --- a/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpWebhookRegistrationTest.java +++ b/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/ClickUpWebhookRegistrationTest.java @@ -18,14 +18,9 @@ import java.io.IOException; import java.io.InputStream; -import java.net.URI; -import java.net.http.HttpClient; -import java.net.http.HttpRequest; -import java.net.http.HttpResponse; import java.util.HashSet; import java.util.List; import java.util.Set; -import java.util.concurrent.TimeUnit; import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.camel.builder.RouteBuilder; @@ -34,114 +29,79 @@ import org.apache.camel.component.clickup.util.ClickUpTestSupport; import org.apache.camel.impl.DefaultCamelContext; import org.apache.camel.test.junit6.TestExecutionConfiguration; -import org.awaitility.Awaitility; import org.junit.jupiter.api.Test; -import static org.junit.jupiter.api.Assertions.*; +import static org.assertj.core.api.Assertions.assertThat; -public class ClickUpWebhookRegistrationTest extends ClickUpTestSupport { - - private final static Long WORKSPACE_ID = 12345L; - private final static String AUTHORIZATION_TOKEN = "mock-authorization-token"; - private final static String WEBHOOK_SECRET = "mock-webhook-secret"; - private final static Set EVENTS = new HashSet<>(List.of("taskTimeTrackedUpdated")); +class ClickUpWebhookRegistrationTest extends ClickUpTestSupport { + private static final Set EVENTS = new HashSet<>(List.of("taskTimeTrackedUpdated")); private static final ObjectMapper MAPPER = new ObjectMapper(); - public static final String WEBHOOK_CREATED_JSON = "messages/webhook-created.json"; + private static final String WEBHOOK_CREATED_JSON = "messages/webhook-created.json"; @Override public void configureTest(TestExecutionConfiguration testExecutionConfiguration) { super.configureTest(testExecutionConfiguration); - testExecutionConfiguration.withUseRouteBuilder(false); } @Test - public void testAutomaticRegistration() throws Exception { - final ClickUpMockRoutes.MockProcessor mockProcessor + void testAutomaticRegistration() throws Exception { + ClickUpMockRoutes.MockProcessor mockProcessor = getMockRoutes().getMock("POST", "team/" + WORKSPACE_ID + "/webhook"); mockProcessor.clearRecordedMessages(); - try (final DefaultCamelContext mockContext = new DefaultCamelContext()) { + try (DefaultCamelContext mockContext = new DefaultCamelContext()) { mockContext.addRoutes(getMockRoutes()); mockContext.start(); waitForClickUpMockAPI(); - - setupContextRoutes(); + addWebhookRoute(); context().start(); - final List recordedMessages = mockProcessor.awaitRecordedMessages(1, 5000); - assertEquals(1, recordedMessages.size()); - String recordedMessage = recordedMessages.get(0); + List recordedMessages = mockProcessor.awaitRecordedMessages(1, 5000); + assertThat(recordedMessages).hasSize(1); - try { - WebhookCreationCommand command = MAPPER.readValue(recordedMessage, WebhookCreationCommand.class); - - assertInstanceOf(WebhookCreationCommand.class, command); - } catch (IOException e) { - throw new AssertionError("Failed to parse recorded message", e); - } + WebhookCreationCommand command = MAPPER.readValue(recordedMessages.get(0), WebhookCreationCommand.class); + assertThat(command).isNotNull(); mockProcessor.clearRecordedMessages(); - context().stop(); } } @Test - public void testAutomaticUnregistration() throws Exception { - final ClickUpMockRoutes.MockProcessor mockProcessor = getMockRoutes().getMock("DELETE", "webhook/"); + void testAutomaticUnregistration() throws Exception { + ClickUpMockRoutes.MockProcessor mockProcessor = getMockRoutes().getMock("DELETE", "webhook/"); mockProcessor.clearRecordedMessages(); - try (final DefaultCamelContext mockContext = new DefaultCamelContext()) { + try (DefaultCamelContext mockContext = new DefaultCamelContext()) { mockContext.addRoutes(getMockRoutes()); mockContext.start(); waitForClickUpMockAPI(); - - setupContextRoutes(); + addWebhookRoute(); context().start(); - context().stop(); - { - final List readRecordedMessages = mockProcessor.awaitRecordedMessages(1, 5000); - assertEquals(1, readRecordedMessages.size()); - String webhookDeleteMessage = readRecordedMessages.get(0); - - assertEquals("", webhookDeleteMessage); + List recordedMessages = mockProcessor.awaitRecordedMessages(1, 5000); + assertThat(recordedMessages).hasSize(1); + assertThat(recordedMessages.get(0)).isEmpty(); - mockProcessor.clearRecordedMessages(); - } + mockProcessor.clearRecordedMessages(); } } - private static void waitForClickUpMockAPI() { - /* Make sure the ClickUp mock API is up and running */ - Awaitility.await() - .atMost(5, TimeUnit.SECONDS) - .until(() -> { - HttpClient client = HttpClient.newBuilder().build(); - HttpRequest request = HttpRequest.newBuilder() - .uri(URI.create("http://localhost:" + port + "/clickup-api-mock/health")).GET().build(); - - final HttpResponse response = client.send(request, HttpResponse.BodyHandlers.ofString()); - return response.statusCode() == 200; - }); - } - - private void setupContextRoutes() throws Exception { + private void addWebhookRoute() throws Exception { context().addRoutes(new RouteBuilder() { @Override public void configure() { String apiMockBaseUrl = "http://localhost:" + port + "/clickup-api-mock"; - from("webhook:clickup:" + WORKSPACE_ID + "?authorizationToken=" + AUTHORIZATION_TOKEN + "&webhookSecret=" - + WEBHOOK_SECRET + "&events=" + String.join(",", EVENTS) + "&webhookAutoRegister=true&baseUrl=" - + apiMockBaseUrl) + fromF("webhook:clickup:%s?authorizationToken=%s&webhookSecret=%s&events=%s&webhookAutoRegister=true&baseUrl=%s", + WORKSPACE_ID, AUTHORIZATION_TOKEN, WEBHOOK_SECRET, String.join(",", EVENTS), apiMockBaseUrl) .id("webhook") .to("mock:endpoint"); } diff --git a/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/util/ClickUpTestSupport.java b/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/util/ClickUpTestSupport.java index cb92941f08fde..ef4117c9f763c 100644 --- a/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/util/ClickUpTestSupport.java +++ b/components/camel-clickup/src/test/java/org/apache/camel/component/clickup/util/ClickUpTestSupport.java @@ -18,12 +18,18 @@ import java.io.IOException; import java.io.InputStream; +import java.net.URI; +import java.net.http.HttpClient; +import java.net.http.HttpRequest; +import java.net.http.HttpResponse; +import java.util.concurrent.TimeUnit; import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.camel.CamelContext; import org.apache.camel.component.clickup.ClickUpComponent; import org.apache.camel.test.AvailablePortFinder; import org.apache.camel.test.junit6.CamelTestSupport; +import org.awaitility.Awaitility; import org.junit.jupiter.api.extension.RegisterExtension; /** @@ -31,6 +37,10 @@ */ public class ClickUpTestSupport extends CamelTestSupport { + protected static final Long WORKSPACE_ID = 12345L; + protected static final String AUTHORIZATION_TOKEN = "mock-authorization-token"; + protected static final String WEBHOOK_SECRET = "mock-webhook-secret"; + @RegisterExtension protected static AvailablePortFinder.Port port = AvailablePortFinder.find(); @@ -47,13 +57,27 @@ public class ClickUpTestSupport extends CamelTestSupport { public static T getJSONResource(String fileName, Class clazz) { ObjectMapper mapper = new ObjectMapper(); try (InputStream stream = ClickUpTestSupport.class.getClassLoader().getResourceAsStream(fileName)) { - T value = mapper.readValue(stream, clazz); - return value; + return mapper.readValue(stream, clazz); } catch (IOException e) { throw new IllegalArgumentException("Unable to load file " + fileName, e); } } + /** + * Waits until the ClickUp mock API health endpoint responds with HTTP 200. + */ + protected void waitForClickUpMockAPI() { + Awaitility.await() + .atMost(5, TimeUnit.SECONDS) + .until(() -> { + HttpClient client = HttpClient.newBuilder().build(); + HttpRequest request = HttpRequest.newBuilder() + .uri(URI.create("http://localhost:" + port + "/clickup-api-mock/health")).GET().build(); + HttpResponse response = client.send(request, HttpResponse.BodyHandlers.ofString()); + return response.statusCode() == 200; + }); + } + @Override protected CamelContext createCamelContext() throws Exception { final CamelContext context = super.createCamelContext();