Spring AMQP

org.springframework.util.exec
Class ExecuteWatchdog

java.lang.Object
  extended by org.springframework.util.exec.ExecuteWatchdog
All Implemented Interfaces:
Runnable

public class ExecuteWatchdog
extends Object
implements Runnable

Destroys a process running for too long. For example:

 ExecuteWatchdog watchdog = new ExecuteWatchdog(30000);
 Execute exec = new Execute(myloghandler, watchdog);
 exec.setCommandLine(mycmdline);
 int exitvalue = exec.execute();
 if (exitvalue != SUCCESS && watchdog.killedProcess()){
              // it was killed on purpose by the watchdog
 }
 

Author:
thomas.haas@softwired-inc.com, Stephane Bailliez
See Also:
Execute

Constructor Summary
ExecuteWatchdog(int timeout)
          Creates a new watchdog with a given timeout.
 
Method Summary
protected  void cleanUp()
          reset the monitor flag and the process.
 Exception getException()
           
 boolean isWatching()
          Indicates whether or not the watchdog is still monitoring the process.
 boolean killedProcess()
          Indicates whether the last process run was killed on timeout or not.
 void run()
          Watches the process and terminates it, if it runs for too long.
 void setDontkill(boolean b)
           
 void start(Process process, Thread execThread)
          Watches the given process and terminates it, if it runs for too long.
 void stop()
          Stops the watcher.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ExecuteWatchdog

public ExecuteWatchdog(int timeout)
Creates a new watchdog with a given timeout.

Parameters:
timeout - the timeout for the process in milliseconds. It must be greather than 0.
Method Detail

setDontkill

public void setDontkill(boolean b)

start

public void start(Process process,
                  Thread execThread)
Watches the given process and terminates it, if it runs for too long. All information from the previous run are reset.

Parameters:
process - the process to monitor. It cannot be null
Throws:
IllegalStateException - thrown if a process is still being monitored.

stop

public void stop()
Stops the watcher. It will notify all threads possibly waiting on this object.


run

public void run()
Watches the process and terminates it, if it runs for too long.

Specified by:
run in interface Runnable

cleanUp

protected void cleanUp()
reset the monitor flag and the process.


getException

public Exception getException()

isWatching

public boolean isWatching()
Indicates whether or not the watchdog is still monitoring the process.

Returns:
true if the process is still running, otherwise false.

killedProcess

public boolean killedProcess()
Indicates whether the last process run was killed on timeout or not.

Returns:
true if the process was killed otherwise false.

Spring AMQP

Copyright © 2011. All Rights Reserved.