How to signal another process?

As we transition to the new Hyland Community, some post links may be temporarily disrupted as we finalize redirects. We apologize for the inconvenience and are working to resolve this as quickly as possible. Details.

vipi_voxa

Hello dear all,

Basically i am struggling with understanding how to send and receive signals (messages) between different processes. 

Could you please help me to design or give me a hints how to create in Eclipse Activiti Designer something like this:

Process "A": start-> User Task-> end.

process A has the data object: "invoiceId"=1

Process "B" start -> (Signal to Process "A" with invoiceId = "1") -> end

process B also has the data object: "invoiceId"=1

Use case would be approximately like that: 

Process A registering new invoice and sends notification to user e.g: "New Incoming Invoice INV_1". The human task can be completed by the assignee OR it can receive a signal from another process and be auto completed.

Another process "B", lets say, it is a Payment receiving process. which received auto payment for an invoice 1. When the payment is received we need to signal Process A to complete. 

I just cant find any tutorials of how to define a signal throwing and catching between two processes based on some kind of correlation id.

 

thank you in advance! 

vipi_voxa

OK i guess it;s time for me to answer my own question. Please advice me if there is more trivial solution in place.

What i did in my mockup. Process A. start -> set business key variable -> User Task -> end

Process A has Signal "globalSignalA" defined 

User Task has Signal Boundary Event with signal reference to "globalSignalA"

Process B : start -> run script (groovy code provided below) -> end

groovy script. gets RuntimeService, collects information about executions with signal subscription: globalSignalA and calls signalEventReceivedAsync (watchout

signalEventReceived wont work). (activiti version: 5.22.0)

This is example of a groovy script i am running, somebody can find it usefull

import org.activiti.engine.runtime.ExecutionQuery
import org.activiti.engine.task.Task
import org.activiti.engine.runtime.ProcessInstance
import org.activiti.engine.RuntimeService
import org.activiti.engine.runtime.ProcessInstanceQuery
import org.activiti.engine.runtime.Execution

RuntimeService runtimeService = processEngine.getRuntimeService();

ProcessInstanceQuery procInstanceQuery = runtimeService.createProcessInstanceQuery()
String lBusinessKey= (String) execution.getVariable('testId')

//gimmi list of active processes by business key

List<ProcessInstance> instances = procInstanceQuery.processInstanceBusinessKey(lBusinessKey).active().list()
int x=0
for (ProcessInstance lProcInstance: instances)
{
x+=1
System.out.println('proc found: ' + lProcInstance.getName() + ', business key=' + lProcInstance.getBusinessKey())
}

if (x==0)
System.out.println('no related active processes found!')

//gimmi executions with globalSignalA by business key

x=0

List<Execution> executions = runtimeService.createExecutionQuery()
.processInstanceBusinessKey(lBusinessKey, true)
.signalEventSubscriptionName("globalSignalA")
.list();

System.out.println('list executions...')
for (Execution exec : executions)
{
x+=1
System.out.println('sending signal to ' + exec.getName() + ' processInstanceId:' + exec.getProcessInstanceId())
// runtimeService.signalEventReceived("globalSignalA", exec.getId());
runtimeService.signalEventReceivedAsync('globalSignalA', exec.getId())
}
System.out.println('signals sent ' + x)
System.out.println('done')