Problems getting my Message Task to correlate - please help

2,791 views

Skip to first unread message

Christopher Campbell

unread,

Jul 28, 2014, 6:13:21 AM7/28/14

to camunda-...@googlegroups.com

Hi there Camunda Users and Contributors,

Up front many thanks in advance for any help provided....

I am having trouble getting my message task delegate to correlate.(Detail below: link to camunda share, camunda standalone error logs, camunda cockpit screenshot)

The process instantiates fine via REST API and waits at the "Submit Order" User Task.

Completing the "Submit Order" User Task via REST API fails.

Here are the details of the JSON post request:

URL: http://localhost:8080/engine-rest/task/7c8f67f1-1638-11e4-8ae3-bdeec683d5e6/submit-form

application/json Content: {"variables":{"orderStatus":{"value":"submitted"}}}

Note: Everything works fine in a previous version of the Model without the message task and the additional participant.

My Delegate code is as follows:

public class OrderMessengerDelegate implements JavaDelegate {

private Expression messageName;

private Expression businessKey;

public static final boolean _DEBUG=true;

public Expression getBusinessKey() {

return businessKey;

}

public void setBusinessKey(Expression businessKey) {

this.businessKey = businessKey;

}

public Expression getMessage() {

return messageName;

}

public void setMessage(Expression message) {

this.messageName = message;

}

@Override

public void execute(DelegateExecution execution) throws Exception {

String orderNumber = (String) execution.getVariableLocal("orderNumber");

String orderId = (String) execution.getVariableLocal("orderId");

String orderStatus = (String) execution.getVariableLocal("orderStatus");

String businessKey = ((ExecutionEntity) execution).getBusinessKey();

String processInstanceId = ((ExecutionEntity) execution).getProcessInstanceId();

String messageName = (String) this.messageName.getValue(execution);

PilotUtils.debug(this.getClass(), PilotUtils.SPACER+" Executing OrderMessengerDelegate "

+ "( orderNumer="+orderNumber

+ " || orderId="+orderId

+ " || orderStatus="+orderStatus

+ " || businessKey="+businessKey

+ " || messageName="+messageName

+ " || processInstanceId="+processInstanceId

+ ")");

Variable orderNumberVariable = new Variable("orderNumber","String",orderNumber);

Variable orderIdVariable = new Variable("orderId","String",orderId);

Variable orderStatusVariable = new Variable("orderStatus","String",orderStatus);

* Do the work

// I use this as input for correlateMessage() which is normally commented out and only for testing

HashMap<String,Object> correlationKeys = new HashMap<String,Object>();

correlationKeys.put(orderNumberVariable.getName(), orderNumberVariable);

correlationKeys.put(orderIdVariable.getName(), orderIdVariable);

// I use this as input for correlateMessage() which is normally commented out and only for testing

HashMap<String,Object> processVariables = new HashMap<String,Object>();

processVariables.put(orderNumberVariable.getName(), orderNumberVariable);

processVariables.put(orderIdVariable.getName(), orderIdVariable);

processVariables.put(orderStatusVariable.getName(), orderStatusVariable);

execution.getProcessEngineServices().getRuntimeService().createMessageCorrelation(messageName)

.setVariable("orderNumber", orderNumber)

.setVariable("orderId",orderId)

.setVariable("orderStatus", orderStatus)

.processInstanceBusinessKey(businessKey)

// .processInstanceId(processInstanceId) //I tried with the instance Id and without

.correlate();

* Just to test if it would work like this.

// execution.getProcessEngineServices().getRuntimeService().correlateMessage(messageName, businessKey, processVariables);

}

Here is the PROCESS which is running in camunda standalone 7.2 alpha3 (P.S. have the same trouble in the standalone 7.1 final):

http://camunda.org/share/#/process/350589da-59ee-4c32-9706-036596809c86

Here is the ERROR MESSAGE:

==> tcat3/server/apache-tomcat-7.0.50/logs/catalina.2014-07-28.log <==

Jul 28, 2014 11:21:23 AM com.camsolute.code.pilot.bpmn.delegates.OrderMessengerDelegate debug

INFO: -------- Executing OrderMessengerDelegate ( orderNumer=1234567890 || orderId=423 || orderStatus=submitted || businessKey=Spanky || messageName=ordershippedcolab || processInstanceId=7c8f67e5-1638-11e4-8ae3-bdeec683d5e6)

Jul 28, 2014 11:21:23 AM org.camunda.bpm.engine.impl.interceptor.CommandContext exception

SEVERE: masked exception in command context. for root cause, see below as it will be rethrown later.

org.camunda.bpm.engine.MismatchingMessageCorrelationException: Cannot correlate message ordershippedcolab: No process definition or execution matches the parameters

at org.camunda.bpm.engine.impl.cmd.CorrelateMessageCmd.execute(CorrelateMessageCmd.java:75)

at org.camunda.bpm.engine.impl.cmd.CorrelateMessageCmd.execute(CorrelateMessageCmd.java:35)

at org.camunda.bpm.engine.impl.interceptor.CommandExecutorImpl.execute(CommandExecutorImpl.java:24)

at org.camunda.bpm.engine.impl.interceptor.CommandContextInterceptor.execute(CommandContextInterceptor.java:90)

at org.camunda.bpm.engine.impl.interceptor.LogInterceptor.execute(LogInterceptor.java:32)

at org.camunda.bpm.engine.impl.RuntimeServiceImpl.correlateMessage(RuntimeServiceImpl.java:318)

at com.camsolute.code.pilot.bpmn.delegates.OrderMessengerDelegate.execute(OrderMessengerDelegate.java:93)

at org.camunda.bpm.engine.impl.delegate.JavaDelegateInvocation.invoke(JavaDelegateInvocation.java:34)

at org.camunda.bpm.engine.impl.delegate.DelegateInvocation.proceed(DelegateInvocation.java:39)

at org.camunda.bpm.engine.impl.delegate.DefaultDelegateInterceptor.handleInvocation(DefaultDelegateInterceptor.java:42)

at org.camunda.bpm.engine.impl.bpmn.behavior.ServiceTaskJavaDelegateActivityBehavior.execute(ServiceTaskJavaDelegateActivityBehavior.java:49)

at org.camunda.bpm.engine.impl.bpmn.behavior.ServiceTaskJavaDelegateActivityBehavior.execute(ServiceTaskJavaDelegateActivityBehavior.java:40)

at org.camunda.bpm.engine.impl.bpmn.helper.ClassDelegate.execute(ClassDelegate.java:111)

at org.camunda.bpm.engine.impl.pvm.runtime.AtomicOperationActivityExecute.execute(AtomicOperationActivityExecute.java:44)

at org.camunda.bpm.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:93)

at org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:728)

at org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:719)

at org.camunda.bpm.engine.impl.pvm.runtime.AtomicOperationTransitionNotifyListenerStart.eventNotificationsCompleted(AtomicOperationTransitionNotifyListenerStart.java:63)

at org.camunda.bpm.engine.impl.pvm.runtime.AbstractEventAtomicOperation.execute(AbstractEventAtomicOperation.java:63)

at org.camunda.bpm.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:93)

at org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:728)

at org.camunda.bpm.engine.impl.pvm.runtime.AbstractEventAtomicOperation.execute(AbstractEventAtomicOperation.java:56)

at org.camunda.bpm.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:93)

at org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:728)

at org.camunda.bpm.engine.impl.pvm.runtime.AbstractEventAtomicOperation.execute(AbstractEventAtomicOperation.java:56)

at org.camunda.bpm.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:93)

at org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:728)

at org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:719)

at org.camunda.bpm.engine.impl.pvm.runtime.AtomicOperationTransitionCreateScope.execute(AtomicOperationTransitionCreateScope.java:54)

at org.camunda.bpm.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:93)

at org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:728)

at org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:719)

at org.camunda.bpm.engine.impl.pvm.runtime.AtomicOperationTransitionNotifyListenerTake.execute(AtomicOperationTransitionNotifyListenerTake.java:73)

at org.camunda.bpm.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:93)

at org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:728)

at org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:719)

at org.camunda.bpm.engine.impl.pvm.runtime.AtomicOperationTransitionNotifyListenerTake.execute(AtomicOperationTransitionNotifyListenerTake.java:58)

at org.camunda.bpm.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:93)

at org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:728)

at org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:719)

at org.camunda.bpm.engine.impl.pvm.runtime.AtomicOperationTransitionDestroyScope.execute(AtomicOperationTransitionDestroyScope.java:117)

at org.camunda.bpm.engine.impl.interceptor.CommandContext.performOperation(CommandContext.java:93)

at org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity.performOperationSync(ExecutionEntity.java:728)

at org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity.performOperation(ExecutionEntity.java:719)

at org.camunda.bpm.engine.impl.pvm.runtime.AtomicOperationTransitionNotifyListenerEnd.eventNotificationsCompleted(AtomicOperationTransitionNotifyListenerEnd.java:36)