Defined event listeners for ProcessInstanceDataExporter

camunda-community-hub · Mar 8, 2023 · be80ac0 · be80ac0
1 parent 76ff678
commit be80ac0
Show file tree

Hide file tree

Showing 3 changed files with 67 additions and 13 deletions.
diff --git a/camunda-7-adapter/pom.xml b/camunda-7-adapter/pom.xml
@@ -27,6 +27,16 @@
     <dependency>
       <groupId>org.camunda.bpm</groupId>
       <artifactId>camunda-engine-spring</artifactId>
+      <exclusions>
+        <exclusion>
+          <groupId>org.camunda.feel</groupId>
+          <artifactId>feel-engine</artifactId>
+        </exclusion>
+      </exclusions>
+    </dependency>
+    <dependency>
+      <groupId>org.camunda.feel</groupId>
+      <artifactId>feel-engine</artifactId>
     </dependency>
     <dependency>
       <groupId>org.camunda.bpm</groupId>

diff --git a/pom.xml b/pom.xml
@@ -1,4 +1,5 @@
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
 
   <groupId>org.camunda.community.migration</groupId>
@@ -22,7 +23,7 @@
     <version.zeebe>8.1.8</version.zeebe>
     <version.spring-zeebe-starter>8.1.17</version.spring-zeebe-starter>
     <version.zeebe-process-test-extension-testcontainer>8.1.8</version.zeebe-process-test-extension-testcontainer>
-    <version.camunda.platform>7.18.0</version.camunda.platform>
+    <version.camunda-bom>7.18.0</version.camunda-bom>
     <version.jsoup>1.15.4</version.jsoup>
     <version.spring-boot>2.7.9</version.spring-boot>
     <version.picocli>4.7.1</version.picocli>
@@ -31,6 +32,11 @@
     <version.opencsv>5.7.1</version.opencsv>
     <version.operate-client>8.1.7.0</version.operate-client>
     <version.camunda-bpm-assert>15.0.0</version.camunda-bpm-assert>
+    <version.scala-library>2.13.10</version.scala-library>
+    <version.feel-engine>1.15.3</version.feel-engine>
+    <version.protobuf>3.21.9</version.protobuf>
+    <version.guava>31.1-android</version.guava>
+    <version.error_prone_annotations>2.14.0</version.error_prone_annotations>
 
     <plugin.version.function-maven-plugin>0.10.1</plugin.version.function-maven-plugin>
     <plugin.version.maven-enforcer-plugin>3.2.1</plugin.version.maven-enforcer-plugin>
@@ -54,7 +60,7 @@
       <dependency>
         <groupId>org.camunda.bpm</groupId>
         <artifactId>camunda-bom</artifactId>
-        <version>${version.camunda.platform}</version>
+        <version>${version.camunda-bom}</version>
         <scope>import</scope>
         <type>pom</type>
       </dependency>
@@ -100,6 +106,36 @@
         <artifactId>camunda-operate-client-java</artifactId>
         <version>${version.operate-client}</version>
       </dependency>
+      <dependency>
+        <groupId>io.camunda</groupId>
+        <artifactId>zeebe-client-java</artifactId>
+        <version>${version.zeebe}</version>
+      </dependency>
+      <dependency>
+        <groupId>org.scala-lang</groupId>
+        <artifactId>scala-library</artifactId>
+        <version>${version.scala-library}</version>
+      </dependency>
+      <dependency>
+        <groupId>org.camunda.feel</groupId>
+        <artifactId>feel-engine</artifactId>
+        <version>${version.feel-engine}</version>
+      </dependency>
+      <dependency>
+        <groupId>com.google.protobuf</groupId>
+        <artifactId>protobuf-java</artifactId>
+        <version>${version.protobuf}</version>
+      </dependency>
+      <dependency>
+        <groupId>com.google.guava</groupId>
+        <artifactId>guava</artifactId>
+        <version>${version.guava}</version>
+      </dependency>
+      <dependency>
+        <groupId>com.google.errorprone</groupId>
+        <artifactId>error_prone_annotations</artifactId>
+        <version>${version.error_prone_annotations}</version>
+      </dependency>
       <dependency>
         <groupId>io.camunda</groupId>
         <artifactId>spring-zeebe-test-testcontainer</artifactId>
@@ -217,10 +253,9 @@
           <version>${plugin.version.maven-enforcer-plugin}</version>
           <configuration>
             <rules>
-              <!--
-                <dependencyConvergence />
-              -->
-              <requirePluginVersions />
+              <reactorModuleConvergence/>
+              <dependencyConvergence/>
+              <requirePluginVersions/>
             </rules>
           </configuration>
           <executions>
@@ -242,18 +277,18 @@
                   <include>*.md</include>
                   <include>.gitignore</include>
                 </includes>
-                <trimTrailingWhitespace />
-                <endWithNewline />
+                <trimTrailingWhitespace/>
+                <endWithNewline/>
                 <indent>
                   <spaces>true</spaces>
                   <spacesPerTab>2</spacesPerTab>
                 </indent>
               </format>
             </formats>
             <java>
-              <googleJavaFormat />
+              <googleJavaFormat/>
             </java>
-            <pom />
+            <pom/>
           </configuration>
         </plugin>
         <plugin>
@@ -288,7 +323,7 @@
                     </goals>
                   </pluginExecutionFilter>
                   <action>
-                    <ignore />
+                    <ignore/>
                   </action>
                 </pluginExecution>
               </pluginExecutions>

diff --git a/...java/org/camunda/community/migration/processInstance/api/ProcessInstanceDataExporter.java b/...java/org/camunda/community/migration/processInstance/api/ProcessInstanceDataExporter.java
@@ -3,9 +3,18 @@
 import org.camunda.community.migration.processInstance.api.model.ProcessInstanceData;
 
 public interface ProcessInstanceDataExporter {
+  /**
+   * @param start
+   * @param limit
+   * @return
+   */
   Page<ProcessInstanceData> list(long start, long limit);
 
   ProcessInstanceData get(String id);
 
-  void delete(String id);
+  void onMigrationStarted(String id);
+
+  void onMigrationSuccess(String id);
+
+  void onMigrationFailed(String id);
 }