Signal Event Subscription is in suspended state after resuming 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.

prachi_mujumdar

Hi,

I have Process A which I am suspending. As per business requirement when a particular condition is met, I need to resume the process and send a signal to it.

This works fine if I have single process instance in suspended state. But if I have multiple process instances of same process in suspended state then I get following error:

org.activiti.engine.ActivitiException: Cannot throw signal event 'SomeSignalName' because execution '2666' is suspended
   at org.activiti.engine.impl.cmd.SignalEventReceivedCmd.execute(SignalEventReceivedCmd.java:61)
   at org.activiti.engine.impl.cmd.SignalEventReceivedCmd.execute(SignalEventReceivedCmd.java:33)
   at org.activiti.engine.impl.interceptor.CommandExecutorImpl.execute(CommandExecutorImpl.java:24)
   at org.activiti.engine.impl.interceptor.CommandContextInterceptor.execute(CommandContextInterceptor.java:61)
   at org.activiti.spring.SpringTransactionInterceptor$1.doInTransaction(SpringTransactionInterceptor.java:42)
   at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:130)
   at org.activiti.spring.SpringTransactionInterceptor.execute(SpringTransactionInterceptor.java:40)
   at org.activiti.engine.impl.interceptor.LogInterceptor.execute(LogInterceptor.java:31)
   at org.activiti.engine.impl.RuntimeServiceImpl.signalEventReceived(RuntimeServiceImpl.java:233)

I am using following code :

To suspend the process

runtimeService.suspendProcessInstanceById(processInstanceId);
‍‍‍

To resume a process

runtimeService.activateProcessInstanceById(processInstanceId);
‍‍‍

And to send event signal

ExecutionQuery executionQuery = runtimeService.createExecutionQuery().processInstanceId(processInstanceId).signalEventSubscriptionName(signalName);
        if (executionQuery != null) {
                   Execution execution = executionQuery.singleResult();
         runtimeService.signalEventReceived(eventSignal, execution.getId());
       }
‍‍‍‍‍‍‍

Can anyone please help me in this?

martin_grofcik

Hi Prachi.

I tried to reproduce your issue with jUnit test. Following test is based on activiti 5.15 sources and jUnit test.

<br>&nbsp; @Deployment(resources = "org/activiti/engine/test/api/runtime/ProcessInstanceSuspensionTest.testSignalEventReceivedAfterProcessInstanceSuspended.bpmn20.xml")<br>&nbsp; public void testSignalEventReceivedAfterMultipleProcessInstancesSuspended() {<br><br>&nbsp;&nbsp;&nbsp; final String signal = "Some Signal";<br><br>&nbsp;&nbsp;&nbsp; // Test if process instance can be completed using the signal<br>&nbsp;&nbsp;&nbsp; ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("signalSuspendedProcessInstance");<br>&nbsp;&nbsp;&nbsp; runtimeService.startProcessInstanceByKey("signalSuspendedProcessInstance");<br>&nbsp;&nbsp;&nbsp; runtimeService.signalEventReceived(signal);<br>&nbsp;&nbsp;&nbsp; assertEquals(0, runtimeService.createProcessInstanceQuery().count());<br><br>&nbsp;&nbsp;&nbsp; // Now test when suspending the process instance: the process instance shouldn't be continued<br>&nbsp;&nbsp;&nbsp; processInstance = runtimeService.startProcessInstanceByKey("signalSuspendedProcessInstance");<br>&nbsp;&nbsp;&nbsp; runtimeService.suspendProcessInstanceById(processInstance.getId());<br>&nbsp;&nbsp;&nbsp; processInstance = runtimeService.startProcessInstanceByKey("signalSuspendedProcessInstance");<br>&nbsp;&nbsp;&nbsp; runtimeService.suspendProcessInstanceById(processInstance.getId());<br>&nbsp;&nbsp;&nbsp; runtimeService.signalEventReceived(signal);<br>&nbsp;&nbsp;&nbsp; assertEquals(2, runtimeService.createProcessInstanceQuery().count());<br><br>&nbsp;&nbsp;&nbsp; runtimeService.signalEventReceived(signal, new HashMap<String, Object>());<br>&nbsp;&nbsp;&nbsp; assertEquals(2, runtimeService.createProcessInstanceQuery().count());<br><br>&nbsp;&nbsp;&nbsp; // Activate and try again<br>&nbsp;&nbsp;&nbsp; runtimeService.activateProcessInstanceById(processInstance.getId());<br>&nbsp;&nbsp;&nbsp; runtimeService.signalEventReceived(signal);<br>&nbsp;&nbsp;&nbsp; assertEquals(1, runtimeService.createProcessInstanceQuery().count());<br>&nbsp; }<br>
I started/suspended 2 process instances. They were not activated by signals. After that I activated one of them and sent a signal. Activated process instance was finished. Is seems that it works as you expected.

Regards
Martin