[camel] branch master updated: CAMEL-13639: Changed the endpoint test-container is waiting for

[aldettinger]

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

aldettinger 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 03c9486  CAMEL-13639: Changed the endpoint test-container is waiting 
for
03c9486 is described below

commit 03c9486a78857fffdfdcbdff439d6f861da757ea
Author: aldettinger <aldettin...@gmail.com>
AuthorDate: Wed Jun 12 20:13:59 2019 +0200

    CAMEL-13639: Changed the endpoint test-container is waiting for
---
 .../java/org/apache/camel/component/pulsar/PulsarTestSupport.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarTestSupport.java
 
b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarTestSupport.java
index ad84334..25f1516 100644
--- 
a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarTestSupport.java
+++ 
b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarTestSupport.java
@@ -26,8 +26,8 @@ public class PulsarTestSupport extends 
ContainerAwareTestSupport {
     public static final String CONTAINER_NAME = "pulsar";
     public static final int BROKER_PORT = 6650;
     public static final int BROKER_HTTP_PORT = 8080;
-    public static final String METRICS_ENDPOINT = "/metrics";
-    
+    public static final String WAIT_FOR_ENDPOINT = 
"/admin/v2/namespaces/public";
+
     @Override
     protected GenericContainer<?> createContainer() {
         return pulsarContainer();
@@ -38,9 +38,9 @@ public class PulsarTestSupport extends 
ContainerAwareTestSupport {
             .withNetworkAliases(CONTAINER_NAME)
             .withExposedPorts(BROKER_PORT, BROKER_HTTP_PORT)
             .withCommand("/pulsar/bin/pulsar", "standalone", 
"--no-functions-worker", "-nss")
-            
.waitingFor(Wait.forHttp(METRICS_ENDPOINT).forStatusCode(200).forPort(BROKER_HTTP_PORT));
+            
.waitingFor(Wait.forHttp(WAIT_FOR_ENDPOINT).forStatusCode(200).forPort(BROKER_HTTP_PORT));
     }
-    
+
     public String getPulsarBrokerUrl() {
         return String.format("pulsar://%s:%s", 
getContainer(CONTAINER_NAME).getContainerIpAddress(), 
getContainer(CONTAINER_NAME).getMappedPort(BROKER_PORT));
     }