fixed operator use as message consumer

automatiko-io · May 31, 2023 · d1a2276 · d1a2276
1 parent 46ef163
commit d1a2276
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/codegen/src/main/java/io/automatiko/engine/codegen/process/MessageConsumerGenerator.java b/codegen/src/main/java/io/automatiko/engine/codegen/process/MessageConsumerGenerator.java
@@ -95,7 +95,7 @@ public MessageConsumerGenerator(GeneratorContext context, WorkflowProcess proces
         this.messageDataEventClassName = messageDataEventClassName;
 
         this.namespaces = (String) trigger.getContext("namespaces",
-                (String) process.getMetaData().getOrDefault("namespaces", ""));
+                (String) process.getMetaData().getOrDefault("namespaces", "JOSDK_ALL_NAMESPACES"));
     }
 
     public MessageConsumerGenerator withDependencyInjection(DependencyInjectionAnnotator annotator) {

diff --git a/pom.xml b/pom.xml
@@ -114,7 +114,7 @@
     <version.org.eclipse.microprofile.config>3.0.3</version.org.eclipse.microprofile.config>
     <version.org.eclipse.microprofile.openapi>3.1</version.org.eclipse.microprofile.openapi>
 
-    <version.io.javaoperatorsdk>6.0.1</version.io.javaoperatorsdk>
+    <version.io.javaoperatorsdk>6.1.0</version.io.javaoperatorsdk>
     <version.io.quarkiverse.googlecloudservices>2.0.0</version.io.quarkiverse.googlecloudservices>
     <version.com.datastax.oss.quarkus>1.2.0</version.com.datastax.oss.quarkus>
     <version.com.datastax.oss>4.15.0</version.com.datastax.oss>