Examples of terminate()


Examples of com.volantis.mcs.repository.xml.XMLRepository.terminate()

                                    repository,
                                    file.getAbsolutePath());
                } finally {
                    // tear down
                    repositoryConnection.disconnect();
                    repository.terminate();
                }
            }
        });
    }
View Full Code Here

Examples of connection.peer.GenericPeerConnection.terminate()

  public void interrupt()
  {
    GenericPeerConnection connection = getConnection();
    if (connection != null)
    {
      connection.terminate();
    }
    interrupted = true;
  }

  public boolean isInterrupted()
View Full Code Here

Examples of de.anomic.search.Switchboard.terminate()

                    } else if ((downloaded == null) || (!downloaded.exists()) || (downloaded.length() == 0)) {
                        sb.getLog().logInfo("AUTO-UPDATE: omitting update because download failed (file cannot be found, is too small or signature was bad)");
                        prop.put("candeploy_autoUpdate", "4");
                    } else {
                        yacyRelease.deployRelease(downloaded);
                        sb.terminate(10, "manual release update to " + downloaded.getName());
                        sb.getLog().logInfo("AUTO-UPDATE: deploy and restart initiated");
                        prop.put("candeploy_autoUpdate", "1");
                    }
                }
            }
View Full Code Here

Examples of de.anomic.server.serverCore.terminate()

                    Log.logSevere("MAIN CONTROL LOOP", "PANIC: " + e.getMessage(),e);
                }
                // shut down
                if (RowCollection.sortingthreadexecutor != null) RowCollection.sortingthreadexecutor.shutdown();
                Log.logConfig("SHUTDOWN", "caught termination signal");
                server.terminate(false);
                server.interrupt();
                server.close();
                /*
                if (server.isAlive()) try {
                    // TODO only send request, don't read response (cause server is already down resulting in error)
View Full Code Here

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

      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 ());
      } catch (NotRunningException e) {
    logger.debug (auk + " not running although state is open?");
View Full Code Here

Examples of de.danet.an.workflow.api.Process.terminate()

      Process process = (Process)(it.next());
      try {
    process.abort();
      } catch (Exception e) {
    try {
        process.terminate();
    } catch (Exception ex) {
    }
      }
  }
    }
View Full Code Here

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

        if (p.typedState().isSameOrSubState
      (NotRunningState.SUSPENDED)) {
      p.abort ();
        } else {
      try {
          p.terminate ();
      } catch (CannotStopException e) {
          try {
        p.suspend ();
        p.abort ();
          } catch
View Full Code Here

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

                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 ());
                } catch (NotRunningException e) {
                    logger.warn (auk + " not running although state is open?");
View Full Code Here

Examples of de.danet.an.workflow.localcoreapi.WfProcessLocal.terminate()

    for (Iterator i = subs.iterator (); i.hasNext();) {
        WfProcessLocal p = (WfProcessLocal)i.next();
        if (p.workflowState() == State.CLOSED) {
      continue;
        }
        p.terminate ();
    }
      }     
  } catch (CannotStopException e) {
      throw new ApplicationNotStoppedException (e.getMessage());
  } catch (NotRunningException e) {
View Full Code Here

Examples of de.danet.an.workflow.omgcore.WfProcess.terminate()

      ("deferredChoiceTests", "terminateTest");
  WfProcess proc = mgr.createProcess(requester);
  String procKey = proc.key();
  proc.start();
  assertTrue(stateReached(proc, "open.running"));
  proc.terminate ();
  assertTrue(stateReached(proc, "closed.terminated"));
  procDir.removeProcess(proc);
    }

    /**
 
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.