1 Reply Latest reply on Mar 28, 2012 1:49 PM by Maciej Swiderski

    jbpm process REST api for signaling process does not work (is it a bug?)

    marmotadev Newbie

      Hello,

       

      I can sucessfully invoke REST api for starting service, however invoking /rs/process/tokens/<process instance id>/transition?signal=<signal name> does not send signals to process engine.

      If I run process locally (in eclipse):

      kcontext.getKnowledgeRuntime().signalEvent( eventType, data, kcontext.getProcessInstance().getId());

       

      - all signals reach nodes inside the process. Event/Signal nodes are configured as "external".

      Here are logs for invoking HTTP requests:

       

      DEBUG org.apache.http.impl.conn.DefaultClientConnection  - Sending request: POST /gwt-console-server/rs/process/tokens/5/transition?signal=RODataReceivedSignal HTTP/1.1

      DEBUG org.apache.http.wire  - >> "POST /gwt-console-server/rs/process/tokens/5/transition?signal=RODataReceivedSignal HTTP/1.1[\r][\n]"

      DEBUG org.apache.http.wire  - >> "JSESSIONID: XRW3Gp28tTUF2NLekPsm10e6[\r][\n]"

      DEBUG org.apache.http.wire  - >> "Content-Length: 0[\r][\n]"

      DEBUG org.apache.http.wire  - >> "Content-Type: application/x-www-form-urlencoded; charset=UTF-8[\r][\n]"

      DEBUG org.apache.http.wire  - >> "Host: localhost:8080[\r][\n]"

      DEBUG org.apache.http.wire  - >> "Connection: Keep-Alive[\r][\n]"

      DEBUG org.apache.http.wire  - >> "User-Agent: Apache-HttpClient/4.1.3 (java 1.5)[\r][\n]"

      DEBUG org.apache.http.wire  - >> "Cookie: JSESSIONID=XRW3Gp28tTUF2NLekPsm10e6[\r][\n]"

      DEBUG org.apache.http.wire  - >> "Cookie2: $Version=1[\r][\n]"

      DEBUG org.apache.http.wire  - >> "[\r][\n]"

      DEBUG org.apache.http.headers  - >> POST /gwt-console-server/rs/process/tokens/5/transition?signal=RODataReceivedSignal HTTP/1.1

      DEBUG org.apache.http.headers  - >> JSESSIONID: XRW3Gp28tTUF2NLekPsm10e6

      DEBUG org.apache.http.headers  - >> Content-Length: 0

      DEBUG org.apache.http.headers  - >> Content-Type: application/x-www-form-urlencoded; charset=UTF-8

      DEBUG org.apache.http.headers  - >> Host: localhost:8080

      DEBUG org.apache.http.headers  - >> Connection: Keep-Alive

      DEBUG org.apache.http.headers  - >> User-Agent: Apache-HttpClient/4.1.3 (java 1.5)

      DEBUG org.apache.http.headers  - >> Cookie: JSESSIONID=XRW3Gp28tTUF2NLekPsm10e6

      DEBUG org.apache.http.headers  - >> Cookie2: $Version=1

      DEBUG org.apache.http.wire  - << "HTTP/1.1 200 OK[\r][\n]"

      DEBUG org.apache.http.wire  - << "Server: Apache-Coyote/1.1[\r][\n]"

      DEBUG org.apache.http.wire  - << "Content-Type: application/json[\r][\n]"

      DEBUG org.apache.http.wire  - << "Transfer-Encoding: chunked[\r][\n]"

      DEBUG org.apache.http.wire  - << "Date: Tue, 27 Mar 2012 18:18:20 GMT[\r][\n]"

      DEBUG org.apache.http.wire  - << "[\r][\n]"

      DEBUG org.apache.http.impl.conn.DefaultClientConnection  - Receiving response: HTTP/1.1 200 OK

      DEBUG org.apache.http.headers  - << HTTP/1.1 200 OK

      DEBUG org.apache.http.headers  - << Server: Apache-Coyote/1.1

      DEBUG org.apache.http.headers  - << Content-Type: application/json

      DEBUG org.apache.http.headers  - << Transfer-Encoding: chunked

      DEBUG org.apache.http.headers  - << Date: Tue, 27 Mar 2012 18:18:20 GMT

      DEBUG org.apache.http.impl.client.DefaultHttpClient  - Connection can be kept alive indefinitely

      DEBUG org.apache.http.wire  - << "0[\r][\n]"

      DEBUG org.apache.http.wire  - << "[\r][\n]"

       

       

       

       

      if I look /gwt-console-server/rs/process/definition/<my process id>/instances, i can see that they are not "signalable":

       


      {"instances":[{"id":"1","definitionId":"<process id>","startDate":"2012-03-27 20:31:13","suspended":false,"rootToken":{"id":"1","name":"","currentNodeName":"","children":[],"availableSignals":[],"canBeSignaled":false}}}]}

       

      But they have 3 signals defined inside process:

       

      <?xml version="1.0" encoding="UTF-8"?>

      <definitions id="Definition"

                   targetNamespace="http://www.jboss.org/drools"

                   typeLanguage="http://www.java.com/javaTypes"

                   expressionLanguage="http://www.mvel.org/2.0"

                   xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"

                   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

                   xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd"

                   xmlns:g="http://www.jboss.org/drools/flow/gpd"

                   xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI"

                   xmlns:dc="http://www.omg.org/spec/DD/20100524/DC"

                   xmlns:di="http://www.omg.org/spec/DD/20100524/DI"

                   xmlns:tns="http://www.jboss.org/drools">

       

       

       

       

        <itemDefinition id="_inputSignalNameItem" structureRef="String" />

       

       

       

       

        <process processType="Private" isExecutable="true" id="<my process id>" name="Signal catch process" tns:packageName="defaultPackage" >

       

       

       

       

          <!-- process variables -->

          <property id="inputSignalName" itemSubjectRef="_inputSignalNameItem"/>

       

       

       

       

          <!-- nodes -->

          <startEvent id="_1" name="StartProcess" />

          <intermediateCatchEvent id="_2" name="Signal" >

            <dataOutput id="_2_Output" name="event" />

            <dataOutputAssociation>

            <sourceRef>_2_Output</sourceRef>

            <targetRef>inputSignalName</targetRef>

            </dataOutputAssociation>

            <outputSet>

              <dataOutputRefs>_2_Output</dataOutputRefs>

            </outputSet>

            <signalEventDefinition signalRef="RODataRepeatedSignal"/>

          </intermediateCatchEvent>

          <scriptTask id="_3" name="Script" scriptFormat="http://www.java.com/java" >

            <script>System.out.println("TEST_SIGNAL");</script>

          </scriptTask>

          <endEvent id="_4" name="End" >

              <terminateEventDefinition/>

          </endEvent>

          <parallelGateway id="_5" name="Gateway" gatewayDirection="Diverging" />

          <intermediateCatchEvent id="_6" name="Signal" >

            <dataOutput id="_6_Output" name="event" />

            <dataOutputAssociation>

            <sourceRef>_6_Output</sourceRef>

            <targetRef>inputSignalName</targetRef>

            </dataOutputAssociation>

            <outputSet>

              <dataOutputRefs>_6_Output</dataOutputRefs>

            </outputSet>

            <signalEventDefinition signalRef="OTHER_EVENT"/>

          </intermediateCatchEvent>

          <scriptTask id="_7" name="Script" >

            <script>System.out.println("OTHER_SIGNAL");</script>

          </scriptTask>

          <exclusiveGateway id="_8" name="Gateway" gatewayDirection="Converging" />

          <intermediateCatchEvent id="_9" name="Signal" >

            <dataOutput id="_9_Output" name="event" />

            <dataOutputAssociation>

            <sourceRef>_9_Output</sourceRef>

            <targetRef>inputSignalName</targetRef>

            </dataOutputAssociation>

            <outputSet>

              <dataOutputRefs>_9_Output</dataOutputRefs>

            </outputSet>

            <signalEventDefinition signalRef="RODataReceivedSignal"/>

          </intermediateCatchEvent>

          <scriptTask id="_10" name="Script" scriptFormat="http://www.java.com/java" >

            <script>System.out.println("BEFORE FIRST EVENT");</script>

          </scriptTask>

          <scriptTask id="_11" name="Script" scriptFormat="http://www.java.com/java" >

            <script>System.out.println("AFTER FIRST EVENT");</script>

          </scriptTask>

       

       

       

       

          <!-- connections -->

          <sequenceFlow id="_5-_2" sourceRef="_5" targetRef="_2" />

          <sequenceFlow id="_2-_3" sourceRef="_2" targetRef="_3" />

          <sequenceFlow id="_8-_4" sourceRef="_8" targetRef="_4" />

          <sequenceFlow id="_11-_5" sourceRef="_11" targetRef="_5" />

          <sequenceFlow id="_5-_6" sourceRef="_5" targetRef="_6" />

          <sequenceFlow id="_6-_7" sourceRef="_6" targetRef="_7" />

          <sequenceFlow id="_3-_8" sourceRef="_3" targetRef="_8" />

          <sequenceFlow id="_7-_8" sourceRef="_7" targetRef="_8" />

          <sequenceFlow id="_10-_9" sourceRef="_10" targetRef="_9" />

          <sequenceFlow id="_1-_10" sourceRef="_1" targetRef="_10" />

          <sequenceFlow id="_9-_11" sourceRef="_9" targetRef="_11" />

       

       

       

       

        </process>

       

       

       

       

        <bpmndi:BPMNDiagram>

          <bpmndi:BPMNPlane bpmnElement="<my process id>" >

            <bpmndi:BPMNShape bpmnElement="_1" >

              <dc:Bounds x="16" y="56" width="48" height="48" />

            </bpmndi:BPMNShape>

            <bpmndi:BPMNShape bpmnElement="_2" >

              <dc:Bounds x="481" y="16" width="48" height="48" />

            </bpmndi:BPMNShape>

            <bpmndi:BPMNShape bpmnElement="_3" >

              <dc:Bounds x="561" y="16" width="80" height="48" />

            </bpmndi:BPMNShape>

            <bpmndi:BPMNShape bpmnElement="_4" >

              <dc:Bounds x="754" y="56" width="48" height="48" />

            </bpmndi:BPMNShape>

            <bpmndi:BPMNShape bpmnElement="_5" >

              <dc:Bounds x="400" y="56" width="48" height="48" />

            </bpmndi:BPMNShape>

            <bpmndi:BPMNShape bpmnElement="_6" >

              <dc:Bounds x="481" y="96" width="48" height="48" />

            </bpmndi:BPMNShape>

            <bpmndi:BPMNShape bpmnElement="_7" >

              <dc:Bounds x="561" y="96" width="80" height="48" />

            </bpmndi:BPMNShape>

            <bpmndi:BPMNShape bpmnElement="_8" >

              <dc:Bounds x="673" y="56" width="48" height="48" />

            </bpmndi:BPMNShape>

            <bpmndi:BPMNShape bpmnElement="_9" >

              <dc:Bounds x="208" y="56" width="48" height="48" />

            </bpmndi:BPMNShape>

            <bpmndi:BPMNShape bpmnElement="_10" >

              <dc:Bounds x="96" y="56" width="80" height="48" />

            </bpmndi:BPMNShape>

            <bpmndi:BPMNShape bpmnElement="_11" >

              <dc:Bounds x="288" y="56" width="80" height="48" />

            </bpmndi:BPMNShape>

            <bpmndi:BPMNEdge bpmnElement="_5-_2" >

              <di:waypoint x="424" y="80" />

              <di:waypoint x="505" y="40" />

            </bpmndi:BPMNEdge>

            <bpmndi:BPMNEdge bpmnElement="_2-_3" >

              <di:waypoint x="505" y="40" />

              <di:waypoint x="601" y="40" />

            </bpmndi:BPMNEdge>

            <bpmndi:BPMNEdge bpmnElement="_8-_4" >

              <di:waypoint x="697" y="80" />

              <di:waypoint x="778" y="80" />

            </bpmndi:BPMNEdge>

            <bpmndi:BPMNEdge bpmnElement="_11-_5" >

              <di:waypoint x="328" y="80" />

              <di:waypoint x="424" y="80" />

            </bpmndi:BPMNEdge>

            <bpmndi:BPMNEdge bpmnElement="_5-_6" >

              <di:waypoint x="424" y="80" />

              <di:waypoint x="505" y="120" />

            </bpmndi:BPMNEdge>

            <bpmndi:BPMNEdge bpmnElement="_6-_7" >

              <di:waypoint x="505" y="120" />

              <di:waypoint x="601" y="120" />

            </bpmndi:BPMNEdge>

            <bpmndi:BPMNEdge bpmnElement="_3-_8" >

              <di:waypoint x="601" y="40" />

              <di:waypoint x="697" y="80" />

            </bpmndi:BPMNEdge>

            <bpmndi:BPMNEdge bpmnElement="_7-_8" >

              <di:waypoint x="601" y="120" />

              <di:waypoint x="697" y="80" />

            </bpmndi:BPMNEdge>

            <bpmndi:BPMNEdge bpmnElement="_10-_9" >

              <di:waypoint x="136" y="80" />

              <di:waypoint x="232" y="80" />

            </bpmndi:BPMNEdge>

            <bpmndi:BPMNEdge bpmnElement="_1-_10" >

              <di:waypoint x="40" y="80" />

              <di:waypoint x="136" y="80" />

            </bpmndi:BPMNEdge>

            <bpmndi:BPMNEdge bpmnElement="_9-_11" >

              <di:waypoint x="232" y="80" />

              <di:waypoint x="328" y="80" />

            </bpmndi:BPMNEdge>

          </bpmndi:BPMNPlane>

        </bpmndi:BPMNDiagram>

       

       

       

       

      </definitions>

       

       

       

      I've started looking and gwt console code and....

      org.jbpm.integration.console.ProcessManagement:65

       


      result.add(Transform.processInstance(processInstance));

       

      makes transformation, which basically omits canBeSignaled, availableSignals fields!

       

       

       



      ProcessInstanceRef result = new ProcessInstanceRef(



      processInstance.getProcessInstanceId() + "",



      processInstance.getProcessId(),



      processInstance.getStart(),



      processInstance.getEnd(),



      false);


      TokenReference token = new TokenReference(



      processInstance.getProcessInstanceId() + "", null, "");


      result.setRootToken(token);


      return result;

       

       

       

       

       

      ProcessManagementTest also lacks any tests:

       

      @Test @Ignore

                public void testSignalExecution() {

                          // TODO implement

                }

       

       

      Of course, I am not sure if this is the cause of ignoring signals. By looking at signal code it seems that processes should be signaled, however I could not setup development environment for gwt-console-server to trace exact behaviour (s.

      Can anyone share experience with signaling processes running on gwt-console-server (Or a way to setup a debuging environment for gwt-console-server on eclipse)?

      P.S. Sorry for formatting