List of typedState() Examples

Examples of typedState()

Examples of de.danet.an.workflow.api.Activity.typedState()

     + auk + " will be terminated.");
  } catch (CannotCompleteException e) {
      logger.error ("Cannot complete " + auk 
        + " (will be terminated): " + e.getMessage ());
  }
  if (act.typedState().workflowState() == State.OPEN) {
      try {
    act.terminate ();
      } catch (CannotStopException e) {
    logger.error 
        ("Cannot terminate " + auk + ": " + e.getMessage ());

View Full Code Here

Examples of de.danet.an.workflow.internalapi.ExtActivityLocal.typedState()

      String key = (String)i.next();
      Collections.sort ((List)transByTo.get(key), transComp);
  }
  for (Iterator i = process.stepsLocal().iterator (); i.hasNext(); ) {
      ExtActivityLocal a = (ExtActivityLocal)i.next();
      State as = a.typedState();
      String ak = a.key();
      if (as.isSameOrSubState(NotRunningState.NOT_STARTED)) {
    if (as.isSameOrSubState (NotStartedState.STARTABLE)) {
        startableActs.put (ak, a);
    } else if (as.isSameOrSubState (NotStartedState.UNKNOWN)

View Full Code Here

Examples of de.danet.an.workflow.internalapi.ExtActivityLocal.typedState()

  if (logger.isDebugEnabled ()) {
      logger.debug ("Trying transit from " 
        + trans.from() + " to " + trans.to());
  }
  ExtActivityLocal toAct = (ExtActivityLocal)trans.to();
  if (toAct.typedState().isSameOrSubState (NotStartedState.UNKNOWN)) {
      Collection triggers = isStartable (trans, toAct);
      if (triggers != null) {
    starts.add (new Object[] { toAct, triggers });
                return true;
      }

View Full Code Here

Examples of de.danet.an.workflow.internalapi.ExtActivityLocal.typedState()

     */
    public Collection startableActivities () {
  Collection res = new ArrayList ();
  for (Iterator i = startableActs.values().iterator (); i.hasNext(); ) {
      ExtActivityLocal a = (ExtActivityLocal)i.next();
      if (a.typedState().isSameOrSubState(NotRunningState.NOT_STARTED)) {
    res.add (a);
      }
  }
  return res;
    }

View Full Code Here

Examples of de.danet.an.workflow.internalapi.ExtActivityLocal.typedState()

  Collection returnList = new ArrayList();


  Iterator it = stepsLocal().iterator();
  while (it.hasNext()) {
      ExtActivityLocal act = (ExtActivityLocal)it.next();
      if (act.typedState().isSameOrSubState (s)) {
    returnList.add(act.toActivity());
      }
  }
  return returnList;
    }

View Full Code Here

Examples of de.danet.an.workflow.internalapi.ExtActivityLocal.typedState()

  // now find not completed/not started activities and/or abandon
  Collection openActs = new ArrayList ();
  for (Iterator i = activitiesOfBlockActivity
     (toi.activity.toString ()).iterator (); i.hasNext ();) {
      ExtActivityLocal a = (ExtActivityLocal)i.next ();
      if (a.typedState().isSameOrSubState(OpenState.RUNNING)
    || a.typedState().isSameOrSubState(NotRunningState.SUSPENDED)) {
    openActs.add (a);
    // complete this if deadline is synchronous
    if (dl.getExecution() == Deadline.SYNCHR) {
        a.initiateAbandoning(true, dl.getExceptionName());

View Full Code Here

Examples of de.danet.an.workflow.internalapi.ExtActivityLocal.typedState()

  Collection openActs = new ArrayList ();
  for (Iterator i = activitiesOfBlockActivity
     (toi.activity.toString ()).iterator (); i.hasNext ();) {
      ExtActivityLocal a = (ExtActivityLocal)i.next ();
      if (a.typedState().isSameOrSubState(OpenState.RUNNING)
    || a.typedState().isSameOrSubState(NotRunningState.SUSPENDED)) {
    openActs.add (a);
    // complete this if deadline is synchronous
    if (dl.getExecution() == Deadline.SYNCHR) {
        a.initiateAbandoning(true, dl.getExceptionName());
        transitionManager().update (a);

View Full Code Here

Examples of de.danet.an.workflow.internalapi.ExtProcessLocal.typedState()

  if (impl instanceof SubFlowImplementation) {
      Collection subs = performersLocal();
      for (Iterator i = subs.iterator (); i.hasNext();) {
    ExtProcessLocal p = (ExtProcessLocal)i.next();
    try {
        if (p.typedState().isSameOrSubState 
      (NotRunningState.SUSPENDED)) {
      p.abort ();
        } else {
      try {
          p.terminate ();

View Full Code Here

Examples of de.danet.an.workflow.localapi.ActivityLocal.typedState()

                        + auk + " will be terminated): " + e.getMessage ());
            } catch (CannotCompleteException e) {
                logger.error ("Cannot complete " + auk 
                        + " (will be terminated): " + e.getMessage ());
            }
            if (act.typedState().workflowState() == State.OPEN) {
                try {
                    act.terminate ();
                } catch (CannotStopException e) {
                    logger.error 
                    ("Cannot terminate " + auk + ": " + e.getMessage ());

View Full Code Here

Examples of de.danet.an.workflow.localapi.ActivityLocal.typedState()

   * @throws RemoteException if a system-level error occurs.
   */
  public boolean allActivitiesClosed() throws RemoteException {
      for (Iterator it = stepsLocal().iterator(); it.hasNext();) {
    ActivityLocal act = (ActivityLocal)it.next();
    if (! act.typedState().isSameOrSubState(State.CLOSED)) {
        return false;
    }
      }
      return true;
  }

View Full Code Here

0 1

TOP

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.