End Message Event

Gopan Sugathan

unread,

Mar 25, 2014, 8:05:53 AM3/25/14

to camunda-...@googlegroups.com

Hi ,

I have sub process within a main process and from the subprocess I am trying to send a message back to the main one.

For this purpose I am using end message event in the process.As per documentation end message is similar to service Task and we just need to implement a java delegate.

Using the Java delegate how do I send a message.

Do we need to use a external system like camel or a JmS queue for this purpose or is there api to send a message already pre built in camunda

Kind regards,
Gopan

Daniel Meyer

unread,

Mar 25, 2014, 8:48:06 AM3/25/14

to camunda-...@googlegroups.com

Hi Gopan,

you have to wait for the next release (end of this week):

then you can simply access the Runtime Service from the delegate:

public class AddVariablesService implements JavaDelegate {


  @Override
  public void execute(DelegateExecution execution) throws Exception {
   
    RuntimeService runtimeService = execution.getProcessEngineServices()
      .getRuntimeService();
    
    runtimeService.createMessageCorrelation("messageName")
      .processInstanceId("add id-of-main-process here!")
      .correlate();      


  }


}

At the moment execution.getProcessEngineServices() does not work yet. So you would have to get the Runtime service from somewhere else. (you could use @Inject with CDI or Spring)

Daniel

Gopan Sugathan

unread,

Mar 26, 2014, 1:22:23 AM3/26/14

to camunda-...@googlegroups.com

Hi Daniel,

Thank You that's wonderful news.

This particular code that's listed below will go inside the end message event.Can you please explain what this line does

runtimeService.createMessageCorrelation("messageName")
.processInstanceId("add id-of-main-process here!")
.correlate();

There is an intermediate message event that waits for a particular message in the main process.So in the main process I should again do the correlation to correlate the message thats is send from sub process end message event

Kind regards,

Gopan.

Daniel Meyer

unread,

Mar 28, 2014, 4:26:32 AM3/28/14

to camunda-...@googlegroups.com

Hi Gopan,

runtimeService.createMessageCorrelation("messageName")
.processInstanceId("add id-of-main-process here!")
.correlate();

can be used to send a message from one process instance to another, assuming that

- catching process instance is currently waiting for a message named "messageName"

- it is only waiting for one such message

No additional work is necessary inside the waiting ṕrocess instance.

Regards,

Daniel Meyer

Gopan Sugathan

unread,

Mar 31, 2014, 1:50:30 AM3/31/14

to camunda-...@googlegroups.com

Thank You very much Daniel!

Gopan Sugathan

unread,

Apr 3, 2014, 7:49:27 AM4/3/14

to camunda-...@googlegroups.com

Hi ,

If I used a embedded sub process and not a call activity and this particular subprocess is in multi instance loop.The embedded sub process has a human task followed by a end message and the main process has a intermediate catch message event.

I tried the following api and I am getting an error

org.camunda.bpm.engine.MismatchingMessageCorrelationException: Cannot correlate message TestResult: 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.MessageCorrelationBuilderImpl.correlate(MessageCorrelationBuilderImpl.java:96)

at com.clearfood.bpm.retail.inbound.exceution.listeners.TestSession.notify(TestSession.java:19)

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

Is there something wrong that I am doing.Should I use a call activity in the main process to call a sub process .

Kind regards,

Gopan

Roman Smirnov

unread,

Apr 3, 2014, 8:27:37 AM4/3/14

to camunda-...@googlegroups.com

Hi Gopan,

I am not sure whether I understand your process completely. However, it is not possible to throw a message and to catch this message internally inside a process instance. This is not BPMN spec conform. It is only possible to throw a message and catch this message by different process instance, for example: process A throws a message and process B catches this message.

What is your use case? Could you provide your process model?

Cheers,

Roman

Gopan Sugathan

unread,

Apr 4, 2014, 1:16:30 AM4/4/14

to camunda-...@googlegroups.com

Hi Roman,

I am attaching a simple process for your reference.

while executing the correlation I am getting the following error.I am attaching the correlation code for your reference

public void notify(DelegateExecution execution) throws Exception {

/*ExecutionEntity execEntity = ((ExecutionEntity)execution);

ExecutionEntity parent = execEntity.getParent();*/

System.out.println("Inside TestSession current ................"+execution.getProcessInstanceId());

//System.out.println("Inside TestSession parentid ................"+parent.getProcessInstanceId());

RuntimeService runtime = execution.getProcessEngineServices().getRuntimeService();

try {

runtime.createMessageCorrelation("TestMessage").processInstanceId(execution.getProcessInstanceId()).correlate();

System.out.println("Correlation successful ###########");

}

catch(Exception e) {

System.out.println("Exception ###########");

e.printStackTrace();

}

Correlation successful ###########

Inside TestSession current ................1f0c5d85-bbb7-11e3-b38e-40f02f573f97

Correlation successful ###########

Apr 04, 2014 10:38:17 AM org.camunda.bpm.engine.impl.interceptor.CommandContext close

SEVERE: Error while closing command context

java.lang.NullPointerException

at org.camunda.bpm.engine.impl.pvm.runtime.AtomicOperationCancelScope.execute(AtomicOperationCancelScope.java:68)

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.persistence.entity.ExecutionEntity.executeActivity(ExecutionEntity.java:535)

at org.camunda.bpm.engine.impl.event.AbstractEventHandler.handleEvent(AbstractEventHandler.java:57)

at org.camunda.bpm.engine.impl.persistence.entity.EventSubscriptionEntity.processEventSync(EventSubscriptionEntity.java:82)

at org.camunda.bpm.engine.impl.persistence.entity.EventSubscriptionEntity.eventReceived(EventSubscriptionEntity.java:73)

at org.camunda.bpm.engine.impl.cmd.MessageEventReceivedCmd.execute(MessageEventReceivedCmd.java:71)

at org.camunda.bpm.engine.impl.cmd.CorrelateMessageCmd.triggerExecution(CorrelateMessageCmd.java:89)

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

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.MessageCorrelationBuilderImpl.correlate(MessageCorrelationBuilderImpl.java:96)

at com.clearfood.bpm.retail.inbound.exceution.listeners.TestSession.notify(TestSession.java:20)

at org.camunda.bpm.engine.impl.delegate.ExecutionListenerInvocation.invoke(ExecutionListenerInvocation.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.helper.ClassDelegate.notify(ClassDelegate.java:69)

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

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.AtomicOperationTransitionNotifyListenerStart.eventNotificationsCompleted(AtomicOperationTransitionNotifyListenerStart.java:52)

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