init
0 parents
Showing
21 changed files
with
606 additions
and
0 deletions
.classpath
0 → 100644
| 1 | <?xml version="1.0" encoding="UTF-8"?> | ||
| 2 | <classpath> | ||
| 3 | <classpathentry kind="src" output="target/classes" path="src/main/java"> | ||
| 4 | <attributes> | ||
| 5 | <attribute name="optional" value="true"/> | ||
| 6 | <attribute name="maven.pomderived" value="true"/> | ||
| 7 | </attributes> | ||
| 8 | </classpathentry> | ||
| 9 | <classpathentry excluding="**" kind="src" output="target/classes" path="src/main/resources"> | ||
| 10 | <attributes> | ||
| 11 | <attribute name="maven.pomderived" value="true"/> | ||
| 12 | </attributes> | ||
| 13 | </classpathentry> | ||
| 14 | <classpathentry kind="src" output="target/test-classes" path="src/test/java"> | ||
| 15 | <attributes> | ||
| 16 | <attribute name="optional" value="true"/> | ||
| 17 | <attribute name="maven.pomderived" value="true"/> | ||
| 18 | <attribute name="test" value="true"/> | ||
| 19 | </attributes> | ||
| 20 | </classpathentry> | ||
| 21 | <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8"> | ||
| 22 | <attributes> | ||
| 23 | <attribute name="maven.pomderived" value="true"/> | ||
| 24 | </attributes> | ||
| 25 | </classpathentry> | ||
| 26 | <classpathentry kind="con" path="org.eclipse.m2e.MAVEN2_CLASSPATH_CONTAINER"> | ||
| 27 | <attributes> | ||
| 28 | <attribute name="maven.pomderived" value="true"/> | ||
| 29 | </attributes> | ||
| 30 | </classpathentry> | ||
| 31 | <classpathentry kind="output" path="target/classes"/> | ||
| 32 | </classpath> |
.mvn/wrapper/maven-wrapper.jar
0 → 100644
No preview for this file type
.mvn/wrapper/maven-wrapper.properties
0 → 100644
.project
0 → 100644
| 1 | <?xml version="1.0" encoding="UTF-8"?> | ||
| 2 | <projectDescription> | ||
| 3 | <name>xxs-exporter</name> | ||
| 4 | <comment></comment> | ||
| 5 | <projects> | ||
| 6 | </projects> | ||
| 7 | <buildSpec> | ||
| 8 | <buildCommand> | ||
| 9 | <name>org.eclipse.jdt.core.javabuilder</name> | ||
| 10 | <arguments> | ||
| 11 | </arguments> | ||
| 12 | </buildCommand> | ||
| 13 | <buildCommand> | ||
| 14 | <name>org.eclipse.m2e.core.maven2Builder</name> | ||
| 15 | <arguments> | ||
| 16 | </arguments> | ||
| 17 | </buildCommand> | ||
| 18 | </buildSpec> | ||
| 19 | <natures> | ||
| 20 | <nature>org.eclipse.jdt.core.javanature</nature> | ||
| 21 | <nature>org.eclipse.m2e.core.maven2Nature</nature> | ||
| 22 | </natures> | ||
| 23 | </projectDescription> |
.settings/org.eclipse.jdt.core.prefs
0 → 100644
| 1 | eclipse.preferences.version=1 | ||
| 2 | org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8 | ||
| 3 | org.eclipse.jdt.core.compiler.compliance=1.8 | ||
| 4 | org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled | ||
| 5 | org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning | ||
| 6 | org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=ignore | ||
| 7 | org.eclipse.jdt.core.compiler.release=disabled | ||
| 8 | org.eclipse.jdt.core.compiler.source=1.8 |
.settings/org.eclipse.m2e.core.prefs
0 → 100644
mvnw
0 → 100644
This diff is collapsed.
Click to expand it.
mvnw.cmd
0 → 100644
| 1 | @REM ---------------------------------------------------------------------------- | ||
| 2 | @REM Licensed to the Apache Software Foundation (ASF) under one | ||
| 3 | @REM or more contributor license agreements. See the NOTICE file | ||
| 4 | @REM distributed with this work for additional information | ||
| 5 | @REM regarding copyright ownership. The ASF licenses this file | ||
| 6 | @REM to you under the Apache License, Version 2.0 (the | ||
| 7 | @REM "License"); you may not use this file except in compliance | ||
| 8 | @REM with the License. You may obtain a copy of the License at | ||
| 9 | @REM | ||
| 10 | @REM https://www.apache.org/licenses/LICENSE-2.0 | ||
| 11 | @REM | ||
| 12 | @REM Unless required by applicable law or agreed to in writing, | ||
| 13 | @REM software distributed under the License is distributed on an | ||
| 14 | @REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY | ||
| 15 | @REM KIND, either express or implied. See the License for the | ||
| 16 | @REM specific language governing permissions and limitations | ||
| 17 | @REM under the License. | ||
| 18 | @REM ---------------------------------------------------------------------------- | ||
| 19 | |||
| 20 | @REM ---------------------------------------------------------------------------- | ||
| 21 | @REM Maven Start Up Batch script | ||
| 22 | @REM | ||
| 23 | @REM Required ENV vars: | ||
| 24 | @REM JAVA_HOME - location of a JDK home dir | ||
| 25 | @REM | ||
| 26 | @REM Optional ENV vars | ||
| 27 | @REM M2_HOME - location of maven2's installed home dir | ||
| 28 | @REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands | ||
| 29 | @REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending | ||
| 30 | @REM MAVEN_OPTS - parameters passed to the Java VM when running Maven | ||
| 31 | @REM e.g. to debug Maven itself, use | ||
| 32 | @REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000 | ||
| 33 | @REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files | ||
| 34 | @REM ---------------------------------------------------------------------------- | ||
| 35 | |||
| 36 | @REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on' | ||
| 37 | @echo off | ||
| 38 | @REM set title of command window | ||
| 39 | title %0 | ||
| 40 | @REM enable echoing by setting MAVEN_BATCH_ECHO to 'on' | ||
| 41 | @if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO% | ||
| 42 | |||
| 43 | @REM set %HOME% to equivalent of $HOME | ||
| 44 | if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%") | ||
| 45 | |||
| 46 | @REM Execute a user defined script before this one | ||
| 47 | if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre | ||
| 48 | @REM check for pre script, once with legacy .bat ending and once with .cmd ending | ||
| 49 | if exist "%USERPROFILE%\mavenrc_pre.bat" call "%USERPROFILE%\mavenrc_pre.bat" %* | ||
| 50 | if exist "%USERPROFILE%\mavenrc_pre.cmd" call "%USERPROFILE%\mavenrc_pre.cmd" %* | ||
| 51 | :skipRcPre | ||
| 52 | |||
| 53 | @setlocal | ||
| 54 | |||
| 55 | set ERROR_CODE=0 | ||
| 56 | |||
| 57 | @REM To isolate internal variables from possible post scripts, we use another setlocal | ||
| 58 | @setlocal | ||
| 59 | |||
| 60 | @REM ==== START VALIDATION ==== | ||
| 61 | if not "%JAVA_HOME%" == "" goto OkJHome | ||
| 62 | |||
| 63 | echo. | ||
| 64 | echo Error: JAVA_HOME not found in your environment. >&2 | ||
| 65 | echo Please set the JAVA_HOME variable in your environment to match the >&2 | ||
| 66 | echo location of your Java installation. >&2 | ||
| 67 | echo. | ||
| 68 | goto error | ||
| 69 | |||
| 70 | :OkJHome | ||
| 71 | if exist "%JAVA_HOME%\bin\java.exe" goto init | ||
| 72 | |||
| 73 | echo. | ||
| 74 | echo Error: JAVA_HOME is set to an invalid directory. >&2 | ||
| 75 | echo JAVA_HOME = "%JAVA_HOME%" >&2 | ||
| 76 | echo Please set the JAVA_HOME variable in your environment to match the >&2 | ||
| 77 | echo location of your Java installation. >&2 | ||
| 78 | echo. | ||
| 79 | goto error | ||
| 80 | |||
| 81 | @REM ==== END VALIDATION ==== | ||
| 82 | |||
| 83 | :init | ||
| 84 | |||
| 85 | @REM Find the project base dir, i.e. the directory that contains the folder ".mvn". | ||
| 86 | @REM Fallback to current working directory if not found. | ||
| 87 | |||
| 88 | set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR% | ||
| 89 | IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir | ||
| 90 | |||
| 91 | set EXEC_DIR=%CD% | ||
| 92 | set WDIR=%EXEC_DIR% | ||
| 93 | :findBaseDir | ||
| 94 | IF EXIST "%WDIR%"\.mvn goto baseDirFound | ||
| 95 | cd .. | ||
| 96 | IF "%WDIR%"=="%CD%" goto baseDirNotFound | ||
| 97 | set WDIR=%CD% | ||
| 98 | goto findBaseDir | ||
| 99 | |||
| 100 | :baseDirFound | ||
| 101 | set MAVEN_PROJECTBASEDIR=%WDIR% | ||
| 102 | cd "%EXEC_DIR%" | ||
| 103 | goto endDetectBaseDir | ||
| 104 | |||
| 105 | :baseDirNotFound | ||
| 106 | set MAVEN_PROJECTBASEDIR=%EXEC_DIR% | ||
| 107 | cd "%EXEC_DIR%" | ||
| 108 | |||
| 109 | :endDetectBaseDir | ||
| 110 | |||
| 111 | IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig | ||
| 112 | |||
| 113 | @setlocal EnableExtensions EnableDelayedExpansion | ||
| 114 | for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a | ||
| 115 | @endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS% | ||
| 116 | |||
| 117 | :endReadAdditionalConfig | ||
| 118 | |||
| 119 | SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe" | ||
| 120 | set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar" | ||
| 121 | set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain | ||
| 122 | |||
| 123 | set DOWNLOAD_URL="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar" | ||
| 124 | |||
| 125 | FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO ( | ||
| 126 | IF "%%A"=="wrapperUrl" SET DOWNLOAD_URL=%%B | ||
| 127 | ) | ||
| 128 | |||
| 129 | @REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central | ||
| 130 | @REM This allows using the maven wrapper in projects that prohibit checking in binary data. | ||
| 131 | if exist %WRAPPER_JAR% ( | ||
| 132 | if "%MVNW_VERBOSE%" == "true" ( | ||
| 133 | echo Found %WRAPPER_JAR% | ||
| 134 | ) | ||
| 135 | ) else ( | ||
| 136 | if not "%MVNW_REPOURL%" == "" ( | ||
| 137 | SET DOWNLOAD_URL="%MVNW_REPOURL%/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar" | ||
| 138 | ) | ||
| 139 | if "%MVNW_VERBOSE%" == "true" ( | ||
| 140 | echo Couldn't find %WRAPPER_JAR%, downloading it ... | ||
| 141 | echo Downloading from: %DOWNLOAD_URL% | ||
| 142 | ) | ||
| 143 | |||
| 144 | powershell -Command "&{"^ | ||
| 145 | "$webclient = new-object System.Net.WebClient;"^ | ||
| 146 | "if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^ | ||
| 147 | "$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^ | ||
| 148 | "}"^ | ||
| 149 | "[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%DOWNLOAD_URL%', '%WRAPPER_JAR%')"^ | ||
| 150 | "}" | ||
| 151 | if "%MVNW_VERBOSE%" == "true" ( | ||
| 152 | echo Finished downloading %WRAPPER_JAR% | ||
| 153 | ) | ||
| 154 | ) | ||
| 155 | @REM End of extension | ||
| 156 | |||
| 157 | @REM Provide a "standardized" way to retrieve the CLI args that will | ||
| 158 | @REM work with both Windows and non-Windows executions. | ||
| 159 | set MAVEN_CMD_LINE_ARGS=%* | ||
| 160 | |||
| 161 | %MAVEN_JAVA_EXE% ^ | ||
| 162 | %JVM_CONFIG_MAVEN_PROPS% ^ | ||
| 163 | %MAVEN_OPTS% ^ | ||
| 164 | %MAVEN_DEBUG_OPTS% ^ | ||
| 165 | -classpath %WRAPPER_JAR% ^ | ||
| 166 | "-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" ^ | ||
| 167 | %WRAPPER_LAUNCHER% %MAVEN_CONFIG% %* | ||
| 168 | if ERRORLEVEL 1 goto error | ||
| 169 | goto end | ||
| 170 | |||
| 171 | :error | ||
| 172 | set ERROR_CODE=1 | ||
| 173 | |||
| 174 | :end | ||
| 175 | @endlocal & set ERROR_CODE=%ERROR_CODE% | ||
| 176 | |||
| 177 | if not "%MAVEN_SKIP_RC%"=="" goto skipRcPost | ||
| 178 | @REM check for post script, once with legacy .bat ending and once with .cmd ending | ||
| 179 | if exist "%USERPROFILE%\mavenrc_post.bat" call "%USERPROFILE%\mavenrc_post.bat" | ||
| 180 | if exist "%USERPROFILE%\mavenrc_post.cmd" call "%USERPROFILE%\mavenrc_post.cmd" | ||
| 181 | :skipRcPost | ||
| 182 | |||
| 183 | @REM pause the script if MAVEN_BATCH_PAUSE is set to 'on' | ||
| 184 | if "%MAVEN_BATCH_PAUSE%"=="on" pause | ||
| 185 | |||
| 186 | if "%MAVEN_TERMINATE_CMD%"=="on" exit %ERROR_CODE% | ||
| 187 | |||
| 188 | cmd /C exit /B %ERROR_CODE% |
pom.xml
0 → 100644
| 1 | <?xml version="1.0" encoding="UTF-8"?> | ||
| 2 | <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 https://maven.apache.org/xsd/maven-4.0.0.xsd"> | ||
| 3 | <modelVersion>4.0.0</modelVersion> | ||
| 4 | <groupId>com.rs2i.camunda.exporter</groupId> | ||
| 5 | <artifactId>rs2i-exporter</artifactId> | ||
| 6 | <packaging>jar</packaging> | ||
| 7 | <version>0.0.1-SNAPSHOT</version> | ||
| 8 | <name>rs2i-exporter</name> | ||
| 9 | <description>Learning camunda RS2i Exporter</description> | ||
| 10 | <properties> | ||
| 11 | <zeebe.version>8.0.5</zeebe.version> | ||
| 12 | <jar.fileName>${project.artifactId}</jar.fileName> | ||
| 13 | <qpid.jms.version>2.1.0</qpid.jms.version> | ||
| 14 | <lombok.version>1.18.24</lombok.version> | ||
| 15 | <maven.compiler.source>1.8</maven.compiler.source> | ||
| 16 | <maven.compiler.target>1.8</maven.compiler.target> | ||
| 17 | <jar.fileName>${project.artifactId}</jar.fileName> | ||
| 18 | <org.json.version>20180130</org.json.version> | ||
| 19 | </properties> | ||
| 20 | <dependencies> | ||
| 21 | <dependency> | ||
| 22 | <groupId>org.projectlombok</groupId> | ||
| 23 | <artifactId>lombok</artifactId> | ||
| 24 | <version>${lombok.version}</version> | ||
| 25 | <scope>provided</scope> | ||
| 26 | </dependency> | ||
| 27 | <dependency> | ||
| 28 | <groupId>io.camunda</groupId> | ||
| 29 | <artifactId>zeebe-exporter-api</artifactId> | ||
| 30 | <version>${zeebe.version}</version> | ||
| 31 | <scope>provided</scope> | ||
| 32 | </dependency> | ||
| 33 | <dependency> | ||
| 34 | <groupId>org.json</groupId> | ||
| 35 | <artifactId>json</artifactId> | ||
| 36 | <version>${org.json.version}</version> | ||
| 37 | </dependency> | ||
| 38 | <dependency> | ||
| 39 | <groupId>org.apache.qpid</groupId> | ||
| 40 | <artifactId>qpid-jms-client</artifactId> | ||
| 41 | <version>${qpid.jms.version}</version> | ||
| 42 | <exclusions> | ||
| 43 | <exclusion> | ||
| 44 | <groupId>org.slf4j</groupId> | ||
| 45 | <artifactId>slf4j-api</artifactId> | ||
| 46 | </exclusion> | ||
| 47 | </exclusions> | ||
| 48 | </dependency> | ||
| 49 | </dependencies> | ||
| 50 | |||
| 51 | <build> | ||
| 52 | <plugins> | ||
| 53 | <plugin> | ||
| 54 | <artifactId>maven-assembly-plugin</artifactId> | ||
| 55 | <executions> | ||
| 56 | <execution> | ||
| 57 | <phase>package</phase> | ||
| 58 | <goals> | ||
| 59 | <goal>single</goal> | ||
| 60 | </goals> | ||
| 61 | </execution> | ||
| 62 | </executions> | ||
| 63 | <configuration> | ||
| 64 | <descriptorRefs> | ||
| 65 | <descriptorRef>jar-with-dependencies</descriptorRef> | ||
| 66 | </descriptorRefs> | ||
| 67 | <appendAssemblyId>false</appendAssemblyId> | ||
| 68 | </configuration> | ||
| 69 | </plugin> | ||
| 70 | </plugins> | ||
| 71 | </build> | ||
| 72 | <profiles> | ||
| 73 | <profile> | ||
| 74 | <id>exclude-native-transport-deps</id> | ||
| 75 | <dependencies> | ||
| 76 | <dependency> | ||
| 77 | <groupId>org.apache.qpid</groupId> | ||
| 78 | <artifactId>qpid-jms-client</artifactId> | ||
| 79 | <exclusions> | ||
| 80 | <exclusion> | ||
| 81 | <groupId>io.netty</groupId> | ||
| 82 | <artifactId>netty-transport-classes-epoll</artifactId> | ||
| 83 | </exclusion> | ||
| 84 | <exclusion> | ||
| 85 | <groupId>io.netty</groupId> | ||
| 86 | <artifactId>netty-transport-native-epoll</artifactId> | ||
| 87 | </exclusion> | ||
| 88 | <exclusion> | ||
| 89 | <groupId>io.netty</groupId> | ||
| 90 | <artifactId>netty-transport-classes-kqueue</artifactId> | ||
| 91 | </exclusion> | ||
| 92 | <exclusion> | ||
| 93 | <groupId>io.netty</groupId> | ||
| 94 | <artifactId>netty-transport-native-kqueue</artifactId> | ||
| 95 | </exclusion> | ||
| 96 | </exclusions> | ||
| 97 | </dependency> | ||
| 98 | </dependencies> | ||
| 99 | </profile> | ||
| 100 | </profiles> | ||
| 101 | </project> | ||
| ... | \ No newline at end of file | ... | \ No newline at end of file |
| 1 | package com.rs2i.camunda.exporter; | ||
| 2 | |||
| 3 | import io.camunda.zeebe.exporter.api.Exporter; | ||
| 4 | import io.camunda.zeebe.exporter.api.context.Context; | ||
| 5 | import io.camunda.zeebe.exporter.api.context.Controller; | ||
| 6 | import io.camunda.zeebe.protocol.record.Record; | ||
| 7 | import io.camunda.zeebe.protocol.record.RecordType; | ||
| 8 | import io.camunda.zeebe.protocol.record.value.*; | ||
| 9 | import org.slf4j.Logger; | ||
| 10 | import java.util.Arrays; | ||
| 11 | import java.util.HashMap; | ||
| 12 | import java.util.List; | ||
| 13 | import java.util.Map; | ||
| 14 | |||
| 15 | public class RS2iExporter implements Exporter { | ||
| 16 | |||
| 17 | public static final String CREATED_INTENT = "CREATED"; | ||
| 18 | public static final String COMPLETED_INTENT = "COMPLETED"; | ||
| 19 | public static final String ELEMENT_ACTIVATED_INTENT = "ELEMENT_ACTIVATED"; | ||
| 20 | public static final String ELEMENT_COMPLETED_INTENT = "ELEMENT_COMPLETED"; | ||
| 21 | public static final String USER_TASK_JOB_TYPE = "io.camunda.zeebe:userTask"; | ||
| 22 | public static final String CANDIDATE_GROUPS_JOB_HEADER = "io.camunda.zeebe:candidateGroups"; | ||
| 23 | public static final String FORM_KEY_JOB_HEADER = "io.camunda.zeebe:formKey"; | ||
| 24 | public static final List<BpmnElementType> ACTIVATED_ELEMENT_TYPES = Arrays.asList( | ||
| 25 | BpmnElementType.USER_TASK, | ||
| 26 | BpmnElementType.SERVICE_TASK, | ||
| 27 | BpmnElementType.BUSINESS_RULE_TASK, | ||
| 28 | //BpmnElementType.MANUAL_TASK, | ||
| 29 | BpmnElementType.RECEIVE_TASK, | ||
| 30 | BpmnElementType.SCRIPT_TASK, | ||
| 31 | BpmnElementType.SEND_TASK, | ||
| 32 | BpmnElementType.END_EVENT | ||
| 33 | ); | ||
| 34 | |||
| 35 | private Controller controller; | ||
| 36 | private Logger logger; | ||
| 37 | |||
| 38 | public void configure(Context context) throws Exception { | ||
| 39 | this.logger = context.getLogger(); | ||
| 40 | } | ||
| 41 | |||
| 42 | public void open(Controller controller) { | ||
| 43 | this.controller = controller; | ||
| 44 | } | ||
| 45 | |||
| 46 | public void close() { | ||
| 47 | } | ||
| 48 | |||
| 49 | public void export(Record<?> record) { | ||
| 50 | if (record != null && RecordType.EVENT.equals(record.getRecordType()) && record.getValueType() != null) { | ||
| 51 | Map<String, Object> event = new HashMap<>(); | ||
| 52 | logger.info("\n\n---------------------------------------------------------------------------------------------------------"); | ||
| 53 | logger.info("RECORD :: ", record.toJson().toString()); | ||
| 54 | switch (record.getValueType()) { | ||
| 55 | // Event : process creation | ||
| 56 | case PROCESS_INSTANCE_CREATION: | ||
| 57 | ProcessInstanceCreationRecordValue processInstanceCreationRecordValue = (ProcessInstanceCreationRecordValue) record.getValue(); | ||
| 58 | event.put("instanceId", processInstanceCreationRecordValue.getProcessInstanceKey()+""); | ||
| 59 | event.put("bpmId", processInstanceCreationRecordValue.getBpmnProcessId()); | ||
| 60 | event.put("bpmVersion", processInstanceCreationRecordValue.getProcessDefinitionKey()+""); | ||
| 61 | logger.info("TYPE: 'PROCESS_INSTANCE_CREATION'"); | ||
| 62 | logger.info("PROCESS VARIABLES : ", processInstanceCreationRecordValue.getVariables().toString()); | ||
| 63 | logger.info("EVENT : ", event.toString()); | ||
| 64 | break; | ||
| 65 | // Event : process progression | ||
| 66 | case PROCESS_INSTANCE: | ||
| 67 | ProcessInstanceRecordValue processInstanceRecordValue = (ProcessInstanceRecordValue) record.getValue(); | ||
| 68 | if (processInstanceRecordValue.getBpmnElementType() != null) { | ||
| 69 | switch (record.getIntent().name()) { | ||
| 70 | case ELEMENT_ACTIVATED_INTENT: | ||
| 71 | if (ACTIVATED_ELEMENT_TYPES.contains(processInstanceRecordValue.getBpmnElementType())) { | ||
| 72 | event.put("instanceId", processInstanceRecordValue.getProcessInstanceKey()+""); | ||
| 73 | event.put("bpmId", processInstanceRecordValue.getBpmnProcessId()); | ||
| 74 | event.put("bpmVersion", processInstanceRecordValue.getProcessDefinitionKey()+""); | ||
| 75 | event.put("currentStep", processInstanceRecordValue.getElementId()); | ||
| 76 | logger.info("TYPE: 'PROCESS_INSTANCE'.'ELEMENT_ACTIVATED_INTENT'"); | ||
| 77 | logger.info("EVENT : ", event.toString()); | ||
| 78 | } | ||
| 79 | break; | ||
| 80 | case ELEMENT_COMPLETED_INTENT: | ||
| 81 | if (ACTIVATED_ELEMENT_TYPES.contains(processInstanceRecordValue.getBpmnElementType())) { | ||
| 82 | event.put("instanceId", processInstanceRecordValue.getProcessInstanceKey()+""); | ||
| 83 | event.put("bpmId", processInstanceRecordValue.getBpmnProcessId()); | ||
| 84 | event.put("bpmVersion", processInstanceRecordValue.getProcessDefinitionKey()+""); | ||
| 85 | event.put("activeJobKey", ""); | ||
| 86 | logger.info("TYPE: 'PROCESS_INSTANCE'.'ELEMENT_COMPLETED_INTENT'"); | ||
| 87 | logger.info("EVENT : ", event.toString()); | ||
| 88 | } | ||
| 89 | break; | ||
| 90 | } | ||
| 91 | } | ||
| 92 | break; | ||
| 93 | // Event : process jobs | ||
| 94 | case JOB: | ||
| 95 | JobRecordValue jobRecordValue = (JobRecordValue) record.getValue(); | ||
| 96 | switch(record.getIntent().name()) { | ||
| 97 | case CREATED_INTENT: | ||
| 98 | if (USER_TASK_JOB_TYPE.equals(jobRecordValue.getType())) { | ||
| 99 | event.put("instanceId", jobRecordValue.getProcessInstanceKey()+""); | ||
| 100 | event.put("bpmId", jobRecordValue.getBpmnProcessId()); | ||
| 101 | event.put("bpmVersion", jobRecordValue.getProcessDefinitionKey()+""); | ||
| 102 | event.put("activeJobKey", record.getKey()); | ||
| 103 | logger.info("TYPE: 'JOB'.'CREATED_INTENT'.'USER_TASK_JOB_TYPE'"); | ||
| 104 | logger.info("EVENT : ", event.toString()); | ||
| 105 | } | ||
| 106 | } | ||
| 107 | break; | ||
| 108 | // Event : process incident | ||
| 109 | case INCIDENT: | ||
| 110 | IncidentRecordValue incidentRecordValue = (IncidentRecordValue) record.getValue(); | ||
| 111 | event.put("instanceId", incidentRecordValue.getProcessInstanceKey()+""); | ||
| 112 | event.put("bpmId", incidentRecordValue.getBpmnProcessId()); | ||
| 113 | event.put("bpmVersion", incidentRecordValue.getProcessDefinitionKey()+""); | ||
| 114 | event.put("errorMessage", incidentRecordValue.getErrorMessage()); | ||
| 115 | logger.info("TYPE: 'INCIDENT'"); | ||
| 116 | logger.info("EVENT : ", event.toString()); | ||
| 117 | break; | ||
| 118 | default: | ||
| 119 | break; | ||
| 120 | } | ||
| 121 | logger.info("---------------------------------------------------------------------------------------------------------\n\n"); | ||
| 122 | } | ||
| 123 | |||
| 124 | this.controller.updateLastExportedRecordPosition(record.getPosition()); | ||
| 125 | } | ||
| 126 | |||
| 127 | } |
src/main/resources/application.properties
0 → 100644
File mode changed
target/classes/META-INF/MANIFEST.MF
0 → 100644
| 1 | <?xml version="1.0" encoding="UTF-8"?> | ||
| 2 | <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 https://maven.apache.org/xsd/maven-4.0.0.xsd"> | ||
| 3 | <modelVersion>4.0.0</modelVersion> | ||
| 4 | <groupId>com.rs2i.camunda.exporter</groupId> | ||
| 5 | <artifactId>rs2i-exporter</artifactId> | ||
| 6 | <packaging>jar</packaging> | ||
| 7 | <version>0.0.1-SNAPSHOT</version> | ||
| 8 | <name>rs2i-exporter</name> | ||
| 9 | <description>Learning camunda RS2i Exporter</description> | ||
| 10 | <properties> | ||
| 11 | <zeebe.version>8.0.5</zeebe.version> | ||
| 12 | <jar.fileName>${project.artifactId}</jar.fileName> | ||
| 13 | <qpid.jms.version>2.1.0</qpid.jms.version> | ||
| 14 | <lombok.version>1.18.24</lombok.version> | ||
| 15 | <maven.compiler.source>1.8</maven.compiler.source> | ||
| 16 | <maven.compiler.target>1.8</maven.compiler.target> | ||
| 17 | <jar.fileName>${project.artifactId}</jar.fileName> | ||
| 18 | <org.json.version>20180130</org.json.version> | ||
| 19 | </properties> | ||
| 20 | <dependencies> | ||
| 21 | <dependency> | ||
| 22 | <groupId>org.projectlombok</groupId> | ||
| 23 | <artifactId>lombok</artifactId> | ||
| 24 | <version>${lombok.version}</version> | ||
| 25 | <scope>provided</scope> | ||
| 26 | </dependency> | ||
| 27 | <dependency> | ||
| 28 | <groupId>io.camunda</groupId> | ||
| 29 | <artifactId>zeebe-exporter-api</artifactId> | ||
| 30 | <version>${zeebe.version}</version> | ||
| 31 | <scope>provided</scope> | ||
| 32 | </dependency> | ||
| 33 | <dependency> | ||
| 34 | <groupId>org.json</groupId> | ||
| 35 | <artifactId>json</artifactId> | ||
| 36 | <version>${org.json.version}</version> | ||
| 37 | </dependency> | ||
| 38 | <dependency> | ||
| 39 | <groupId>org.apache.qpid</groupId> | ||
| 40 | <artifactId>qpid-jms-client</artifactId> | ||
| 41 | <version>${qpid.jms.version}</version> | ||
| 42 | <exclusions> | ||
| 43 | <exclusion> | ||
| 44 | <groupId>org.slf4j</groupId> | ||
| 45 | <artifactId>slf4j-api</artifactId> | ||
| 46 | </exclusion> | ||
| 47 | </exclusions> | ||
| 48 | </dependency> | ||
| 49 | </dependencies> | ||
| 50 | |||
| 51 | <build> | ||
| 52 | <plugins> | ||
| 53 | <plugin> | ||
| 54 | <artifactId>maven-assembly-plugin</artifactId> | ||
| 55 | <executions> | ||
| 56 | <execution> | ||
| 57 | <phase>package</phase> | ||
| 58 | <goals> | ||
| 59 | <goal>single</goal> | ||
| 60 | </goals> | ||
| 61 | </execution> | ||
| 62 | </executions> | ||
| 63 | <configuration> | ||
| 64 | <descriptorRefs> | ||
| 65 | <descriptorRef>jar-with-dependencies</descriptorRef> | ||
| 66 | </descriptorRefs> | ||
| 67 | <appendAssemblyId>false</appendAssemblyId> | ||
| 68 | </configuration> | ||
| 69 | </plugin> | ||
| 70 | </plugins> | ||
| 71 | </build> | ||
| 72 | <profiles> | ||
| 73 | <profile> | ||
| 74 | <id>exclude-native-transport-deps</id> | ||
| 75 | <dependencies> | ||
| 76 | <dependency> | ||
| 77 | <groupId>org.apache.qpid</groupId> | ||
| 78 | <artifactId>qpid-jms-client</artifactId> | ||
| 79 | <exclusions> | ||
| 80 | <exclusion> | ||
| 81 | <groupId>io.netty</groupId> | ||
| 82 | <artifactId>netty-transport-classes-epoll</artifactId> | ||
| 83 | </exclusion> | ||
| 84 | <exclusion> | ||
| 85 | <groupId>io.netty</groupId> | ||
| 86 | <artifactId>netty-transport-native-epoll</artifactId> | ||
| 87 | </exclusion> | ||
| 88 | <exclusion> | ||
| 89 | <groupId>io.netty</groupId> | ||
| 90 | <artifactId>netty-transport-classes-kqueue</artifactId> | ||
| 91 | </exclusion> | ||
| 92 | <exclusion> | ||
| 93 | <groupId>io.netty</groupId> | ||
| 94 | <artifactId>netty-transport-native-kqueue</artifactId> | ||
| 95 | </exclusion> | ||
| 96 | </exclusions> | ||
| 97 | </dependency> | ||
| 98 | </dependencies> | ||
| 99 | </profile> | ||
| 100 | </profiles> | ||
| 101 | </project> | ||
| ... | \ No newline at end of file | ... | \ No newline at end of file |
target/classes/application.properties
0 → 100644
File mode changed
No preview for this file type
No preview for this file type
target/maven-archiver/pom.properties
0 → 100644
| 1 | C:\produits\bpm\Formation_camunda\rs2i-exporter\src\main\java\com\rs2i\camunda\exporter\RS2iExporter.java |
target/rs2i-exporter-0.0.1-SNAPSHOT.jar
0 → 100644
No preview for this file type
-
Please register or sign in to post a comment