inteligr8/mq-activiti-ext
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

remove process scope field from publish task

Browse Source
This commit is contained in:
Brian Long
2025-02-19 11:58:30 -05:00
parent c11e6c7610
commit cc14a59959
3 changed files with 20 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/activiti/MQ.json
View File

@@ -3087,8 +3087,7 @@
"mq_prioritypackage",
"mq_payloadpackage",
"mq_replyQueueNamepackage",
"mq_statusQueueNamepackage",
"mq_metadataProcessScopepackage"
"mq_statusQueueNamepackage"
],
"hiddenPropertyPackages": [
"multiinstance_typepackage",

17
src/main/java/com/inteligr8/activiti/mq/MqDelegateExecution.java
View File

@@ -54,12 +54,7 @@ public class MqDelegateExecution {
}
protected void setMqVariable(String varName, Object value) {
varName = this.formulateVariableName(varName);
if (this.task.doWriteToProcessScope()) {
this.execution.setVariable(varName, value);
} else {
this.execution.setVariableLocal(varName, value);
}
this.execution.setVariable(varName, value);
}
public String formulateVariableName(String varName) {
@@ -67,11 +62,19 @@ public class MqDelegateExecution {
varName += "_" + this.getMessageNameFromModel();
return varName;
}
/**
* Always pull from the process scope.
* @param correlationId
*/
public String getCorrelationId() {
return this.execution.getVariable(this.formulateVariableName(Constants.VARIABLE_CORRELATION_ID), String.class);
}
/**
* Always set at process scope.
* @param correlationId
*/
public void setCorrelationId(String correlationId) {
this.execution.setVariable(this.formulateVariableName(Constants.VARIABLE_CORRELATION_ID), correlationId);
}

9
src/main/java/com/inteligr8/activiti/mq/MqSubscribeDelegateExecution.java
View File

@@ -8,6 +8,15 @@ public class MqSubscribeDelegateExecution extends MqDelegateExecution {
public MqSubscribeDelegateExecution(ProcessEngine services, MqServiceTaskService msts, DelegateExecution execution) {
super(services, msts, execution);
}
protected void setMqVariable(String varName, Object value) {
varName = this.formulateVariableName(varName);
if (this.task.doWriteToProcessScope()) {
this.execution.setVariable(varName, value);
} else {
this.execution.setVariableLocal(varName, value);
}
}
public Integer getConcurrencyFromModel() {
return this.getFieldValueFromModel(Constants.FIELD_CONCURRENCY, Integer.class);