topic Re: How to trigger event for event based gateway in java in Alfresco Forum

How to trigger event for event based gateway in java

shobhit — Mon, 05 Jun 2017 08:59:10 GMT

Hi I am trying to implement event based - gateway as shown in example of activiti user guide Activiti User Guide .Only difference in below mentioned image and my model is that there is a service task (lets call it task T) between start event and event-based gateway.I am firing event in this service

Re: How to trigger event for event based gateway in java

Anonymous — Mon, 05 Jun 2017 12:32:15 GMT

You should specify executionId by ExecutionQuery().signalEventSubscriptionName.

Execution execution = runtimeService.createExecutionQuery().processInstanceId(processInstance.getId()).signalEventSubscriptionName("alert").singleResult();
runtimeService.signalEventReceived("alert", execution.getId());

Re: How to trigger event for event based gateway in java

shobhit — Mon, 05 Jun 2017 14:09:38 GMT

Value of execution variable is coming as Null in above solution also.

Is there anything wrong in use of "Alert" and "alert"? also in xml both intermediate catch event have name as "Alert" but different id. Is this correct?

Re: How to trigger event for event based gateway in java

shobhit — Mon, 05 Jun 2017 14:26:48 GMT

I tried using all id and name of all signal, signalEvent and timerEvent, i also tried by changing name of Alerts to two different names but in all cases execution is null.

I am using activiti 5.18

Re: How to trigger event for event based gateway in java

shobhit — Mon, 05 Jun 2017 14:34:37 GMT

my updated xml:

Inside "Service Task" I am triggering event.

<?xml version="1.0" encoding="UTF-8"?>
<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="Examples" id="definitions">
  <signal id="alertSignal" name="alert"></signal>
  <process id="catchSignal" isExecutable="true">
    <startEvent id="start"></startEvent>
    <eventBasedGateway id="gw1"></eventBasedGateway>
    <sequenceFlow id="sequenceFlow-3051249c-7a8d-4664-b555-3d2dbad2cd87" sourceRef="gw1" targetRef="signalEvent"></sequenceFlow>
    <sequenceFlow id="sequenceFlow-f7c70e01-8a9d-401f-891a-86ac6adba48d" sourceRef="gw1" targetRef="timerEvent"></sequenceFlow>
    <intermediateCatchEvent id="signalEvent" name="Alert">
      <signalEventDefinition signalRef="alertSignal"></signalEventDefinition>
    </intermediateCatchEvent>
    <intermediateCatchEvent id="timerEvent" name="Alert">
      <timerEventDefinition>
        <timeDuration>PT10M</timeDuration>
      </timerEventDefinition>
    </intermediateCatchEvent>
    <sequenceFlow id="sequenceFlow-63cbfd19-ba5a-4731-a55c-465e63864847" sourceRef="timerEvent" targetRef="exGw1"></sequenceFlow>
    <sequenceFlow id="sequenceFlow-a89c2ece-3118-4dc1-b060-0e95df0579de" sourceRef="signalEvent" targetRef="servicetask1"></sequenceFlow>
    <exclusiveGateway id="exGw1"></exclusiveGateway>
    <sequenceFlow id="sequenceFlow-d97bc397-6f10-4748-a787-8e4d18ee1ea4" sourceRef="servicetask1" targetRef="exGw1"></sequenceFlow>
    <sequenceFlow id="sequenceFlow-f1a30ab8-6521-4f8b-af60-84dc23fac33c" sourceRef="exGw1" targetRef="end"></sequenceFlow>
    <endEvent id="end"></endEvent>
    <serviceTask id="servicetask1" name="Handle alert" activiti:delegateExpression="${logRetryErrorJ}"></serviceTask>
    <serviceTask id="servicetask2" name="Service Task" activiti:delegateExpression="${createNewAffliateTask}"></serviceTask>
    <sequenceFlow id="flow1" sourceRef="start" targetRef="servicetask2"></sequenceFlow>
    <sequenceFlow id="flow2" sourceRef="servicetask2" targetRef="gw1"></sequenceFlow>
  </process>
</definitions>

Re: How to trigger event for event based gateway in java

Anonymous — Mon, 05 Jun 2017 18:15:53 GMT

Are you acquiring the execution of signal event from servicetask2?
You cannot acquire because there is no execution of signal event at the stage of servicetask2.

Re: How to trigger event for event based gateway in java

shobhit — Tue, 06 Jun 2017 03:50:18 GMT

okay, what will be the right way to do this, can you please help? am stuck on this past 2 days just trying various permutations.. somehow google is not able to help me.

My service task 2 class: What should I have done differently here? Do i need to create some other class for event gateway or something?

@Component("createNewAffliateTask")
public class CreateNewAffliateTask implements JavaDelegate {

    private Logger logger = LoggerFactory.getLogger(getClass());

    @Autowired
    private RuntimeService runtimeService;

    @Override
    public void execute(DelegateExecution execution) throws Exception {
        try {

            String companyName = execution.getVariable(Constants.ONBOARDING_COMPANY_NAME, String.class);
            String companyPan = execution.getVariable(Constants.ONBOARDING_COMPANY_PAN, String.class);
            String employeeEmail = execution.getVariable(Constants.ONBOARDING_EMPLOYEE_EMAIL, String.class);
            String executionId = execution.getId();
            
            Execution executions = runtimeService.createExecutionQuery().processInstanceId(execution.getProcessInstanceId())
                    .signalEventSubscriptionName("alert").singleResult();
            runtimeService.signalEventReceived("alert", execution.getId()); //TRIGGERING EVENT HERE

        } catch (Exception ex) {
            String processInstanceId = execution.getProcessInstanceId();
            runtimeService.suspendProcessInstanceById(processInstanceId);

            throw new ActivitiException("", "Exception encountered for process id: " + String.valueOf(processInstanceId));
        }
    }
}

Re: How to trigger event for event based gateway in java

Anonymous — Tue, 06 Jun 2017 09:36:38 GMT

You cannot acquire the execution of signal event because there is no execution of signal event at the stage of servicetask2.
You should execute ExecutionQuery after the execution of signal event was generated.

I made a sample.
https://github.com/daisuke-yoshimoto/message_signal_samples

message_signal_samples/SignalThrowingInExecutionSample.java at master · daisuke-yoshimoto/message_signal_samples · GitHu…