Package de.danet.an.workflow.localapi

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

340
341
342
343
344
345
346
347
348
349
350
                        + 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
375
376
377
378
379
380
381
382
383
384
385
   * @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
1727
1728
1729
1730
1731
1732
1733
1734
1735
1736
1737
        NotRunningException {
  mayCloseCheck (ClosedState.TERMINATED);
  if (stepsLocal() != null) {
      for (Iterator it = stepsLocal().iterator(); it.hasNext();) {
    ActivityLocal act = (ActivityLocal)it.next();
    State s = act.typedState();
    if (s.isSameOrSubState(NotRunningState.SUSPENDED)
        || s == ClosedState.ABORTED) {
        throw new CannotStopException
      (act.toString() + " is suspended.");
    }
View Full Code Here
1740
1741
1742
1743
1744
1745
1746
1747
1748
1749
1750
      try {
    setPaTypedState(RunningState.TERMINATING);
    for (Iterator it = stepsLocal().iterator(); it.hasNext();) {
        ActivityLocal act = (ActivityLocal)it.next();
        if (act.workflowState() == State.OPEN
      && (!act.typedState().isSameOrSubState
          (NotRunningState.NOT_STARTED))) {
      try {
          act.terminate();
      } catch (CannotStopException e) {
          unstoppable = act.toString()
View Full Code Here
1779
1780
1781
1782
1783
1784
1785
1786
1787
1788
1789
      try {
    setPaTypedState(SuspendedState.ABORTING);
    for (Iterator it = stepsLocal().iterator(); it.hasNext();) {
        ActivityLocal act = (ActivityLocal)it.next();
        try {
      if (act.typedState().isSameOrSubState
          (NotRunningState.SUSPENDED)) {
          act.abort ();
      } else if (act.typedState().isSameOrSubState
           (OpenState.RUNNING)) {
          try {
View Full Code Here
1782
1783
1784
1785
1786
1787
1788
1789
1790
1791
1792
        ActivityLocal act = (ActivityLocal)it.next();
        try {
      if (act.typedState().isSameOrSubState
          (NotRunningState.SUSPENDED)) {
          act.abort ();
      } else if (act.typedState().isSameOrSubState
           (OpenState.RUNNING)) {
          try {
        act.terminate();
          } catch (CannotStopException e) {
        act.suspend ();
View Full Code Here
1983
1984
1985
1986
1987
1988
1989
1990
1991
1992
1993
      && (((SubProcRequester)req).execution()
    == SubFlowImplementation.SYNCHR)) {
      String key = ((SubProcRequester)req).requestingActivity();
      try {
    ActivityLocal act = lookupActivityLocal (key);
    if (act.typedState () != RunningState.ABANDONING
        && act.typedState() != ClosedCompletedState.ABANDONED) {
        act.terminate ();
    }
      } catch (InvalidKeyException e) {
    logger.warn (toString() + " cannot notify requesting activity "
View Full Code Here
1984
1985
1986
1987
1988
1989
1990
1991
1992
1993
1994
    == SubFlowImplementation.SYNCHR)) {
      String key = ((SubProcRequester)req).requestingActivity();
      try {
    ActivityLocal act = lookupActivityLocal (key);
    if (act.typedState () != RunningState.ABANDONING
        && act.typedState() != ClosedCompletedState.ABANDONED) {
        act.terminate ();
    }
      } catch (InvalidKeyException e) {
    logger.warn (toString() + " cannot notify requesting activity "
           + key + " : " + e.getMessage ());
View Full Code Here
2031
2032
2033
2034
2035
2036
2037
2038
2039
2040
2041
      && (((SubProcRequester)req).execution()
    == SubFlowImplementation.SYNCHR)) {
      String key = ((SubProcRequester)req).requestingActivity();
      try {
    ActivityLocal act = lookupActivityLocal (key);
    if (act.typedState() != RunningState.ABANDONING
        && act.typedState() != ClosedCompletedState.ABANDONED) {
        ProcessData res = processContext();
        FormalParameter[] fps
      = processDefinition().formalParameters();
        ProcessData pd = new ProcessDataWithParams (fps);
View Full Code Here
2032
2033
2034
2035
2036
2037
2038
2039
2040
2041
2042
    == SubFlowImplementation.SYNCHR)) {
      String key = ((SubProcRequester)req).requestingActivity();
      try {
    ActivityLocal act = lookupActivityLocal (key);
    if (act.typedState() != RunningState.ABANDONING
        && act.typedState() != ClosedCompletedState.ABANDONED) {
        ProcessData res = processContext();
        FormalParameter[] fps
      = processDefinition().formalParameters();
        ProcessData pd = new ProcessDataWithParams (fps);
        for (int i = 0; i < fps.length; i++) {
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.