This is an automated email from the ASF dual-hosted git repository.
pcongiusti pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 21305bfcd104 chore(components): mark deprecated tests
21305bfcd104 is described below
commit 21305bfcd1042ce0ddc22f7b969e4f1f2bc11fb4
Author: Pasquale Congiusti <[email protected]>
AuthorDate: Tue Jan 20 11:59:16 2026 +0100
chore(components): mark deprecated tests
Ref CAMEL-22549
---
.../apache/camel/component/zookeeper/cloud/MetaData.java | 2 +-
.../zookeeper/cloud/ZooKeeperServiceDiscovery.java | 2 +-
.../zookeeper/cloud/ZooKeeperServiceDiscoveryFactory.java | 2 +-
.../zookeeper/cloud/ZooKeeperServiceRegistry.java | 2 +-
.../cloud/ZooKeeperServiceRegistryConfiguration.java | 2 +-
.../integration/SpringZooKeeperServiceCallRouteIT.java | 2 ++
.../cloud/integration/ZooKeeperServiceCallRouteIT.java | 2 ++
.../cloud/integration/ZooKeeperServiceDiscoveryIT.java | 2 ++
.../integration/ZooKeeperServiceRegistrationITBase.java | 2 ++
...erServiceRegistrationWithRoutePolicyAndMetadataIT.java | 2 ++
...KeeperServiceRegistrationWithRoutePolicyFactoryIT.java | 2 ++
.../ZooKeeperServiceRegistrationWithRoutePolicyIT.java | 2 ++
...ooKeeperServiceRegistrationWithServiceComponentIT.java | 2 ++
.../ZooKeeperClusteredRoutePolicyFactoryIT.java | 3 +--
.../integration/ZooKeeperClusteredRoutePolicyIT.java | 3 +--
.../zookeeper/cluster/integration/ZooKeeperMasterIT.java | 3 +--
.../zookeeper/integration/ZooKeeperProducerIT.java | 15 ++++++++-------
17 files changed, 32 insertions(+), 18 deletions(-)
diff --git
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/MetaData.java
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/MetaData.java
index f1acd58a9072..4cf9c1b0311d 100644
---
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/MetaData.java
+++
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/MetaData.java
@@ -22,7 +22,7 @@ import java.util.Map;
import com.fasterxml.jackson.annotation.JsonRootName;
@JsonRootName("meta")
-@Deprecated
+@Deprecated(since = "4.7.0")
public class MetaData extends HashMap<String, String> {
public MetaData() {
}
diff --git
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceDiscovery.java
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceDiscovery.java
index f4553bd20bc2..cce56b5f9005 100644
---
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceDiscovery.java
+++
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceDiscovery.java
@@ -35,7 +35,7 @@ import org.apache.curator.x.discovery.ServiceDiscovery;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-@Deprecated
+@Deprecated(since = "4.7.0")
public class ZooKeeperServiceDiscovery extends DefaultServiceDiscovery {
private static final Logger LOGGER =
LoggerFactory.getLogger(ZooKeeperServiceDiscovery.class);
diff --git
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceDiscoveryFactory.java
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceDiscoveryFactory.java
index f5269a8baa1d..853dc957ef86 100644
---
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceDiscoveryFactory.java
+++
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceDiscoveryFactory.java
@@ -32,7 +32,7 @@ import org.apache.curator.framework.CuratorFramework;
@CloudServiceFactory("zookeeper-service-discovery")
@Configurer
-@Deprecated
+@Deprecated(since = "4.7.0")
public class ZooKeeperServiceDiscoveryFactory implements
ServiceDiscoveryFactory {
private ZooKeeperCuratorConfiguration configuration;
diff --git
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistry.java
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistry.java
index 1dcfcd7a511f..e7f50c9e751c 100644
---
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistry.java
+++
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistry.java
@@ -34,7 +34,7 @@ import org.apache.curator.x.discovery.ServiceInstance;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-@Deprecated
+@Deprecated(since = "4.7.0")
public class ZooKeeperServiceRegistry extends AbstractServiceRegistry {
private static final Logger LOGGER =
LoggerFactory.getLogger(ZooKeeperServiceRegistry.class);
diff --git
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistryConfiguration.java
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistryConfiguration.java
index 21e4143e86c0..e94047f37e2e 100644
---
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistryConfiguration.java
+++
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistryConfiguration.java
@@ -19,7 +19,7 @@ package org.apache.camel.component.zookeeper.cloud;
import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.zookeeper.ZooKeeperCuratorConfiguration;
-@Deprecated
+@Deprecated(since = "4.7.0")
public class ZooKeeperServiceRegistryConfiguration extends
ZooKeeperCuratorConfiguration {
/**
* Should we remove all the registered services know by this registry on
stop?
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/SpringZooKeeperServiceCallRouteIT.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/SpringZooKeeperServiceCallRouteIT.java
index a31785133853..0cb510cf4a50 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/SpringZooKeeperServiceCallRouteIT.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/SpringZooKeeperServiceCallRouteIT.java
@@ -37,6 +37,8 @@ import org.junit.jupiter.api.extension.RegisterExtension;
import org.springframework.context.support.AbstractApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
+@Deprecated(since = "4.7.0")
+// NOTE: we should remove this test when removing the source code deprecation
on cloud.
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/integration/ZooKeeperServiceCallRouteIT.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceCallRouteIT.java
index a83f8e932147..7df0796a6c8d 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceCallRouteIT.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceCallRouteIT.java
@@ -38,6 +38,8 @@ import
org.apache.curator.x.discovery.details.JsonInstanceSerializer;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.RegisterExtension;
+@Deprecated(since = "4.7.0")
+// NOTE: we should remove this test when removing the source code deprecation
on cloud.
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/integration/ZooKeeperServiceDiscoveryIT.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceDiscoveryIT.java
index 4de7f2830833..ed6cf6859fa9 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceDiscoveryIT.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceDiscoveryIT.java
@@ -40,6 +40,8 @@ import static org.awaitility.Awaitility.await;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
+@Deprecated(since = "4.7.0")
+// NOTE: we should remove this test when removing the source code deprecation
on cloud.
class ZooKeeperServiceDiscoveryIT {
@RegisterExtension
static ZooKeeperService service = ZooKeeperServiceFactory.createService();
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationITBase.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationITBase.java
index 8bdb3b9a7d34..804c78d0f76d 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationITBase.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationITBase.java
@@ -43,6 +43,8 @@ import static org.awaitility.Awaitility.await;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
+@Deprecated(since = "4.7.0")
+// NOTE: we should remove this test when removing the source code deprecation
on cloud.
public abstract class ZooKeeperServiceRegistrationITBase extends
CamelTestSupport {
protected static final String SERVICE_ID = UUID.randomUUID().toString();
protected static final String SERVICE_NAME = "my-service";
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyAndMetadataIT.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyAndMetadataIT.java
index b3901c09a756..949703a4984e 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyAndMetadataIT.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyAndMetadataIT.java
@@ -21,6 +21,8 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.cloud.ServiceDefinition;
import org.apache.camel.impl.cloud.ServiceRegistrationRoutePolicy;
+@Deprecated(since = "4.7.0")
+// NOTE: we should remove this test when removing the source code deprecation
on cloud.
public class ZooKeeperServiceRegistrationWithRoutePolicyAndMetadataIT extends
ZooKeeperServiceRegistrationITBase {
@Override
protected RoutesBuilder createRouteBuilder() {
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyFactoryIT.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyFactoryIT.java
index c0446f24ffe0..aa30edb94a09 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyFactoryIT.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyFactoryIT.java
@@ -21,6 +21,8 @@ import org.apache.camel.RoutesBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.cloud.ServiceRegistrationRoutePolicyFactory;
+@Deprecated(since = "4.7.0")
+// NOTE: we should remove this test when removing the source code deprecation
on cloud.
public class ZooKeeperServiceRegistrationWithRoutePolicyFactoryIT extends
ZooKeeperServiceRegistrationITBase {
@Override
protected CamelContext createCamelContext() throws Exception {
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyIT.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyIT.java
index a9e2e968e040..3223168b7797 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyIT.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithRoutePolicyIT.java
@@ -20,6 +20,8 @@ import org.apache.camel.RoutesBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.cloud.ServiceRegistrationRoutePolicy;
+@Deprecated(since = "4.7.0")
+// NOTE: we should remove this test when removing the source code deprecation
on cloud.
public class ZooKeeperServiceRegistrationWithRoutePolicyIT extends
ZooKeeperServiceRegistrationITBase {
@Override
protected RoutesBuilder createRouteBuilder() {
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithServiceComponentIT.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithServiceComponentIT.java
index 0cc75b54ccc0..4961232deeee 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithServiceComponentIT.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationWithServiceComponentIT.java
@@ -24,6 +24,8 @@ import org.apache.camel.RoutesBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.service.ServiceComponent;
+@Deprecated(since = "4.7.0")
+// NOTE: we should remove this test when removing the source code deprecation
on cloud.
public class ZooKeeperServiceRegistrationWithServiceComponentIT extends
ZooKeeperServiceRegistrationITBase {
@BindToRegistry("service")
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyFactoryIT.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyFactoryIT.java
index 58fd469419d8..c4338ff8a25f 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyFactoryIT.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyFactoryIT.java
@@ -72,7 +72,7 @@ public final class ZooKeeperClusteredRoutePolicyFactoryIT {
// ************************************
private static void run(String connectString, String id) {
- try {
+ try (DefaultCamelContext context = new DefaultCamelContext()) {
int events = ThreadLocalRandom.current().nextInt(2, 6);
CountDownLatch contextLatch = new CountDownLatch(events);
@@ -81,7 +81,6 @@ public final class ZooKeeperClusteredRoutePolicyFactoryIT {
service.setNodes(connectString);
service.setBasePath("/camel");
- DefaultCamelContext context = new DefaultCamelContext();
context.disableJMX();
context.getCamelContextExtension().setName("context-" + id);
context.addService(service);
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyIT.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyIT.java
index 5103fd24c483..ca11a6fca63c 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyIT.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyIT.java
@@ -72,7 +72,7 @@ public final class ZooKeeperClusteredRoutePolicyIT {
// ************************************
private static void run(String connectString, String id) {
- try {
+ try (DefaultCamelContext context = new DefaultCamelContext()) {
int events = ThreadLocalRandom.current().nextInt(2, 6);
CountDownLatch contextLatch = new CountDownLatch(events);
@@ -81,7 +81,6 @@ public final class ZooKeeperClusteredRoutePolicyIT {
service.setNodes(connectString);
service.setBasePath("/camel");
- DefaultCamelContext context = new DefaultCamelContext();
context.disableJMX();
context.getCamelContextExtension().setName("context-" + id);
context.addService(service);
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperMasterIT.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperMasterIT.java
index 1f69a99f5014..02349fd7a06c 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperMasterIT.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperMasterIT.java
@@ -71,7 +71,7 @@ public final class ZooKeeperMasterIT {
// ************************************
private static void run(String connectString, String id) {
- try {
+ try (DefaultCamelContext context = new DefaultCamelContext()) {
int events = ThreadLocalRandom.current().nextInt(2, 6);
CountDownLatch contextLatch = new CountDownLatch(events);
@@ -80,7 +80,6 @@ public final class ZooKeeperMasterIT {
service.setNodes(connectString);
service.setBasePath("/camel/master");
- DefaultCamelContext context = new DefaultCamelContext();
context.disableJMX();
context.getCamelContextExtension().setName("context-" + id);
context.addService(service);
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZooKeeperProducerIT.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZooKeeperProducerIT.java
index 7048b995c7f3..1db6e8ecf303 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZooKeeperProducerIT.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ZooKeeperProducerIT.java
@@ -25,6 +25,7 @@ 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.camel.test.junit5.TestSupport;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.data.Stat;
import org.junit.jupiter.api.Test;
@@ -93,7 +94,7 @@ public class ZooKeeperProducerIT extends ZooKeeperITSupport {
mock.expectedMessageCount(1);
pipeline.expectedMessageCount(1);
- Exchange e = createExchangeWithBody(testPayload);
+ Exchange e = TestSupport.createExchangeWithBody(this.context,
testPayload);
e.setPattern(ExchangePattern.InOut);
template.send("direct:roundtrip", e);
@@ -105,7 +106,7 @@ public class ZooKeeperProducerIT extends ZooKeeperITSupport
{
MockEndpoint mock = getMockEndpoint("mock:consumed-from-node");
mock.expectedMessageCount(1);
- Exchange e = createExchangeWithBody(testPayload);
+ Exchange e = TestSupport.createExchangeWithBody(this.context,
testPayload);
template.send("direct:roundtrip", e);
MockEndpoint.assertIsSatisfied(context);
@@ -115,7 +116,7 @@ public class ZooKeeperProducerIT extends ZooKeeperITSupport
{
public void setUsingCreateModeFromHeader() throws Exception {
client.createPersistent("/modes-test", "parent for modes");
- Exchange exchange = createExchangeWithBody(testPayload);
+ Exchange exchange = TestSupport.createExchangeWithBody(this.context,
testPayload);
exchange.getIn().setHeader(ZOOKEEPER_CREATE_MODE,
CreateMode.EPHEMERAL.name());
exchange.getIn().setHeader(ZOOKEEPER_NODE, "/modes-test/" +
CreateMode.EPHEMERAL.name());
exchange.setPattern(ExchangePattern.InOut);
@@ -130,7 +131,7 @@ public class ZooKeeperProducerIT extends ZooKeeperITSupport
{
MockEndpoint mock = getMockEndpoint("mock:create-mode");
mock.expectedMessageCount(1);
- Exchange e = createExchangeWithBody(testPayload);
+ Exchange e = TestSupport.createExchangeWithBody(this.context,
testPayload);
e.setPattern(ExchangePattern.InOut);
template.send("direct:create-mode", e);
@@ -147,7 +148,7 @@ public class ZooKeeperProducerIT extends ZooKeeperITSupport
{
mock.expectedMessageCount(1);
client.createPersistent("/to-be-deleted", "to be deleted");
- Exchange e = createExchangeWithBody(null);
+ Exchange e = TestSupport.createExchangeWithBody(this.context, null);
e.setPattern(ExchangePattern.InOut);
e.getIn().setHeader(ZOOKEEPER_OPERATION, "DELETE");
template.send("direct:delete", e);
@@ -161,7 +162,7 @@ public class ZooKeeperProducerIT extends ZooKeeperITSupport
{
public void setAndGetListing() throws Exception {
client.createPersistent("/set-listing", "parent for set and list
test");
- Exchange exchange = createExchangeWithBody(testPayload);
+ Exchange exchange = TestSupport.createExchangeWithBody(this.context,
testPayload);
exchange.getIn().setHeader(ZOOKEEPER_NODE, "/set-listing/firstborn");
exchange.setPattern(ExchangePattern.InOut);
template.send(
@@ -177,7 +178,7 @@ public class ZooKeeperProducerIT extends ZooKeeperITSupport
{
MockEndpoint mock = getMockEndpoint("mock:consumed-from-node");
mock.expectedMessageCount(1);
- Exchange exchange = createExchangeWithBody(testPayload);
+ Exchange exchange = TestSupport.createExchangeWithBody(this.context,
testPayload);
template.send("direct:roundtrip", exchange);
MockEndpoint.assertIsSatisfied(context);
