Hyland Community
Help
cancel
Turn on suggestions
Auto-suggest helps you quickly narrow down your search results by suggesting possible matches as you type.
Showing results for 
Search instead for 
Did you mean: 

Problems with understanding signals

strauss
Champ in-the-making
Champ in-the-making

‎07-27-2018 08:51 AM

Hi everyone!

I have a problem with signals in activiti. Please help me.

My case: i have two simple processes (p1 and p2)

p1: start -> catchSignal -> end

p2: start -> throwSignal (async) -> end

First, i start process p1. Second, i start process p2. They launched in separates java threads.

This is how it works in my case (based on RuntimeService events):

>>> [start_p1][ACTIVITY_STARTED]
>>> [start_p1][ACTIVITY_COMPLETED]
>>> [signal_catch_p1][ACTIVITY_STARTED]
>>> [start_p2][ACTIVITY_STARTED]
>>> [start_p2][ACTIVITY_COMPLETED]
>>> [signal_throw_p2][ACTIVITY_STARTED]
>>> [signal_catch_p1][ACTIVITY_SIGNALED]
>>> [signal_throw_p2][ACTIVITY_COMPLETED]
>>> [end_p2][ACTIVITY_STARTED]
>>> [end_p2][ACTIVITY_COMPLETED]

I can't understand, why process p1 not ended? Signal_catch_p1 was signaled... and nothing more. I expected signal_catch_p1 to be completed and process go to end.

Java code:

public void test() {
          String bpmnDbPath = "E:\\activiti-db;DB_CLOSE_DELAY=1000";

          ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration();
          cfg = cfg.setJdbcDriver("org.h2.Driver").setJdbcUrl("jdbc:h2:" + bpmnDbPath).setJdbcUsername("sa")
                     .setJdbcPassword("").setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
          ManagedAsyncJobExecutor jobExecutor = new ManagedAsyncJobExecutor();
          jobExecutor.setAutoActivate(true);
          jobExecutor.setCorePoolSize(3);
          jobExecutor.setMaxPoolSize(20);
          cfg.setAsyncExecutor(jobExecutor);
          cfg.setAsyncExecutorActivate(true);

          ProcessEngine processEngine = cfg.buildProcessEngine();
          processEngine.getRuntimeService().addEventListener(new ActivitiEventListener() {
               @Override
               public void onEvent(ActivitiEvent activitiEvent) {
                    if (activitiEvent instanceof ActivitiActivityEventImpl) {
                         ActivitiActivityEventImpl aaeImpl = (ActivitiActivityEventImpl) activitiEvent;
                         String activitiId = aaeImpl.getActivityId();
                         String type = activitiEvent.getType().toString();
                         System.out.println(String.format(">>> [%s][%s]", activitiId, type));
                    }
               }

               @Override
               public boolean isFailOnException() {
                    return true;
               }
          });

          String p1 = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" +
                         "<definitions xmlns=\"http://www.omg.org/spec/BPMN/20100524/MODEL\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:activiti=\"http://activiti.org/bpmn\" xmlns:bpmndi=\"http://www.omg.org/spec/BPMN/20100524/DI\" xmlns:omgdc=\"http://www.omg.org/spec/DD/20100524/DC\" xmlns:omgdi=\"http://www.omg.org/spec/DD/20100524/DI\" typeLanguage=\"http://www.w3.org/2001/XMLSchema\" expressionLanguage=\"http://www.w3.org/1999/XPath\" targetNamespace=\"http://www.activiti.org/test\">\n" +
                         "  <signal id=\"UnknownSignal\" name=\"UnknownSignal\"></signal>\n" +
                         "  <process id=\"p1\" isExecutable=\"true\">\n" +
                         "    <endEvent id=\"end_p1\"></endEvent>\n" +
                         "    <startEvent id=\"start_p1\"></startEvent>\n" +
                         "    <intermediateCatchEvent id=\"signal_catch_p1\">\n" +
                         "      <signalEventDefinition signalRef=\"UnknownSignal\"></signalEventDefinition>\n" +
                         "    </intermediateCatchEvent>\n" +
                         "    <sequenceFlow sourceRef=\"start_p1\" targetRef=\"signal_catch_p1\"></sequenceFlow>\n" +
                         "    <sequenceFlow sourceRef=\"signal_catch_p1\" targetRef=\"end_p1\"></sequenceFlow>\n" +
                         "  </process>\n" +
                         "</definitions>";

          String p2 = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" +
                         "<definitions xmlns=\"http://www.omg.org/spec/BPMN/20100524/MODEL\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:activiti=\"http://activiti.org/bpmn\" xmlns:bpmndi=\"http://www.omg.org/spec/BPMN/20100524/DI\" xmlns:omgdc=\"http://www.omg.org/spec/DD/20100524/DC\" xmlns:omgdi=\"http://www.omg.org/spec/DD/20100524/DI\" typeLanguage=\"http://www.w3.org/2001/XMLSchema\" expressionLanguage=\"http://www.w3.org/1999/XPath\" targetNamespace=\"http://www.activiti.org/test\">\n" +
                         "  <signal id=\"UnknownSignal\" name=\"UnknownSignal\"></signal>\n" +
                         "  <process id=\"p2\" isExecutable=\"true\">\n" +
                         "    <endEvent id=\"end_p2\"></endEvent>\n" +
                         "    <startEvent id=\"start_p2\"></startEvent>\n" +
                         "    <intermediateThrowEvent id=\"signal_throw_p2\">\n" +
                         "      <signalEventDefinition signalRef=\"UnknownSignal\" activiti:async=\"true\"></signalEventDefinition>\n" +
                         "    </intermediateThrowEvent>\n" +
                         "    <sequenceFlow sourceRef=\"start_p2\" targetRef=\"signal_throw_p2\"></sequenceFlow>\n" +
                         "    <sequenceFlow sourceRef=\"signal_throw_p2\" targetRef=\"end_p2\"></sequenceFlow>\n" +
                         "  </process>\n" +
                         "</definitions>";

          deployAndStartProcess(processEngine, p1, "p1");
          deployAndStartProcess(processEngine, p2, "p2");
     }

     private void deployAndStartProcess(ProcessEngine processEngine, String bpmnProcess, String processId) {
          try {
               RuntimeService runtimeService = processEngine.getRuntimeService();
               RepositoryService repositoryService = processEngine.getRepositoryService();
               DeploymentBuilder db = repositoryService.createDeployment();

               String deploymentId = processId + ".bpmn20.xml";

               db.addString(deploymentId, bpmnProcess).deploy();

               Runnable r = () -> runtimeService.startProcessInstanceByKey(processId);
               (new Thread(r)).start();
          } catch (Exception e) {
               System.out.println(e.getMessage());
          }
     }‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍
Labels:
0 Kudos
4 REPLIES 4

mdtabrezmca
Star Contributor
Star Contributor

‎07-31-2018 06:19 AM

Did you checked the event logs at this table in activiti act_evt_log.Because when i see the similar application running using activiti app(not from the java code) it is able to end the process p1 in my case.below is the event logs from my activiti databse. also please find the attachment of my APP.

 25VARIABLE_CREATEDsignal_catch_process:1:2500725022250222018-07-31 12:16:05.0951...1
 26HISTORIC_PROCESS_INSTANCE_CREATEDsignal_catch_process:1:25007250222018-07-31 12:16:05.0971...1
 27HISTORIC_ACTIVITY_INSTANCE_CREATEDsignal_catch_process:1:2500725022250222018-07-31 12:16:05.1041...1
 28HISTORIC_ACTIVITY_INSTANCE_ENDEDsignal_catch_process:1:2500725022250222018-07-31 12:16:05.1091...1
 29SEQUENCEFLOW_TAKENsignal_catch_process:1:2500725022250222018-07-31 12:16:05.1011...1
 30HISTORIC_ACTIVITY_INSTANCE_CREATEDsignal_catch_process:1:2500725022250262018-07-31 12:16:05.1101...1
 31VARIABLE_CREATEDsignal_throwing_process:1:2500625029250292018-07-31 12:16:45.1211...1
 32HISTORIC_PROCESS_INSTANCE_CREATEDsignal_throwing_process:1:25006250292018-07-31 12:16:45.1211...1
 33HISTORIC_ACTIVITY_INSTANCE_CREATEDsignal_throwing_process:1:2500625029250292018-07-31 12:16:45.1211...1
 34HISTORIC_ACTIVITY_INSTANCE_ENDEDsignal_throwing_process:1:2500625029250292018-07-31 12:16:45.1361...1
 35SEQUENCEFLOW_TAKENsignal_throwing_process:1:2500625029250292018-07-31 12:16:45.1211...1
 36HISTORIC_ACTIVITY_INSTANCE_CREATEDsignal_throwing_process:1:2500625029250292018-07-31 12:16:45.1361...1
 37HISTORIC_ACTIVITY_INSTANCE_ENDEDsignal_catch_process:1:2500725022250262018-07-31 12:16:45.1551...1
 38SEQUENCEFLOW_TAKENsignal_catch_process:1:2500725022250222018-07-31 12:16:45.1361...1
 39HISTORIC_ACTIVITY_INSTANCE_CREATEDsignal_catch_process:1:2500725022250222018-07-31 12:16:45.1571...1
 40HISTORIC_ACTIVITY_INSTANCE_ENDEDsignal_catch_process:1:2500725022250222018-07-31 12:16:45.1651...1
 41HISTORIC_PROCESS_INSTANCE_ENDEDsignal_catch_process:1:25007250222018-07-31 12:16:45.1591...1
 42VARIABLE_DELETEDsignal_catch_process:1:2500725022250222018-07-31 12:16:45.1621...1
 43HISTORIC_ACTIVITY_INSTANCE_ENDEDsignal_throwing_process:1:2500625029250292018-07-31 12:16:45.1671...1
 44SEQUENCEFLOW_TAKENsignal_throwing_process:1:2500625029250292018-07-31 12:16:45.1591...1
 45HISTORIC_ACTIVITY_INSTANCE_CREATEDsignal_throwing_process:1:2500625029250292018-07-31 12:16:45.1751...1
 46HISTORIC_ACTIVITY_INSTANCE_ENDEDsignal_throwing_process:1:2500625029250292018-07-31 12:16:45.1741...1
 47HISTORIC_PROCESS_INSTANCE_ENDEDsignal_throwing_process:1:25006250292018-07-31 12:16:45.1761...1
 48VARIABLE_DELETEDsignal_throwing_process:1:2500625029250292018-07-31 12:16:45.1791...1
0 Kudos

mdtabrezmca
Star Contributor
Star Contributor

‎07-31-2018 06:21 AM

Forgot to attach the app......

SignalThrowingAndCatching.zip
0 Kudos

strauss
Champ in-the-making
Champ in-the-making

‎07-31-2018 11:13 AM

tabrez khan‌

Thank you for answer.

I looked at your app. But it contains one important difference from my case: you use IntermediateThrowSignal in sync mode. I want use this in async mode.

0 Kudos

mdtabrezmca
Star Contributor
Star Contributor

‎08-01-2018 01:25 AM

I see you are using Async Intermediate throwing event. I guess you can see some of the test cases written in activiti-engine which you can find helpful......

Activiti/modules/activiti-engine/src/test/resources/org/activiti/engine/test/bpmn/event/signal at 6.... 

0 Kudos
Getting started

Explore our Alfresco products with the links below. Use labels to filter content by product module.

Copyright © 2024 Khoros, LLC