Loading src/main/java/com/inteligr8/activiti/mq/MqDeploymentEventListener.java +2 −2 Original line number Diff line number Diff line Loading @@ -73,9 +73,9 @@ public class MqDeploymentEventListener implements ActivitiEntityEventListener<De try { Set<String> executionIds = this.subscriptionService.cancelAllOtherVersions(procDefId); if (this.logger.isDebugEnabled()) { this.logger.debug("Subscription executions ended early: {}: {}", procDefId, executionIds); this.logger.debug("Subscription starter executions ended early: {}: {}", procDefId, executionIds); } else { this.logger.info("Subscriptions ended early: {}: {}", procDefId, executionIds.size()); this.logger.info("Subscriptions starter ended early: {}: {}", procDefId, executionIds.size()); } } catch (Exception e) { this.logger.error("The subscriptions could not be cancelled: " + procDefId, e); Loading src/main/java/com/inteligr8/activiti/mq/MqSubscribeLooper.java +7 −1 Original line number Diff line number Diff line Loading @@ -78,9 +78,15 @@ public class MqSubscribeLooper { } private void loop(String tenantId, String processDefinitionId) { ProcessDefinition procDef = this.services.getRepositoryService().getProcessDefinition(processDefinitionId); if (procDef == null) throw new IllegalArgumentException("The process definition does not exist: " + processDefinitionId); if (procDef.isSuspended()) throw new IllegalStateException("The process definition is suspended: " + processDefinitionId); ServiceTask task = this.registry.findMqStartSubscribeTask(processDefinitionId); if (task == null) throw new IllegalArgumentException(); throw new IllegalArgumentException("The process definition does not qualify for MQ subscription looping: " + processDefinitionId); int concurrency = this.determineConcurrency(task); this.logger.debug("Process definition MQ subscription task is configured for concurrency: {}: {}", processDefinitionId, concurrency); Loading Loading
src/main/java/com/inteligr8/activiti/mq/MqDeploymentEventListener.java +2 −2 Original line number Diff line number Diff line Loading @@ -73,9 +73,9 @@ public class MqDeploymentEventListener implements ActivitiEntityEventListener<De try { Set<String> executionIds = this.subscriptionService.cancelAllOtherVersions(procDefId); if (this.logger.isDebugEnabled()) { this.logger.debug("Subscription executions ended early: {}: {}", procDefId, executionIds); this.logger.debug("Subscription starter executions ended early: {}: {}", procDefId, executionIds); } else { this.logger.info("Subscriptions ended early: {}: {}", procDefId, executionIds.size()); this.logger.info("Subscriptions starter ended early: {}: {}", procDefId, executionIds.size()); } } catch (Exception e) { this.logger.error("The subscriptions could not be cancelled: " + procDefId, e); Loading
src/main/java/com/inteligr8/activiti/mq/MqSubscribeLooper.java +7 −1 Original line number Diff line number Diff line Loading @@ -78,9 +78,15 @@ public class MqSubscribeLooper { } private void loop(String tenantId, String processDefinitionId) { ProcessDefinition procDef = this.services.getRepositoryService().getProcessDefinition(processDefinitionId); if (procDef == null) throw new IllegalArgumentException("The process definition does not exist: " + processDefinitionId); if (procDef.isSuspended()) throw new IllegalStateException("The process definition is suspended: " + processDefinitionId); ServiceTask task = this.registry.findMqStartSubscribeTask(processDefinitionId); if (task == null) throw new IllegalArgumentException(); throw new IllegalArgumentException("The process definition does not qualify for MQ subscription looping: " + processDefinitionId); int concurrency = this.determineConcurrency(task); this.logger.debug("Process definition MQ subscription task is configured for concurrency: {}: {}", processDefinitionId, concurrency); Loading