[camel] branch camel-3.4.x updated: [CAMEL-15315] Fix Pulsar AutoConfiguration.ensureNamespace() (#4040)

[acosentino]

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

acosentino pushed a commit to branch camel-3.4.x
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/camel-3.4.x by this push:
     new d3ca16e  [CAMEL-15315] Fix Pulsar AutoConfiguration.ensureNamespace() 
(#4040)
d3ca16e is described below

commit d3ca16ea3cd88b88ec6d0f2de72eda8c5478a8a0
Author: James Adam <ja...@jamesadam.me>
AuthorDate: Thu Jul 23 12:02:48 2020 -0400

    [CAMEL-15315] Fix Pulsar AutoConfiguration.ensureNamespace() (#4040)
---
 .../org/apache/camel/component/pulsar/utils/AutoConfiguration.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/AutoConfiguration.java
 
b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/AutoConfiguration.java
index d97fcc3..ab13d8f 100644
--- 
a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/AutoConfiguration.java
+++ 
b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/AutoConfiguration.java
@@ -59,8 +59,8 @@ public class AutoConfiguration {
 
     private void ensureNameSpace(String tenant, String namespace) throws 
PulsarAdminException {
         List<String> namespaces = 
pulsarAdmin.namespaces().getNamespaces(tenant);
-        if (!namespaces.contains(namespace)) {
-            pulsarAdmin.namespaces().createNamespace(namespace, clusters);
+        if (!namespaces.contains(tenant + "/" + namespace)) {
+            pulsarAdmin.namespaces().createNamespace(tenant + "/" + namespace, 
clusters);
         }
     }