Feature/decision polling

camunda-kafka-model/src/main/java/de/viadee/camunda/kafka/event/ActivityInstanceEvent.java

@@ -6,10 +6,10 @@
  * ActivityInstanceEvent class.
  * </p>
  *
- * 
- * 
+ *
+ *
  * @author viadee
- * 
+ *
  * @version $Id: $Id
  */
 public class ActivityInstanceEvent extends ScopeInstanceEvent {

camunda-kafka-model/src/main/java/de/viadee/camunda/kafka/event/DecisionDefinitionEvent.java

@@ -0,0 +1,88 @@
+package de.viadee.camunda.kafka.event;
+
+import java.util.Date;
+
+public class DecisionDefinitionEvent extends DeploymentEvent {
+
+    private String key;
+    private String category;
+    private Integer version;
+    private String resource;
+    private String decisionRequirementsDefinitionId;
+    private String decisionRequirementsDefinitionKey;
+    private Integer historyTimeToLive;
+    private String versionTag;
+    private String xml;
+
+    public String getKey() {
+        return key;
+    }
+
+    public void setKey(String key) {
+        this.key = key;
+    }
+
+    public String getCategory() {
+        return category;
+    }
+
+    public void setCategory(String category) {
+        this.category = category;
+    }
+
+    public Integer getVersion() {
+        return version;
+    }
+
+    public void setVersion(Integer version) {
+        this.version = version;
+    }
+
+    public String getResource() {
+        return resource;
+    }
+
+    public void setResource(String resource) {
+        this.resource = resource;
+    }
+
+    public String getDecisionRequirementsDefinitionId() {
+        return decisionRequirementsDefinitionId;
+    }
+
+    public void setDecisionRequirementsDefinitionId(String decisionRequirementsDefinitionId) {
+        this.decisionRequirementsDefinitionId = decisionRequirementsDefinitionId;
+    }
+
+    public String getDecisionRequirementsDefinitionKey() {
+        return decisionRequirementsDefinitionKey;
+    }
+
+    public void setDecisionRequirementsDefinitionKey(String decisionRequirementsDefinitionKey) {
+        this.decisionRequirementsDefinitionKey = decisionRequirementsDefinitionKey;
+    }
+
+    public Integer getHistoryTimeToLive() {
+        return historyTimeToLive;
+    }
+
+    public void setHistoryTimeToLive(Integer historyTimeToLive) {
+        this.historyTimeToLive = historyTimeToLive;
+    }
+
+    public String getVersionTag() {
+        return versionTag;
+    }
+
+    public void setVersionTag(String versionTag) {
+        this.versionTag = versionTag;
+    }
+
+    public String getXml() {
+        return xml;
+    }
+
+    public void setXml(String xml) {
+        this.xml = xml;
+    }
+}

camunda-kafka-model/src/main/java/de/viadee/camunda/kafka/event/DecisionInstanceEvent.java

@@ -0,0 +1,164 @@
+package de.viadee.camunda.kafka.event;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * <p>
+ * DecisionInstanceEvent class.
+ * </p>
+ *
+ *
+ *
+ * @author viadee
+ *
+ * @version $Id: $Id
+ */
+public class DecisionInstanceEvent extends HistoryEvent {
+
+    private String decisionDefinitionId;
+    private String decisionDefinitionKey;
+    private String decisionDefinitionName;
+    private Date evaluationTime;
+    private Date removalTime;
+    private String activityId;
+    private String activityInstanceId;
+    private String tenantId;
+    private String userId;
+    private String rootDecisionInstanceId;
+    private String rootProcessInstanceId;
+    private String decisionRequirementsDefinitionId;
+    private String decisionRequirementsDefinitionKey;
+    private Double collectResultValue;
+    private List<DecisionInstanceInputEvent> inputs;
+    private List<DecisionInstanceOutputEvent> outputs;
+
+    public String getDecisionDefinitionId() {
+        return decisionDefinitionId;
+    }
+
+    public void setDecisionDefinitionId(String decisionDefinitionId) {
+        this.decisionDefinitionId = decisionDefinitionId;
+    }
+
+    public String getDecisionDefinitionKey() {
+        return decisionDefinitionKey;
+    }
+
+    public void setDecisionDefinitionKey(String decisionDefinitionKey) {
+        this.decisionDefinitionKey = decisionDefinitionKey;
+    }
+
+    public String getDecisionDefinitionName() {
+        return decisionDefinitionName;
+    }
+
+    public void setDecisionDefinitionName(String decisionDefinitionName) {
+        this.decisionDefinitionName = decisionDefinitionName;
+    }
+
+    public Date getEvaluationTime() {
+        return evaluationTime;
+    }
+
+    public void setEvaluationTime(Date evaluationTime) {
+        this.evaluationTime = evaluationTime;
+    }
+
+    public Date getRemovalTime() {
+        return removalTime;
+    }
+
+    public void setRemovalTime(Date removalTime) {
+        this.removalTime = removalTime;
+    }
+
+    public String getActivityId() {
+        return activityId;
+    }
+
+    public void setActivityId(String activityId) {
+        this.activityId = activityId;
+    }
+
+    public String getActivityInstanceId() {
+        return activityInstanceId;
+    }
+
+    public void setActivityInstanceId(String activityInstanceId) {
+        this.activityInstanceId = activityInstanceId;
+    }
+
+    public String getTenantId() {
+        return tenantId;
+    }
+
+    public void setTenantId(String tenantId) {
+        this.tenantId = tenantId;
+    }
+
+    public String getUserId() {
+        return userId;
+    }
+
+    public void setUserId(String userId) {
+        this.userId = userId;
+    }
+
+    public String getRootDecisionInstanceId() {
+        return rootDecisionInstanceId;
+    }
+
+    public void setRootDecisionInstanceId(String rootDecisionInstanceId) {
+        this.rootDecisionInstanceId = rootDecisionInstanceId;
+    }
+
+    public String getRootProcessInstanceId() {
+        return rootProcessInstanceId;
+    }
+
+    public void setRootProcessInstanceId(String rootProcessInstanceId) {
+        this.rootProcessInstanceId = rootProcessInstanceId;
+    }
+
+    public String getDecisionRequirementsDefinitionId() {
+        return decisionRequirementsDefinitionId;
+    }
+
+    public void setDecisionRequirementsDefinitionId(String decisionRequirementsDefinitionId) {
+        this.decisionRequirementsDefinitionId = decisionRequirementsDefinitionId;
+    }
+
+    public String getDecisionRequirementsDefinitionKey() {
+        return decisionRequirementsDefinitionKey;
+    }
+
+    public void setDecisionRequirementsDefinitionKey(String decisionRequirementsDefinitionKey) {
+        this.decisionRequirementsDefinitionKey = decisionRequirementsDefinitionKey;
+    }
+
+    public Double getCollectResultValue() {
+        return collectResultValue;
+    }
+
+    public void setCollectResultValue(Double collectResultValue) {
+        this.collectResultValue = collectResultValue;
+    }
+
+    public List<DecisionInstanceInputEvent> getInputs() {
+        return inputs;
+    }
+
+    public void setInputs(List<DecisionInstanceInputEvent> inputs) {
+        this.inputs = inputs;
+    }
+
+    public List<DecisionInstanceOutputEvent> getOutputs() {
+        return outputs;
+    }
+
+    public void setOutputs(List<DecisionInstanceOutputEvent> outputs) {
+        this.outputs = outputs;
+    }
+
+}

camunda-kafka-model/src/main/java/de/viadee/camunda/kafka/event/DecisionInstanceInputEvent.java

@@ -0,0 +1,107 @@
+package de.viadee.camunda.kafka.event;
+
+import java.util.Date;
+import java.util.Map;
+
+public class DecisionInstanceInputEvent {
+
+    private String id;
+    private String decisionInstanceId;
+    private String clauseId;
+    private String clauseName;
+    private String errorMessage;
+    private String type;
+    private Date createTime;
+    private Date removalTime;
+    private String rootProcessInstanceId;
+    private String value;
+    private Map<String, Object> valueInfo;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getDecisionInstanceId() {
+        return decisionInstanceId;
+    }
+
+    public void setDecisionInstanceId(String decisionInstanceId) {
+        this.decisionInstanceId = decisionInstanceId;
+    }
+
+    public String getClauseId() {
+        return clauseId;
+    }
+
+    public void setClauseId(String clauseId) {
+        this.clauseId = clauseId;
+    }
+
+    public String getClauseName() {
+        return clauseName;
+    }
+
+    public void setClauseName(String clauseName) {
+        this.clauseName = clauseName;
+    }
+
+    public String getErrorMessage() {
+        return errorMessage;
+    }
+
+    public void setErrorMessage(String errorMessage) {
+        this.errorMessage = errorMessage;
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    public Date getRemovalTime() {
+        return removalTime;
+    }
+
+    public void setRemovalTime(Date removalTime) {
+        this.removalTime = removalTime;
+    }
+
+    public String getRootProcessInstanceId() {
+        return rootProcessInstanceId;
+    }
+
+    public void setRootProcessInstanceId(String rootProcessInstanceId) {
+        this.rootProcessInstanceId = rootProcessInstanceId;
+    }
+
+    public String getValue() {
+        return value;
+    }
+
+    public void setValue(String value) {
+        this.value = value;
+    }
+
+    public Map<String, Object> getValueInfo() {
+        return valueInfo;
+    }
+
+    public void setValueInfo(Map<String, Object> valueInfo) {
+        this.valueInfo = valueInfo;
+    }
+}