You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2023/08/06 19:13:03 UTC

[camel] 01/01: camel-zookeeper-master - Do not create new CamelContext but use injected context in test.

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch zk
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 7bcda963d139e8c17d168173b4d7f8f6384e7c34
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Sun Aug 6 21:12:52 2023 +0200

    camel-zookeeper-master - Do not create new CamelContext but use injected context in test.
---
 .../org/apache/camel/component/zookeepermaster/MasterEndpointIT.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/components/camel-zookeeper-master/src/test/java/org/apache/camel/component/zookeepermaster/MasterEndpointIT.java b/components/camel-zookeeper-master/src/test/java/org/apache/camel/component/zookeepermaster/MasterEndpointIT.java
index 6e2441c3efd..c9328073aaa 100644
--- a/components/camel-zookeeper-master/src/test/java/org/apache/camel/component/zookeepermaster/MasterEndpointIT.java
+++ b/components/camel-zookeeper-master/src/test/java/org/apache/camel/component/zookeepermaster/MasterEndpointIT.java
@@ -26,7 +26,6 @@ import org.apache.camel.Route;
 import org.apache.camel.component.file.remote.SftpEndpoint;
 import org.apache.camel.component.mock.MockEndpoint;
 import org.apache.camel.component.zookeepermaster.group.ZookeeprContainer;
-import org.apache.camel.impl.DefaultCamelContext;
 import org.apache.camel.test.spring.junit5.CamelSpringTest;
 import org.awaitility.Awaitility;
 import org.junit.jupiter.api.Test;
@@ -74,8 +73,7 @@ public class MasterEndpointIT {
         final String uri
                 = "zookeeper-master://name:sftp://myhost/inbox?password=RAW(_BEFORE_AMPERSAND_&_AFTER_AMPERSAND_)&username=jdoe";
 
-        DefaultCamelContext ctx = new DefaultCamelContext();
-        MasterEndpoint master = (MasterEndpoint) ctx.getEndpoint(uri);
+        MasterEndpoint master = (MasterEndpoint) camelContext.getEndpoint(uri);
         SftpEndpoint sftp = (SftpEndpoint) master.getEndpoint();
 
         assertEquals("_BEFORE_AMPERSAND_&_AFTER_AMPERSAND_", sftp.getConfiguration().getPassword());