From 8a5f9f4bcaf22dd9989adce6132caacddcfdc153 Mon Sep 17 00:00:00 2001
From: Thomas Kerin <me@thomaskerin.io>
Date: Tue, 18 Jan 2022 20:46:23 +0000
Subject: [PATCH] Add zeebe dep, use new zeebe namespace

---
 pom.xml                                                     | 6 ++++++
 .../connector/mojaloop/party/PartiesResponseProcessor.java  | 2 +-
 .../mifos/connector/mojaloop/party/PartyLookupWorkers.java  | 2 +-
 .../connector/mojaloop/quote/QuoteResponseProcessor.java    | 2 +-
 .../org/mifos/connector/mojaloop/quote/QuoteWorkers.java    | 2 +-
 .../transactionrequest/TransactionResponseProcessor.java    | 2 +-
 .../mojaloop/transactionrequest/TransactionWorkers.java     | 2 +-
 .../mojaloop/transfer/TransferResponseProcessor.java        | 2 +-
 .../mifos/connector/mojaloop/transfer/TransferRoutes.java   | 2 +-
 .../mifos/connector/mojaloop/transfer/TransferWorkers.java  | 2 +-
 .../connector/mojaloop/zeebe/ZeebeClientConfiguration.java  | 2 +-
 .../mifos/connector/mojaloop/zeebe/ZeebeProcessStarter.java | 2 +-
 .../org/mifos/connector/mojaloop/zeebe/ZeebeeWorkers.java   | 2 +-
 src/main/resources/logback.xml                              | 2 +-
 14 files changed, 19 insertions(+), 13 deletions(-)

diff --git a/pom.xml b/pom.xml
index 5131f30..a05976b 100644
--- 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
index b5a9ab6..d53d836 100644
--- 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
index 8e6676d..cd7ff88 100644
--- 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
index 6f4aeb0..e7dbcfb 100644
--- 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
index 357ea57..1b61cd1 100644
--- 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/src/main/java/org/mifos/connector/mojaloop/transactionrequest/TransactionResponseProcessor.java b/src/main/java/org/mifos/connector/mojaloop/transactionrequest/TransactionResponseProcessor.java
index e315b6c..78bc9bf 100644
--- a/src/main/java/org/mifos/connector/mojaloop/transactionrequest/TransactionResponseProcessor.java
+++ b/src/main/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
index f18c056..521c75c 100644
--- 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
index adc8fca..e064772 100644
--- 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
index 8abb5a7..a9508b6 100644
--- 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
index 9a4792a..53fdc1a 100644
--- 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
index c5181ac..308b7ce 100644
--- 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
index cc5a3a5..c2f3b43 100644
--- 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
index 4ca18e3..80e5ce5 100644
--- 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
index 46f13de..a9d692e 100644
--- 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"/>-->