[camel] branch master updated: [CAMEL-15315] Fix Pulsar AutoConfiguration.ensureNamespace() (#4039)

[ac...@apache.org]

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

acosentino 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 149d2cc  [CAMEL-15315] Fix Pulsar AutoConfiguration.ensureNamespace() (#4039)
149d2cc is described below

commit 149d2ccc787df943b74abc2f8600776c0dc8ea87
Author: James Adam <ja...@jamesadam.me>
AuthorDate: Thu Jul 23 11:37:59 2020 -0400

    [CAMEL-15315] Fix Pulsar AutoConfiguration.ensureNamespace() (#4039)
---
 .../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);
         }
     }