This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 2e5f4b5 CAMEL-16400: split unit and integration tests for
camel-zookeeper (#5374)
2e5f4b5 is described below
commit 2e5f4b58e5e03a23dc7fe0e5ac9837eecf7926ca
Author: Otavio Rodolfo Piske <[email protected]>
AuthorDate: Thu Apr 15 11:43:39 2021 +0200
CAMEL-16400: split unit and integration tests for camel-zookeeper (#5374)
---
components/camel-zookeeper/pom.xml | 104 ++++++---------------
.../SpringZooKeeperServiceCallRouteIT.java} | 5 +-
.../ZooKeeperServiceCallRouteIT.java} | 5 +-
.../ZooKeeperServiceDiscoveryIT.java} | 5 +-
.../ZooKeeperServiceRegistrationITBase.java} | 5 +-
...eRegistrationWithRoutePolicyAndMetadataIT.java} | 4 +-
...rviceRegistrationWithRoutePolicyFactoryIT.java} | 4 +-
...eeperServiceRegistrationWithRoutePolicyIT.java} | 4 +-
...ServiceRegistrationWithServiceComponentIT.java} | 4 +-
.../ZooKeeperClusteredRoutePolicyFactoryIT.java} | 7 +-
.../ZooKeeperClusteredRoutePolicyIT.java} | 7 +-
.../ZooKeeperMasterIT.java} | 7 +-
.../ConsumeChildrenIT.java} | 6 +-
.../ConsumeDataIT.java} | 5 +-
.../ZooKeeperITSupport.java} | 5 +-
.../ZooKeeperManagedEndpointIT.java} | 5 +-
.../ZooKeeperProducerIT.java} | 5 +-
.../ZookeeperConnectionManagerIT.java} | 8 +-
.../AnyOfOperationIT.java} | 9 +-
.../ChildrenChangedOperationIT.java} | 7 +-
.../CreateOperationIT.java} | 8 +-
.../DataChangedOperationIT.java} | 7 +-
.../ExistenceChangedOperationIT.java} | 7 +-
.../ExistenceOperationIT.java} | 7 +-
.../SetDataOperationIT.java} | 8 +-
25 files changed, 114 insertions(+), 134 deletions(-)
diff --git a/components/camel-zookeeper/pom.xml
b/components/camel-zookeeper/pom.xml
index bf00b43..2fa050f 100644
--- a/components/camel-zookeeper/pom.xml
+++ b/components/camel-zookeeper/pom.xml
@@ -198,81 +198,33 @@
</dependencies>
-
- <profiles>
- <profile>
- <id>zookeeper-skip-tests</id>
- <activation>
- <activeByDefault>true</activeByDefault>
- </activation>
- <build>
- <plugins>
- <plugin>
- <artifactId>maven-surefire-plugin</artifactId>
- <configuration>
- <skipTests>true</skipTests>
- </configuration>
- </plugin>
- </plugins>
- </build>
- </profile>
-
- <!-- activate test if the docker socket file is accessible -->
- <profile>
- <id>zookeeper-tests-docker-file</id>
- <activation>
- <file>
- <exists>/var/run/docker.sock</exists>
- </file>
- </activation>
- <build>
- <plugins>
- <plugin>
- <artifactId>maven-surefire-plugin</artifactId>
- <configuration>
- <skipTests>${skipTests}</skipTests>
- <systemPropertyVariables>
-
<visibleassertions.silence>true</visibleassertions.silence>
- </systemPropertyVariables>
- <childDelegation>false</childDelegation>
- <useFile>true</useFile>
- <forkCount>1</forkCount>
- <reuseForks>true</reuseForks>
-
<forkedProcessTimeoutInSeconds>600</forkedProcessTimeoutInSeconds>
- </configuration>
- </plugin>
- </plugins>
- </build>
- </profile>
-
- <!-- activate test if the DOCKER_HOST env var is set -->
- <profile>
- <id>zookeeper-tests-docker-env</id>
- <activation>
- <property>
- <name>env.DOCKER_HOST</name>
- </property>
- </activation>
- <build>
- <plugins>
- <plugin>
- <artifactId>maven-surefire-plugin</artifactId>
- <configuration>
- <skipTests>${skipTests}</skipTests>
- <systemPropertyVariables>
-
<visibleassertions.silence>true</visibleassertions.silence>
- </systemPropertyVariables>
- <childDelegation>false</childDelegation>
- <useFile>true</useFile>
- <forkCount>1</forkCount>
- <reuseForks>true</reuseForks>
-
<forkedProcessTimeoutInSeconds>600</forkedProcessTimeoutInSeconds>
- </configuration>
- </plugin>
- </plugins>
- </build>
- </profile>
-
- </profiles>
+ <build>
+ <plugins>
+ <plugin>
+ <artifactId>maven-surefire-plugin</artifactId>
+ <configuration>
+ <skipTests>${skipTests}</skipTests>
+ <systemPropertyVariables>
+
<visibleassertions.silence>true</visibleassertions.silence>
+ </systemPropertyVariables>
+ <childDelegation>false</childDelegation>
+ <useFile>true</useFile>
+ <forkCount>1</forkCount>
+ <reuseForks>true</reuseForks>
+
<forkedProcessTimeoutInSeconds>600</forkedProcessTimeoutInSeconds>
+ </configuration>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-failsafe-plugin</artifactId>
+ <configuration>
+ <skipTests>${skipTests}</skipTests>
+ <systemPropertyVariables>
+
<visibleassertions.silence>true</visibleassertions.silence>
+ </systemPropertyVariables>
+ </configuration>
+ </plugin>
+ </plugins>
+ </build>
</project>
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/SpringZooKeeperServiceCallRouteTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/SpringZooKeeperServiceCallRouteIT.java
similarity index 96%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/SpringZooKeeperServiceCallRouteTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/SpringZooKeeperServiceCallRouteIT.java
index e6fb4aa..d985315 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/SpringZooKeeperServiceCallRouteTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/SpringZooKeeperServiceCallRouteIT.java
@@ -14,9 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.cloud;
+package org.apache.camel.component.zookeeper.cloud.integration;
import org.apache.camel.CamelContext;
+import org.apache.camel.component.zookeeper.cloud.ZooKeeperServiceDiscovery;
import org.apache.camel.spi.PropertiesComponent;
import org.apache.camel.test.AvailablePortFinderPropertiesFunction;
import org.apache.camel.test.infra.zookeeper.services.ZooKeeperService;
@@ -35,7 +36,7 @@ import org.junit.jupiter.api.extension.RegisterExtension;
import org.springframework.context.support.AbstractApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
-public class SpringZooKeeperServiceCallRouteTest extends
CamelSpringTestSupport {
+public class SpringZooKeeperServiceCallRouteIT extends CamelSpringTestSupport {
@RegisterExtension
static ZooKeeperService service = ZooKeeperServiceFactory.createService();
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceCallRouteTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceCallRouteIT.java
similarity index 96%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceCallRouteTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceCallRouteIT.java
index 83b1eae..d567932 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceCallRouteTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceCallRouteIT.java
@@ -14,13 +14,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.cloud;
+package org.apache.camel.component.zookeeper.cloud.integration;
import java.util.ArrayList;
import java.util.List;
import org.apache.camel.RoutesBuilder;
import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.zookeeper.cloud.ZooKeeperServiceDiscovery;
import org.apache.camel.test.AvailablePortFinder;
import org.apache.camel.test.infra.zookeeper.services.ZooKeeperService;
import org.apache.camel.test.infra.zookeeper.services.ZooKeeperServiceFactory;
@@ -36,7 +37,7 @@ import
org.apache.curator.x.discovery.details.JsonInstanceSerializer;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.RegisterExtension;
-public class ZooKeeperServiceCallRouteTest extends CamelTestSupport {
+public class ZooKeeperServiceCallRouteIT extends CamelTestSupport {
@RegisterExtension
static ZooKeeperService service = ZooKeeperServiceFactory.createService();
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceDiscoveryTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceDiscoveryIT.java
similarity index 96%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceDiscoveryTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceDiscoveryIT.java
index 93a72b8..8d2d66c 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceDiscoveryTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceDiscoveryIT.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.cloud;
+package org.apache.camel.component.zookeeper.cloud.integration;
import java.util.ArrayList;
import java.util.List;
@@ -22,6 +22,7 @@ import java.util.List;
import org.apache.camel.cloud.ServiceDefinition;
import org.apache.camel.component.zookeeper.ZooKeeperCuratorConfiguration;
import org.apache.camel.component.zookeeper.ZooKeeperCuratorHelper;
+import org.apache.camel.component.zookeeper.cloud.ZooKeeperServiceDiscovery;
import org.apache.camel.test.AvailablePortFinder;
import org.apache.camel.test.infra.zookeeper.services.ZooKeeperService;
import org.apache.camel.test.infra.zookeeper.services.ZooKeeperServiceFactory;
@@ -36,7 +37,7 @@ import org.junit.jupiter.api.extension.RegisterExtension;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
-public class ZooKeeperServiceDiscoveryTest {
+public class ZooKeeperServiceDiscoveryIT {
@RegisterExtension
static ZooKeeperService service = ZooKeeperServiceFactory.createService();
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationTestBase.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationITBase.java
similarity index 96%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationTestBase.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationITBase.java
index a8eb54b..e803bea 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationTestBase.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationITBase.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.cloud;
+package org.apache.camel.component.zookeeper.cloud.integration;
import java.util.Collection;
import java.util.Collections;
@@ -23,6 +23,7 @@ import java.util.UUID;
import org.apache.camel.CamelContext;
import org.apache.camel.cloud.ServiceDefinition;
+import org.apache.camel.component.zookeeper.cloud.ZooKeeperServiceRegistry;
import org.apache.camel.test.AvailablePortFinder;
import org.apache.camel.test.infra.zookeeper.services.ZooKeeperContainer;
import org.apache.camel.test.junit5.CamelTestSupport;
@@ -40,7 +41,7 @@ import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
-public abstract class ZooKeeperServiceRegistrationTestBase extends
CamelTestSupport {
+public abstract class ZooKeeperServiceRegistrationITBase extends
CamelTestSupport {
protected static final String SERVICE_ID = UUID.randomUUID().toString();
protected static final String SERVICE_NAME = "my-service";
protected static final String SERVICE_HOST = "localhost";
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithRoutePolicyAndMetadataTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyAndMetadataIT.java
similarity index 93%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithRoutePolicyAndMetadataTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyAndMetadataIT.java
index 7aede01..a6a953a 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithRoutePolicyAndMetadataTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyAndMetadataIT.java
@@ -14,14 +14,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.cloud;
+package org.apache.camel.component.zookeeper.cloud.integration;
import org.apache.camel.RoutesBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.cloud.ServiceDefinition;
import org.apache.camel.impl.cloud.ServiceRegistrationRoutePolicy;
-public class ZooKeeperServiceRegistrationWithRoutePolicyAndMetadataTest
extends ZooKeeperServiceRegistrationTestBase {
+public class ZooKeeperServiceRegistrationWithRoutePolicyAndMetadataIT extends
ZooKeeperServiceRegistrationITBase {
@Override
protected RoutesBuilder createRouteBuilder() throws Exception {
return new RouteBuilder() {
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithRoutePolicyFactoryTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyFactoryIT.java
similarity index 90%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithRoutePolicyFactoryTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyFactoryIT.java
index b73c95c..205a522 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithRoutePolicyFactoryTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyFactoryIT.java
@@ -14,14 +14,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.cloud;
+package org.apache.camel.component.zookeeper.cloud.integration;
import org.apache.camel.CamelContext;
import org.apache.camel.RoutesBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.cloud.ServiceRegistrationRoutePolicyFactory;
-public class ZooKeeperServiceRegistrationWithRoutePolicyFactoryTest extends
ZooKeeperServiceRegistrationTestBase {
+public class ZooKeeperServiceRegistrationWithRoutePolicyFactoryIT extends
ZooKeeperServiceRegistrationITBase {
@Override
protected CamelContext createCamelContext() throws Exception {
CamelContext context = super.createCamelContext();
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithRoutePolicyTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyIT.java
similarity index 90%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithRoutePolicyTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyIT.java
index 367f31e..20d7e53 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithRoutePolicyTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyIT.java
@@ -14,13 +14,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.cloud;
+package org.apache.camel.component.zookeeper.cloud.integration;
import org.apache.camel.RoutesBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.cloud.ServiceRegistrationRoutePolicy;
-public class ZooKeeperServiceRegistrationWithRoutePolicyTest extends
ZooKeeperServiceRegistrationTestBase {
+public class ZooKeeperServiceRegistrationWithRoutePolicyIT extends
ZooKeeperServiceRegistrationITBase {
@Override
protected RoutesBuilder createRouteBuilder() throws Exception {
return new RouteBuilder() {
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithServiceComponentTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithServiceComponentIT.java
similarity index 91%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithServiceComponentTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithServiceComponentIT.java
index f009d53..6addd57 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithServiceComponentTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithServiceComponentIT.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.cloud;
+package org.apache.camel.component.zookeeper.cloud.integration;
import java.util.Collections;
import java.util.Map;
@@ -24,7 +24,7 @@ import org.apache.camel.RoutesBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.service.ServiceComponent;
-public class ZooKeeperServiceRegistrationWithServiceComponentTest extends
ZooKeeperServiceRegistrationTestBase {
+public class ZooKeeperServiceRegistrationWithServiceComponentIT extends
ZooKeeperServiceRegistrationITBase {
@BindToRegistry("service")
private ServiceComponent service = new ServiceComponent();
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperClusteredRoutePolicyFactoryTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyFactoryIT.java
similarity index 94%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperClusteredRoutePolicyFactoryTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyFactoryIT.java
index 04d9d5f..2d41080 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperClusteredRoutePolicyFactoryTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyFactoryIT.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.cluster;
+package org.apache.camel.component.zookeeper.cluster.integration;
import java.util.ArrayList;
import java.util.List;
@@ -27,6 +27,7 @@ import java.util.stream.Collectors;
import java.util.stream.IntStream;
import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.zookeeper.cluster.ZooKeeperClusterService;
import org.apache.camel.impl.DefaultCamelContext;
import org.apache.camel.impl.cluster.ClusteredRoutePolicyFactory;
import org.apache.camel.test.infra.zookeeper.services.ZooKeeperService;
@@ -39,11 +40,11 @@ import org.slf4j.LoggerFactory;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
-public final class ZooKeeperClusteredRoutePolicyFactoryTest {
+public final class ZooKeeperClusteredRoutePolicyFactoryIT {
@RegisterExtension
static ZooKeeperService service = ZooKeeperServiceFactory.createService();
- private static final Logger LOGGER =
LoggerFactory.getLogger(ZooKeeperClusteredRoutePolicyFactoryTest.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(ZooKeeperClusteredRoutePolicyFactoryIT.class);
private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).collect(Collectors.toList());
private static final List<String> RESULTS = new ArrayList<>();
private static final ScheduledExecutorService SCHEDULER =
Executors.newScheduledThreadPool(CLIENTS.size() * 2);
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperClusteredRoutePolicyTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyIT.java
similarity index 94%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperClusteredRoutePolicyTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyIT.java
index 166ce8e..9600dad 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperClusteredRoutePolicyTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyIT.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.cluster;
+package org.apache.camel.component.zookeeper.cluster.integration;
import java.util.ArrayList;
import java.util.List;
@@ -27,6 +27,7 @@ import java.util.stream.Collectors;
import java.util.stream.IntStream;
import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.zookeeper.cluster.ZooKeeperClusterService;
import org.apache.camel.impl.DefaultCamelContext;
import org.apache.camel.impl.cluster.ClusteredRoutePolicy;
import org.apache.camel.test.infra.zookeeper.services.ZooKeeperService;
@@ -39,11 +40,11 @@ import org.slf4j.LoggerFactory;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
-public final class ZooKeeperClusteredRoutePolicyTest {
+public final class ZooKeeperClusteredRoutePolicyIT {
@RegisterExtension
static ZooKeeperService service = ZooKeeperServiceFactory.createService();
- private static final Logger LOGGER =
LoggerFactory.getLogger(ZooKeeperClusteredRoutePolicyTest.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(ZooKeeperClusteredRoutePolicyIT.class);
private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).collect(Collectors.toList());
private static final List<String> RESULTS = new ArrayList<>();
private static final ScheduledExecutorService SCHEDULER =
Executors.newScheduledThreadPool(CLIENTS.size() * 2);
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperMasterTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperMasterIT.java
similarity index 95%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperMasterTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperMasterIT.java
index 6b153ed..b7974d8 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/ZooKeeperMasterTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperMasterIT.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.cluster;
+package org.apache.camel.component.zookeeper.cluster.integration;
import java.util.ArrayList;
import java.util.List;
@@ -27,6 +27,7 @@ import java.util.stream.Collectors;
import java.util.stream.IntStream;
import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.zookeeper.cluster.ZooKeeperClusterService;
import org.apache.camel.impl.DefaultCamelContext;
import org.apache.camel.test.infra.zookeeper.services.ZooKeeperService;
import org.apache.camel.test.infra.zookeeper.services.ZooKeeperServiceFactory;
@@ -38,11 +39,11 @@ import org.slf4j.LoggerFactory;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
-public final class ZooKeeperMasterTest {
+public final class ZooKeeperMasterIT {
@RegisterExtension
static ZooKeeperService service = ZooKeeperServiceFactory.createService();
- private static final Logger LOGGER =
LoggerFactory.getLogger(ZooKeeperMasterTest.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(ZooKeeperMasterIT.class);
private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).collect(Collectors.toList());
private static final List<String> RESULTS = new ArrayList<>();
private static final ScheduledExecutorService SCHEDULER =
Executors.newScheduledThreadPool(CLIENTS.size());
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ConsumeChildrenTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ConsumeChildrenIT.java
similarity index 94%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ConsumeChildrenTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ConsumeChildrenIT.java
index 0a4f025..4c0cf68 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ConsumeChildrenTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ConsumeChildrenIT.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper;
+package org.apache.camel.component.zookeeper.integration;
import java.util.List;
@@ -24,7 +24,9 @@ import org.apache.camel.Message;
import org.apache.camel.NoSuchHeaderException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.component.zookeeper.NaturalSortComparator;
import org.apache.camel.component.zookeeper.NaturalSortComparator.Order;
+import org.apache.camel.component.zookeeper.ZooKeeperMessage;
import org.apache.camel.support.ExchangeHelper;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.data.Stat;
@@ -33,7 +35,7 @@ import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotSame;
-public class ConsumeChildrenTest extends ZooKeeperTestSupport {
+public class ConsumeChildrenIT extends ZooKeeperITSupport {
@Override
protected RouteBuilder[] createRouteBuilders() throws Exception {
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ConsumeDataTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ConsumeDataIT.java
similarity index 95%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ConsumeDataTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ConsumeDataIT.java
index 9c6b300..e5f7591 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ConsumeDataTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ConsumeDataIT.java
@@ -14,12 +14,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper;
+package org.apache.camel.component.zookeeper.integration;
import java.util.concurrent.TimeUnit;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.component.zookeeper.ZooKeeperMessage;
import org.apache.zookeeper.KeeperException.NodeExistsException;
import org.apache.zookeeper.Watcher.Event.EventType;
import org.junit.jupiter.api.Test;
@@ -27,7 +28,7 @@ import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
-public class ConsumeDataTest extends ZooKeeperTestSupport {
+public class ConsumeDataIT extends ZooKeeperITSupport {
@Override
protected RouteBuilder[] createRouteBuilders() throws Exception {
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperTestSupport.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZooKeeperITSupport.java
similarity index 97%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperTestSupport.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZooKeeperITSupport.java
index 5ce8629..c5cf2d9 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperTestSupport.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZooKeeperITSupport.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper;
+package org.apache.camel.component.zookeeper.integration;
import java.util.Arrays;
import java.util.List;
@@ -23,6 +23,7 @@ import java.util.concurrent.CountDownLatch;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.component.zookeeper.ZooKeeperMessage;
import org.apache.camel.test.infra.zookeeper.services.ZooKeeperService;
import org.apache.camel.test.infra.zookeeper.services.ZooKeeperServiceFactory;
import org.apache.camel.test.junit5.CamelTestSupport;
@@ -42,7 +43,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
-public class ZooKeeperTestSupport extends CamelTestSupport {
+public class ZooKeeperITSupport extends CamelTestSupport {
@RegisterExtension
static ZooKeeperService service = ZooKeeperServiceFactory.createService();
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperManagedEndpointTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZooKeeperManagedEndpointIT.java
similarity index 95%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperManagedEndpointTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZooKeeperManagedEndpointIT.java
index 868ea2d..ffedc6c 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperManagedEndpointTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZooKeeperManagedEndpointIT.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper;
+package org.apache.camel.component.zookeeper.integration;
import java.util.ArrayList;
import java.util.Set;
@@ -23,13 +23,14 @@ import javax.management.MBeanServer;
import javax.management.ObjectName;
import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.zookeeper.ZooKeeperEndpoint;
import org.junit.jupiter.api.Test;
import org.springframework.jmx.support.JmxUtils;
import static org.junit.jupiter.api.Assertions.assertEquals;
@SuppressWarnings("all")
-public class ZooKeeperManagedEndpointTest extends ZooKeeperTestSupport {
+public class ZooKeeperManagedEndpointIT extends ZooKeeperITSupport {
@Override
protected boolean useJmx() {
return true;
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperProducerTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZooKeeperProducerIT.java
similarity index 97%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperProducerTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZooKeeperProducerIT.java
index 6208466..7cfdefa 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperProducerTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZooKeeperProducerIT.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper;
+package org.apache.camel.component.zookeeper.integration;
import java.util.List;
@@ -23,6 +23,7 @@ import org.apache.camel.ExchangePattern;
import org.apache.camel.Message;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.component.zookeeper.ZooKeeperMessage;
import org.apache.camel.component.zookeeper.operations.GetChildrenOperation;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.data.Stat;
@@ -35,7 +36,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertNull;
-public class ZooKeeperProducerTest extends ZooKeeperTestSupport {
+public class ZooKeeperProducerIT extends ZooKeeperITSupport {
private String zookeeperUri;
private String testPayload = "TestPayload";
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZookeeperConnectionManagerTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZookeeperConnectionManagerIT.java
similarity index 80%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZookeeperConnectionManagerTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZookeeperConnectionManagerIT.java
index 21bc6c7..8e5fa65 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZookeeperConnectionManagerTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZookeeperConnectionManagerIT.java
@@ -14,15 +14,19 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper;
+package org.apache.camel.component.zookeeper.integration;
+import org.apache.camel.component.zookeeper.ZooKeeperComponent;
+import org.apache.camel.component.zookeeper.ZooKeeperConfiguration;
+import org.apache.camel.component.zookeeper.ZooKeeperConnectionManager;
+import org.apache.camel.component.zookeeper.ZooKeeperEndpoint;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.ZooKeeper.States;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertEquals;
-public class ZookeeperConnectionManagerTest extends ZooKeeperTestSupport {
+public class ZookeeperConnectionManagerIT extends ZooKeeperITSupport {
@Test
public void shouldWaitForConnection() {
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/AnyOfOperationTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/AnyOfOperationIT.java
similarity index 81%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/AnyOfOperationTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/AnyOfOperationIT.java
index ed22899..9e1009c 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/AnyOfOperationTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/AnyOfOperationIT.java
@@ -14,15 +14,18 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.operations;
+package org.apache.camel.component.zookeeper.operations.integration;
-import org.apache.camel.component.zookeeper.ZooKeeperTestSupport;
+import org.apache.camel.component.zookeeper.integration.ZooKeeperITSupport;
+import org.apache.camel.component.zookeeper.operations.AnyOfOperations;
+import
org.apache.camel.component.zookeeper.operations.ExistenceChangedOperation;
+import org.apache.camel.component.zookeeper.operations.ExistsOperation;
import org.apache.zookeeper.ZooKeeper;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertEquals;
-public class AnyOfOperationTest extends ZooKeeperTestSupport {
+public class AnyOfOperationIT extends ZooKeeperITSupport {
@Test
public void testExistsOrWaitsWhenNodeExists() throws Exception {
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/ChildrenChangedOperationTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/ChildrenChangedOperationIT.java
similarity index 89%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/ChildrenChangedOperationTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/ChildrenChangedOperationIT.java
index f1a78d7..d0b5dd8 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/ChildrenChangedOperationTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/ChildrenChangedOperationIT.java
@@ -14,15 +14,16 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.operations;
+package org.apache.camel.component.zookeeper.operations.integration;
-import org.apache.camel.component.zookeeper.ZooKeeperTestSupport;
+import org.apache.camel.component.zookeeper.integration.ZooKeeperITSupport;
+import
org.apache.camel.component.zookeeper.operations.ChildrenChangedOperation;
import org.apache.zookeeper.ZooKeeper;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertEquals;
-public class ChildrenChangedOperationTest extends ZooKeeperTestSupport {
+public class ChildrenChangedOperationIT extends ZooKeeperITSupport {
@Test
public void getsListingWhenNodeIsCreated() throws Exception {
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/CreateOperationTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/CreateOperationIT.java
similarity index 91%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/CreateOperationTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/CreateOperationIT.java
index 7e8ce74..2f471ba 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/CreateOperationTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/CreateOperationIT.java
@@ -14,12 +14,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.operations;
+package org.apache.camel.component.zookeeper.operations.integration;
import java.util.ArrayList;
import java.util.List;
-import org.apache.camel.component.zookeeper.ZooKeeperTestSupport;
+import org.apache.camel.component.zookeeper.integration.ZooKeeperITSupport;
+import org.apache.camel.component.zookeeper.operations.CreateOperation;
+import org.apache.camel.component.zookeeper.operations.OperationResult;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooDefs.Perms;
@@ -31,7 +33,7 @@ import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
-public class CreateOperationTest extends ZooKeeperTestSupport {
+public class CreateOperationIT extends ZooKeeperITSupport {
private ZooKeeper connection;
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/DataChangedOperationTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/DataChangedOperationIT.java
similarity index 87%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/DataChangedOperationTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/DataChangedOperationIT.java
index 8e94cb5..11fcf71 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/DataChangedOperationTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/DataChangedOperationIT.java
@@ -14,16 +14,17 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.operations;
+package org.apache.camel.component.zookeeper.operations.integration;
-import org.apache.camel.component.zookeeper.ZooKeeperTestSupport;
+import org.apache.camel.component.zookeeper.integration.ZooKeeperITSupport;
+import org.apache.camel.component.zookeeper.operations.DataChangedOperation;
import org.apache.zookeeper.ZooKeeper;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertArrayEquals;
import static org.junit.jupiter.api.Assertions.assertNull;
-public class DataChangedOperationTest extends ZooKeeperTestSupport {
+public class DataChangedOperationIT extends ZooKeeperITSupport {
@Test
public void getsDataWhenNodeChanges() throws Exception {
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/ExistenceChangedOperationTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/ExistenceChangedOperationIT.java
similarity index 87%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/ExistenceChangedOperationTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/ExistenceChangedOperationIT.java
index 36f3cf7..e3ecac4 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/ExistenceChangedOperationTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/ExistenceChangedOperationIT.java
@@ -14,9 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.operations;
+package org.apache.camel.component.zookeeper.operations.integration;
-import org.apache.camel.component.zookeeper.ZooKeeperTestSupport;
+import org.apache.camel.component.zookeeper.integration.ZooKeeperITSupport;
+import
org.apache.camel.component.zookeeper.operations.ExistenceChangedOperation;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooKeeper;
import org.junit.jupiter.api.Test;
@@ -25,7 +26,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertNull;
-public class ExistenceChangedOperationTest extends ZooKeeperTestSupport {
+public class ExistenceChangedOperationIT extends ZooKeeperITSupport {
@Test
public void getStatsWhenNodeIsCreated() throws Exception {
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/ExistenceOperationTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/ExistenceOperationIT.java
similarity index 88%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/ExistenceOperationTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/ExistenceOperationIT.java
index 43334ef..82286ae 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/ExistenceOperationTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/ExistenceOperationIT.java
@@ -14,16 +14,17 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.operations;
+package org.apache.camel.component.zookeeper.operations.integration;
-import org.apache.camel.component.zookeeper.ZooKeeperTestSupport;
+import org.apache.camel.component.zookeeper.integration.ZooKeeperITSupport;
+import org.apache.camel.component.zookeeper.operations.ExistsOperation;
import org.apache.zookeeper.ZooKeeper;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertTrue;
-public class ExistenceOperationTest extends ZooKeeperTestSupport {
+public class ExistenceOperationIT extends ZooKeeperITSupport {
@Test
public void okWhenNodeMustExistAndDoesExists() throws Exception {
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/SetDataOperationTest.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/SetDataOperationIT.java
similarity index 87%
rename from
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/SetDataOperationTest.java
rename to
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/SetDataOperationIT.java
index 4bf9c15..d1fb958 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/SetDataOperationTest.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/operations/integration/SetDataOperationIT.java
@@ -14,16 +14,18 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.zookeeper.operations;
+package org.apache.camel.component.zookeeper.operations.integration;
-import org.apache.camel.component.zookeeper.ZooKeeperTestSupport;
+import org.apache.camel.component.zookeeper.integration.ZooKeeperITSupport;
+import org.apache.camel.component.zookeeper.operations.OperationResult;
+import org.apache.camel.component.zookeeper.operations.SetDataOperation;
import org.apache.zookeeper.ZooKeeper;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertEquals;
-public class SetDataOperationTest extends ZooKeeperTestSupport {
+public class SetDataOperationIT extends ZooKeeperITSupport {
private ZooKeeper connection;
