You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ji...@apache.org on 2024/01/25 10:14:03 UTC
(camel-quarkus) 14/17: Variables - global vs local setVariable test (#5654)
This is an automated email from the ASF dual-hosted git repository.
jiriondrusek pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 7cff5ca193f9c925a043c6f02488f51a19cea392
Author: JiriOndrusek <on...@gmail.com>
AuthorDate: Mon Jan 22 10:24:02 2024 +0100
Variables - global vs local setVariable test (#5654)
---
integration-test-groups/foundation/pom.xml | 1 +
.../foundation/variables/pom.xml | 149 +++++++++++++++++
.../quarkus/variables/it/VariablesProducers.java | 71 ++++++++
.../quarkus/variables/it/VariablesResource.java | 186 +++++++++++++++++++++
.../quarkus/variables/it/VariablesRoutes.java | 71 ++++++++
.../it/CustomRepositoryVariablesTest.java | 59 +++++++
.../camel/quarkus/variables/it/VariablesIT.java | 24 +++
.../camel/quarkus/variables/it/VariablesTest.java | 97 +++++++++++
8 files changed, 658 insertions(+)
diff --git a/integration-test-groups/foundation/pom.xml b/integration-test-groups/foundation/pom.xml
index efd89872c1..f0849165a9 100644
--- a/integration-test-groups/foundation/pom.xml
+++ b/integration-test-groups/foundation/pom.xml
@@ -57,6 +57,7 @@
<module>timer</module>
<module>transformer</module>
<module>type-converter</module>
+ <module>variables</module>
</modules>
</project>
diff --git a/integration-test-groups/foundation/variables/pom.xml b/integration-test-groups/foundation/variables/pom.xml
new file mode 100644
index 0000000000..f466f4944c
--- /dev/null
+++ b/integration-test-groups/foundation/variables/pom.xml
@@ -0,0 +1,149 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-build-parent-it</artifactId>
+ <version>3.7.0-SNAPSHOT</version>
+ <relativePath>../../../poms/build-parent-it/pom.xml</relativePath>
+ </parent>
+
+ <artifactId>camel-quarkus-integration-test-variables</artifactId>
+ <name>Camel Quarkus :: Integration Tests :: Variables</name>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-bean</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-mock</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-direct</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>io.quarkus</groupId>
+ <artifactId>quarkus-resteasy</artifactId>
+ </dependency>
+
+
+ <!-- test dependencies -->
+ <dependency>
+ <groupId>io.quarkus</groupId>
+ <artifactId>quarkus-junit5</artifactId>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>io.rest-assured</groupId>
+ <artifactId>rest-assured</artifactId>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-integration-wiremock-support</artifactId>
+ <scope>test</scope>
+ </dependency>
+ </dependencies>
+
+ <profiles>
+ <profile>
+ <id>native</id>
+ <activation>
+ <property>
+ <name>native</name>
+ </property>
+ </activation>
+ <properties>
+ <quarkus.package.type>native</quarkus.package.type>
+ </properties>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-failsafe-plugin</artifactId>
+ <executions>
+ <execution>
+ <goals>
+ <goal>integration-test</goal>
+ <goal>verify</goal>
+ </goals>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ <profile>
+ <id>virtualDependencies</id>
+ <activation>
+ <property>
+ <name>!noVirtualDependencies</name>
+ </property>
+ </activation>
+ <dependencies>
+ <!-- The following dependencies guarantee that this module is built after them. You can update them by running `mvn process-resources -Pformat -N` from the source tree root directory -->
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-bean-deployment</artifactId>
+ <version>${project.version}</version>
+ <type>pom</type>
+ <scope>test</scope>
+ <exclusions>
+ <exclusion>
+ <groupId>*</groupId>
+ <artifactId>*</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-direct-deployment</artifactId>
+ <version>${project.version}</version>
+ <type>pom</type>
+ <scope>test</scope>
+ <exclusions>
+ <exclusion>
+ <groupId>*</groupId>
+ <artifactId>*</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-mock-deployment</artifactId>
+ <version>${project.version}</version>
+ <type>pom</type>
+ <scope>test</scope>
+ <exclusions>
+ <exclusion>
+ <groupId>*</groupId>
+ <artifactId>*</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ </dependencies>
+ </profile>
+ </profiles>
+
+</project>
diff --git a/integration-test-groups/foundation/variables/src/main/java/org/apache/camel/quarkus/variables/it/VariablesProducers.java b/integration-test-groups/foundation/variables/src/main/java/org/apache/camel/quarkus/variables/it/VariablesProducers.java
new file mode 100644
index 0000000000..c51d6607a2
--- /dev/null
+++ b/integration-test-groups/foundation/variables/src/main/java/org/apache/camel/quarkus/variables/it/VariablesProducers.java
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.quarkus.variables.it;
+
+import io.quarkus.runtime.annotations.RegisterForReflection;
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.enterprise.inject.Alternative;
+import jakarta.inject.Named;
+import org.apache.camel.Variable;
+import org.apache.camel.spi.VariableRepository;
+import org.apache.camel.support.service.ServiceSupport;
+
+public class VariablesProducers {
+
+ //repository is created as alternative to be disabled by default
+ //QuarkusTestProfile is used to enable the bean for the appropriate tests.
+ @Named("global-variable-repository")
+ @Alternative
+ @ApplicationScoped
+ public static class MyGlobalRepo extends ServiceSupport implements VariableRepository {
+
+ private Object value;
+
+ @Override
+ public String getId() {
+ return "myGlobal";
+ }
+
+ @Override
+ public Object getVariable(String name) {
+ if (value != null) {
+ return "!" + value + "!";
+ }
+ return null;
+ }
+
+ @Override
+ public void setVariable(String name, Object value) {
+ this.value = value;
+ }
+
+ @Override
+ public Object removeVariable(String name) {
+ return null;
+ }
+ }
+
+ @Named("my-bean")
+ @ApplicationScoped
+ @RegisterForReflection(methods = true)
+ public static class MyBean {
+ public boolean matches(@Variable("location") String location) {
+ return "Medford".equals(location);
+ }
+ }
+
+}
diff --git a/integration-test-groups/foundation/variables/src/main/java/org/apache/camel/quarkus/variables/it/VariablesResource.java b/integration-test-groups/foundation/variables/src/main/java/org/apache/camel/quarkus/variables/it/VariablesResource.java
new file mode 100644
index 0000000000..57205f37ac
--- /dev/null
+++ b/integration-test-groups/foundation/variables/src/main/java/org/apache/camel/quarkus/variables/it/VariablesResource.java
@@ -0,0 +1,186 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.quarkus.variables.it;
+
+import java.util.List;
+
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.inject.Inject;
+import jakarta.ws.rs.POST;
+import jakarta.ws.rs.Path;
+import jakarta.ws.rs.PathParam;
+import jakarta.ws.rs.core.Response;
+import org.apache.camel.CamelContext;
+import org.apache.camel.Exchange;
+import org.apache.camel.ProducerTemplate;
+import org.apache.camel.component.mock.MockEndpoint;
+
+@Path("/variables")
+@ApplicationScoped
+public class VariablesResource {
+
+ @Inject
+ ProducerTemplate producerTemplate;
+
+ @Inject
+ CamelContext context;
+
+ @Path("/setLocalVariable")
+ @POST
+ public String setLocalVariable(String body) throws Exception {
+ MockEndpoint end = context.getEndpoint("mock:setLocalVariableEnd", MockEndpoint.class);
+ end.expectedMessageCount(1);
+ end.expectedVariableReceived(VariablesRoutes.VARIABLE_NAME, VariablesRoutes.VARIABLE_VALUE);
+
+ producerTemplate.requestBody("direct:setLocalVariableStart", body, String.class);
+
+ // make sure we got the message
+ end.assertIsSatisfied();
+
+ // lets get the variable value
+ List<Exchange> exchanges = end.getExchanges();
+ Exchange exchange = exchanges.get(0);
+
+ return exchange.getVariable(VariablesRoutes.VARIABLE_NAME, String.class);
+ }
+
+ @Path("/setGlobalVariable")
+ @POST
+ public Response setGlobalVariable(String body) throws Exception {
+ if (context.getVariable(VariablesRoutes.VARIABLE_NAME) != null) {
+ return Response.status(500).entity(String.format("Variable '%s' has to be null before sending message to the rout.",
+ VariablesRoutes.VARIABLE_VALUE)).build();
+ }
+
+ MockEndpoint end = context.getEndpoint("mock:setGlobalVariableEnd", MockEndpoint.class);
+ end.expectedMessageCount(1);
+
+ producerTemplate.requestBody("direct:setGlobalVariableStart", body, String.class);
+
+ // make sure we got the message
+ end.assertIsSatisfied();
+
+ // lets get the variable value
+ List<Exchange> exchanges = end.getExchanges();
+ Exchange exchange = exchanges.get(0);
+
+ String resp = exchange.getVariable(VariablesRoutes.VARIABLE_NAME, String.class) + ","
+ + context.getVariable(VariablesRoutes.VARIABLE_NAME, String.class);
+ return Response.ok().entity(resp).build();
+ }
+
+ @Path("/removeLocalVariable")
+ @POST
+ public String removeLocalVariable(String body) throws Exception {
+ MockEndpoint end = context.getEndpoint("mock:removeLocalVariableEnd", MockEndpoint.class);
+ end.expectedMessageCount(1);
+
+ MockEndpoint mid = context.getEndpoint("mock:removeLocalVariableMid", MockEndpoint.class);
+ mid.expectedMessageCount(1);
+
+ producerTemplate.requestBody("direct:removeLocalVariableStart", body, String.class);
+
+ // make sure we got the message
+ end.assertIsSatisfied();
+ mid.assertIsSatisfied();
+
+ // lets get the variable value
+ List<Exchange> exchanges = end.getExchanges();
+ Exchange endExchange = exchanges.get(0);
+ exchanges = mid.getExchanges();
+ Exchange midExchange = exchanges.get(0);
+
+ return midExchange.getVariable(VariablesRoutes.VARIABLE_NAME, String.class) + ","
+ + endExchange.getVariable(VariablesRoutes.VARIABLE_NAME, String.class);
+ }
+
+ @Path("/removeGlobalVariable")
+ @POST
+ public String removeGlobalVariable(String body) throws Exception {
+ MockEndpoint mid = context.getEndpoint("mock:removeGlobalVariableMid", MockEndpoint.class);
+ mid.expectedMessageCount(1);
+
+ producerTemplate.requestBody("direct:removeGlobalVariableStart", body, String.class);
+
+ // make sure we got the message
+ mid.assertIsSatisfied();
+
+ // lets get the variable value
+ List<Exchange> exchanges = mid.getExchanges();
+ Exchange midExchange = exchanges.get(0);
+
+ return midExchange.getVariable(VariablesRoutes.VARIABLE_NAME, String.class) + ","
+ + context.getVariable(VariablesRoutes.VARIABLE_NAME, String.class);
+ }
+
+ @Path("/customGlobalRepository")
+ @POST
+ public Response customGlobalRepository(String body) throws Exception {
+ context.getRouteController().startRoute("customGlobalRepository");
+
+ MockEndpoint end = context.getEndpoint("mock:setGlobalCustomEnd", MockEndpoint.class);
+ end.expectedMessageCount(1);
+
+ producerTemplate.requestBody("direct:setGlobalCustomStart", body, String.class);
+
+ // make sure we got the message
+ end.assertIsSatisfied();
+
+ // lets get the variable value
+ List<Exchange> exchanges = end.getExchanges();
+ Exchange exchange = exchanges.get(0);
+
+ String resp = exchange.getVariable(VariablesRoutes.VARIABLE_NAME, String.class) + ","
+ + context.getVariable(VariablesRoutes.VARIABLE_NAME, String.class);
+ return Response.ok().entity(resp).build();
+ }
+
+ @Path("/convert")
+ @POST
+ public String convert(String body) throws Exception {
+ MockEndpoint end = context.getEndpoint("mock:convertEnd", MockEndpoint.class);
+ end.expectedMessageCount(1);
+
+ producerTemplate.requestBody("direct:convertStart", body, String.class);
+
+ // make sure we got the message
+ end.assertIsSatisfied();
+
+ List<Exchange> exchanges = end.getExchanges();
+ Exchange exchange = exchanges.get(0);
+
+ return exchange.getVariable(VariablesRoutes.VARIABLE_NAME, String.class);
+ }
+
+ @Path("/filter/{city}")
+ @POST
+ public Response filter(String body, @PathParam("city") String city) throws Exception {
+ MockEndpoint end = context.getEndpoint("mock:filterEnd", MockEndpoint.class);
+ end.expectedMessageCount(1);
+
+ producerTemplate.requestBodyAndHeader("direct:filterStart", body, "city", city, String.class);
+
+ try {
+ Exchange exhange = end.assertExchangeReceived(0);
+ return Response.ok().entity(exhange.getIn().getBody(String.class)).build();
+ } catch (AssertionError e) {
+ return Response.status(204).build();
+ }
+
+ }
+
+}
diff --git a/integration-test-groups/foundation/variables/src/main/java/org/apache/camel/quarkus/variables/it/VariablesRoutes.java b/integration-test-groups/foundation/variables/src/main/java/org/apache/camel/quarkus/variables/it/VariablesRoutes.java
new file mode 100644
index 0000000000..7bbc716434
--- /dev/null
+++ b/integration-test-groups/foundation/variables/src/main/java/org/apache/camel/quarkus/variables/it/VariablesRoutes.java
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.quarkus.variables.it;
+
+import org.apache.camel.builder.RouteBuilder;
+
+public class VariablesRoutes extends RouteBuilder {
+
+ public static String VARIABLE_NAME = "foo";
+ public static String VARIABLE_VALUE = "bar";
+
+ @Override
+ public void configure() throws Exception {
+ transformer().withDefaults();
+
+ from("direct:setLocalVariableStart")
+ .setVariable(VARIABLE_NAME)
+ .constant(VARIABLE_VALUE)
+ .to("mock:setLocalVariableEnd");
+
+ from("direct:setGlobalVariableStart")
+ .setVariable("global:" + VARIABLE_NAME)
+ .constant(VARIABLE_VALUE)
+ .to("mock:setGlobalVariableEnd");
+
+ from("direct:removeLocalVariableStart")
+ .setVariable(VARIABLE_NAME)
+ .constant(VARIABLE_VALUE)
+ .to("mock:removeLocalVariableMid")
+ .removeVariable(VARIABLE_NAME)
+ .to("mock:removeLocalVariableEnd");
+
+ from("direct:removeGlobalVariableStart")
+ .setVariable("global:" + VARIABLE_NAME)
+ .constant(VARIABLE_VALUE)
+ .to("mock:removeGlobalVariableMid")
+ .removeVariable("global:" + VARIABLE_NAME);
+
+ from("direct:setGlobalCustomStart")
+ .id("customGlobalRepository")
+ .autoStartup(false)
+ .setVariable("global:" + VARIABLE_NAME)
+ .constant(VARIABLE_VALUE)
+ .to("mock:setGlobalCustomEnd");
+
+ from("direct:convertStart")
+ .setVariable(VARIABLE_NAME)
+ .constant(11)
+ .convertVariableTo(VARIABLE_NAME, Double.class)
+ .to("mock:convertEnd");
+
+ from("direct:filterStart")
+ .setVariable("location", header("city"))
+ .filter().method("my-bean", "matches")
+ .to("mock:filterEnd");
+ }
+}
diff --git a/integration-test-groups/foundation/variables/src/test/java/org/apache/camel/quarkus/variables/it/CustomRepositoryVariablesTest.java b/integration-test-groups/foundation/variables/src/test/java/org/apache/camel/quarkus/variables/it/CustomRepositoryVariablesTest.java
new file mode 100644
index 0000000000..f15cab374f
--- /dev/null
+++ b/integration-test-groups/foundation/variables/src/test/java/org/apache/camel/quarkus/variables/it/CustomRepositoryVariablesTest.java
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.quarkus.variables.it;
+
+import java.util.Collections;
+import java.util.Set;
+
+import io.quarkus.test.junit.QuarkusTest;
+import io.quarkus.test.junit.QuarkusTestProfile;
+import io.quarkus.test.junit.TestProfile;
+import io.restassured.RestAssured;
+import io.restassured.http.ContentType;
+import org.hamcrest.Matchers;
+import org.junit.jupiter.api.Test;
+
+/**
+ * Test is executed in JVM mode only because the profile enabling customVariableRepository can not be enabled for
+ * this class in the native (and stay disabled for the other test class).
+ * I think that it is not necessary to create a module for this test only, because it uses code tested by other tests
+ * and
+ * there is no reason to believe, that it fails in native.
+ */
+@QuarkusTest
+@TestProfile(CustomRepositoryVariablesTest.Profile.class)
+class CustomRepositoryVariablesTest {
+
+ @Test
+ public void testCustomGlobalRepository() {
+ RestAssured.given()
+ .contentType(ContentType.TEXT)
+ .post("/variables/customGlobalRepository")
+ .then()
+ .statusCode(200)
+ .body(Matchers.is("null,!" + VariablesRoutes.VARIABLE_VALUE + "!"));
+ }
+
+ public static class Profile implements QuarkusTestProfile {
+
+ @Override
+ public Set<Class<?>> getEnabledAlternatives() {
+ return Collections.singleton(VariablesProducers.MyGlobalRepo.class);
+ }
+ }
+
+}
diff --git a/integration-test-groups/foundation/variables/src/test/java/org/apache/camel/quarkus/variables/it/VariablesIT.java b/integration-test-groups/foundation/variables/src/test/java/org/apache/camel/quarkus/variables/it/VariablesIT.java
new file mode 100644
index 0000000000..ee312a2109
--- /dev/null
+++ b/integration-test-groups/foundation/variables/src/test/java/org/apache/camel/quarkus/variables/it/VariablesIT.java
@@ -0,0 +1,24 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.quarkus.variables.it;
+
+import io.quarkus.test.junit.QuarkusIntegrationTest;
+
+@QuarkusIntegrationTest
+class VariablesIT extends VariablesTest {
+
+}
diff --git a/integration-test-groups/foundation/variables/src/test/java/org/apache/camel/quarkus/variables/it/VariablesTest.java b/integration-test-groups/foundation/variables/src/test/java/org/apache/camel/quarkus/variables/it/VariablesTest.java
new file mode 100644
index 0000000000..10ad5c7b91
--- /dev/null
+++ b/integration-test-groups/foundation/variables/src/test/java/org/apache/camel/quarkus/variables/it/VariablesTest.java
@@ -0,0 +1,97 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.quarkus.variables.it;
+
+import io.quarkus.test.junit.QuarkusTest;
+import io.restassured.RestAssured;
+import io.restassured.http.ContentType;
+import org.hamcrest.Matchers;
+import org.junit.jupiter.api.Test;
+
+@QuarkusTest
+class VariablesTest {
+
+ @Test
+ public void testSetLocalVariable() {
+ RestAssured.given()
+ .contentType(ContentType.TEXT)
+ .post("/variables/setLocalVariable")
+ .then()
+ .statusCode(200)
+ .body(Matchers.is(VariablesRoutes.VARIABLE_VALUE));
+ }
+
+ @Test
+ public void testSetGlobalVariable() {
+ RestAssured.given()
+ .contentType(ContentType.TEXT)
+ .post("/variables/setGlobalVariable")
+ .then()
+ .statusCode(200)
+ .body(Matchers.is("null," + VariablesRoutes.VARIABLE_VALUE));
+ }
+
+ @Test
+ public void testRemoveLocalVariable() {
+ RestAssured.given()
+ .contentType(ContentType.TEXT)
+ .post("/variables/removeLocalVariable")
+ .then()
+ .statusCode(200)
+ .body(Matchers.is(VariablesRoutes.VARIABLE_VALUE + ",null"));
+ }
+
+ @Test
+ public void testRemoveGlobalVariable() {
+ RestAssured.given()
+ .contentType(ContentType.TEXT)
+ .post("/variables/removeGlobalVariable")
+ .then()
+ .statusCode(200)
+ .body(Matchers.is("null,null"));
+ }
+
+ @Test
+ public void testConvert() {
+ RestAssured.given()
+ .contentType(ContentType.TEXT)
+ .body("aaaa")
+ .post("/variables/convert")
+ .then()
+ .statusCode(200)
+ .body(Matchers.is("11.0"));
+ }
+
+ @Test
+ public void testFilter() {
+ //first call fails, because city Gotham is filtered Out
+ RestAssured.given()
+ .contentType(ContentType.TEXT)
+ .body("Sheldon")
+ .post("/variables/filter/Gotham")
+ .then()
+ .statusCode(204);
+
+ RestAssured.given()
+ .contentType(ContentType.TEXT)
+ .body("Sheldon")
+ .post("/variables/filter/Medford")
+ .then()
+ .statusCode(200)
+ .body(Matchers.is("Sheldon"));
+ }
+}