Examples of signal()


Examples of org.camunda.bpm.engine.impl.pvm.PvmExecution.signal()

    assertEquals("expected "+expectedEvents+", but was \n"+eventCollector+"\n", expectedEvents, eventCollector.events);
    eventCollector.events.clear();

    PvmExecution execution = processInstance.findExecution("c1");
    execution.signal(null, null);

    expectedEvents = new ArrayList<String>();
    expectedEvents.add("end on Activity(c1)");
    expectedEvents.add("start on Activity(join)");
View Full Code Here

Examples of org.camunda.bpm.engine.impl.pvm.PvmExecution.signal()

    eventCollector.events.clear();

    execution = processInstance.findExecution("c2");

    // this process gets blocked in the join
    execution.signal(null, null);
  }
}
View Full Code Here

Examples of org.camunda.bpm.engine.impl.pvm.PvmExecution.signal()

    PvmProcessInstance processInstance = processDefinition.createProcessInstance();
    processInstance.start();

    PvmExecution timerExecution = processInstance.findExecution("timer");
    timerExecution.signal(null, null);

    verifier.assertNonCompletingActivityInstance("start", 1);
    verifier.assertNonCompletingActivityInstance("userTask", 1);
    verifier.assertIsCompletingActivityInstance("end2", 1);
  }
View Full Code Here

Examples of org.camunda.bpm.engine.impl.pvm.PvmExecution.signal()

    processInstance.start();
   
    PvmExecution execution = processInstance.findExecution("scopedWait");
    assertNotNull(execution);
   
    execution.signal(null, null);
 
    assertEquals(new ArrayList<String>(), processInstance.findActiveActivityIds());
    assertTrue(processInstance.isEnded());
  }
View Full Code Here

Examples of org.camunda.bpm.engine.impl.pvm.PvmExecution.signal()

    processInstance.start();
   
    PvmExecution activityInstance = processInstance.findExecution("scopedWait");
    assertNotNull(activityInstance);
   
    activityInstance.signal(null, null);
 
    assertEquals(new ArrayList<String>(), processInstance.findActiveActivityIds());
    assertTrue(processInstance.isEnded());
  }
}
View Full Code Here

Examples of org.camunda.bpm.engine.impl.pvm.PvmProcessInstance.signal()

      }
    }
   
    assertTrue(eventScopeFound);
   
    processInstance.signal(null, null);

    assertTrue(processInstance.isEnded());
        
  }
 
View Full Code Here

Examples of org.camunda.bpm.engine.impl.pvm.delegate.ActivityExecution.signal()

    // join compensating executions
    if(execution.getExecutions().isEmpty()) {
      if(execution.getParent() != null) {
        ActivityExecution parent = execution.getParent();
        execution.remove();
        parent.signal("compensationDone", signalData);
      }
    } else {
      ((ExecutionEntity)execution).forceUpdate();
    }
View Full Code Here

Examples of org.camunda.bpm.engine.impl.pvm.delegate.SignallableActivityBehavior.signal()

      throw new PvmException("cannot signal execution " + this.id + ": it has no current activity");
    }

    SignallableActivityBehavior activityBehavior = (SignallableActivityBehavior) activity.getActivityBehavior();
    try {
      activityBehavior.signal(this, signalName, signalData);
    } catch (RuntimeException e) {
      throw e;
    } catch (Exception e) {
      throw new PvmException("couldn't process signal '"+signalName+"' on activity '"+activity.getId()+"': "+e.getMessage(), e);
    }
View Full Code Here

Examples of org.jbpm.api.activity.ExternalActivityBehaviour.signal()

    ExternalActivityBehaviour externalActivityBehaviour = (ExternalActivityBehaviour) activity.getBehaviour();
   
    try {
      execution.setPropagation(Propagation.UNSPECIFIED);
      externalActivityBehaviour.signal(execution, signalName, parameters);

    } catch (RuntimeException e) {
      throw e;
     
    } catch (Exception e) {
View Full Code Here

Examples of org.jbpm.graph.exe.ProcessInstance.signal()

        instance.getContextInstance().getVariable("message"));

    // Move the process instance from its start state to the first state.
    // The configured action should execute and the appropriate message
    // should appear in the message process variable.
    instance.signal();
    assertEquals(
        "Instance is in first state",
        instance.getRootToken().getNode().getName(),
        "first");
    assertEquals(
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.