Loading src/main/java/com/inteligr8/activiti/mq/ProcessDefinitionRegistry.java +8 −0 Original line number Diff line number Diff line package com.inteligr8.activiti.mq; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.regex.Matcher; import java.util.regex.Pattern; import javax.annotation.PostConstruct; import org.activiti.bpmn.model.BpmnModel; import org.activiti.bpmn.model.FlowElement; import org.activiti.bpmn.model.SequenceFlow; Loading Loading @@ -35,6 +38,11 @@ public class ProcessDefinitionRegistry { private Map<String, ServiceTask> processDefinitionMqSubscribeTasks; @PostConstruct private void init() { this.processDefinitionMqSubscribeTasks = new HashMap<>(); } public synchronized boolean isMqStart(String processDefinitionId) { if (this.processDefinitionMqSubscribeTasks.containsKey(processDefinitionId)) { return this.processDefinitionMqSubscribeTasks.get(processDefinitionId) != null; Loading Loading
src/main/java/com/inteligr8/activiti/mq/ProcessDefinitionRegistry.java +8 −0 Original line number Diff line number Diff line package com.inteligr8.activiti.mq; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.regex.Matcher; import java.util.regex.Pattern; import javax.annotation.PostConstruct; import org.activiti.bpmn.model.BpmnModel; import org.activiti.bpmn.model.FlowElement; import org.activiti.bpmn.model.SequenceFlow; Loading Loading @@ -35,6 +38,11 @@ public class ProcessDefinitionRegistry { private Map<String, ServiceTask> processDefinitionMqSubscribeTasks; @PostConstruct private void init() { this.processDefinitionMqSubscribeTasks = new HashMap<>(); } public synchronized boolean isMqStart(String processDefinitionId) { if (this.processDefinitionMqSubscribeTasks.containsKey(processDefinitionId)) { return this.processDefinitionMqSubscribeTasks.get(processDefinitionId) != null; Loading