Add zeebe dep, use new zeebe namespace

openMF · Jan 18, 2022 · 8a5f9f4 · 8a5f9f4
1 parent 12fa4d3
commit 8a5f9f4
Show file tree

Hide file tree

Showing 14 changed files with 19 additions and 13 deletions.
diff --git a/pom.xml b/pom.xml
@@ -29,6 +29,7 @@
 	<properties>
 		<camel.version>3.4.0</camel.version>
 		<ilp.version>1.3</ilp.version>
+		<zeebe.version>1.1.0</zeebe.version>
 		<compiler-plugin.version>3.8.1</compiler-plugin.version>
 
 		<maven.compiler.parameters>true</maven.compiler.parameters>
@@ -57,6 +58,11 @@
 			<artifactId>camel-jackson-starter</artifactId>
 			<version>${camel.version}</version>
 		</dependency>
+		<dependency>
+			<groupId>io.camunda</groupId>
+			<artifactId>zeebe-client-java</artifactId>
+			<version>${zeebe.version}</version>
+		</dependency>
 		<dependency>
 			<groupId>com.interop.ilp.conditions</groupId>
 			<artifactId>interop-ilp-conditions</artifactId>

diff --git a/src/main/java/org/mifos/connector/mojaloop/party/PartiesResponseProcessor.java b/src/main/java/org/mifos/connector/mojaloop/party/PartiesResponseProcessor.java
@@ -1,6 +1,6 @@
 package org.mifos.connector.mojaloop.party;
 
-import io.zeebe.client.ZeebeClient;
+import io.camunda.zeebe.client.ZeebeClient;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.mifos.connector.common.mojaloop.dto.PartySwitchResponseDTO;

diff --git a/src/main/java/org/mifos/connector/mojaloop/party/PartyLookupWorkers.java b/src/main/java/org/mifos/connector/mojaloop/party/PartyLookupWorkers.java
@@ -1,7 +1,7 @@
 package org.mifos.connector.mojaloop.party;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
-import io.zeebe.client.ZeebeClient;
+import io.camunda.zeebe.client.ZeebeClient;
 import org.apache.camel.CamelContext;
 import org.apache.camel.Exchange;
 import org.apache.camel.ProducerTemplate;

diff --git a/src/main/java/org/mifos/connector/mojaloop/quote/QuoteResponseProcessor.java b/src/main/java/org/mifos/connector/mojaloop/quote/QuoteResponseProcessor.java
@@ -2,7 +2,7 @@
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import io.zeebe.client.ZeebeClient;
+import io.camunda.zeebe.client.ZeebeClient;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.mifos.connector.common.mojaloop.dto.QuoteSwitchResponseDTO;

diff --git a/src/main/java/org/mifos/connector/mojaloop/quote/QuoteWorkers.java b/src/main/java/org/mifos/connector/mojaloop/quote/QuoteWorkers.java
@@ -1,7 +1,7 @@
 package org.mifos.connector.mojaloop.quote;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
-import io.zeebe.client.ZeebeClient;
+import io.camunda.zeebe.client.ZeebeClient;
 import org.apache.camel.CamelContext;
 import org.apache.camel.Exchange;
 import org.apache.camel.ProducerTemplate;

diff --git a/...in/java/org/mifos/connector/mojaloop/transactionrequest/TransactionResponseProcessor.java b/...in/java/org/mifos/connector/mojaloop/transactionrequest/TransactionResponseProcessor.java
@@ -1,7 +1,7 @@
 package org.mifos.connector.mojaloop.transactionrequest;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
-import io.zeebe.client.ZeebeClient;
+import io.camunda.zeebe.client.ZeebeClient;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.mifos.connector.common.mojaloop.dto.TransactionRequestSwitchResponseDTO;

diff --git a/src/main/java/org/mifos/connector/mojaloop/transactionrequest/TransactionWorkers.java b/src/main/java/org/mifos/connector/mojaloop/transactionrequest/TransactionWorkers.java
@@ -1,7 +1,7 @@
 package org.mifos.connector.mojaloop.transactionrequest;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
-import io.zeebe.client.ZeebeClient;
+import io.camunda.zeebe.client.ZeebeClient;
 import org.apache.camel.CamelContext;
 import org.apache.camel.Exchange;
 import org.apache.camel.ProducerTemplate;

diff --git a/src/main/java/org/mifos/connector/mojaloop/transfer/TransferResponseProcessor.java b/src/main/java/org/mifos/connector/mojaloop/transfer/TransferResponseProcessor.java
@@ -1,6 +1,6 @@
 package org.mifos.connector.mojaloop.transfer;
 
-import io.zeebe.client.ZeebeClient;
+import io.camunda.zeebe.client.ZeebeClient;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.mifos.connector.common.mojaloop.dto.TransferSwitchResponseDTO;

diff --git a/src/main/java/org/mifos/connector/mojaloop/transfer/TransferRoutes.java b/src/main/java/org/mifos/connector/mojaloop/transfer/TransferRoutes.java
@@ -2,7 +2,7 @@
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.ilp.conditions.models.pdp.Transaction;
-import io.zeebe.client.ZeebeClient;
+import io.camunda.zeebe.client.ZeebeClient;
 import org.apache.camel.Exchange;
 import org.apache.camel.LoggingLevel;
 import org.apache.camel.Processor;

diff --git a/src/main/java/org/mifos/connector/mojaloop/transfer/TransferWorkers.java b/src/main/java/org/mifos/connector/mojaloop/transfer/TransferWorkers.java
@@ -1,6 +1,6 @@
 package org.mifos.connector.mojaloop.transfer;
 
-import io.zeebe.client.ZeebeClient;
+import io.camunda.zeebe.client.ZeebeClient;
 import org.apache.camel.CamelContext;
 import org.apache.camel.Exchange;
 import org.apache.camel.ProducerTemplate;

diff --git a/src/main/java/org/mifos/connector/mojaloop/zeebe/ZeebeClientConfiguration.java b/src/main/java/org/mifos/connector/mojaloop/zeebe/ZeebeClientConfiguration.java
@@ -1,6 +1,6 @@
 package org.mifos.connector.mojaloop.zeebe;
 
-import io.zeebe.client.ZeebeClient;
+import io.camunda.zeebe.client.ZeebeClient;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
 import org.springframework.context.annotation.Bean;

diff --git a/src/main/java/org/mifos/connector/mojaloop/zeebe/ZeebeProcessStarter.java b/src/main/java/org/mifos/connector/mojaloop/zeebe/ZeebeProcessStarter.java
@@ -1,6 +1,6 @@
 package org.mifos.connector.mojaloop.zeebe;
 
-import io.zeebe.client.ZeebeClient;
+import io.camunda.zeebe.client.ZeebeClient;
 import org.apache.camel.Exchange;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

diff --git a/src/main/java/org/mifos/connector/mojaloop/zeebe/ZeebeeWorkers.java b/src/main/java/org/mifos/connector/mojaloop/zeebe/ZeebeeWorkers.java
@@ -1,6 +1,6 @@
 package org.mifos.connector.mojaloop.zeebe;
 
-import io.zeebe.client.ZeebeClient;
+import io.camunda.zeebe.client.ZeebeClient;
 import org.mifos.connector.common.mojaloop.type.TransactionRequestState;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

diff --git a/src/main/resources/logback.xml b/src/main/resources/logback.xml
@@ -14,7 +14,7 @@
 
     <logger name="org" level="INFO"/>
     <logger name="io" level="INFO"/>
-<!--    <logger name="io.zeebe.client.job.poller" level="TRACE"/>-->
+<!--    <logger name="io.camunda.zeebe.client.job.poller" level="TRACE"/>-->
 <!--    <logger name="hu.dpc" level="TRACE"/>-->
 <!--    <logger name="org.eclipse" level="TRACE"/>-->