de.ipcon.db

Class ExecutionPolicyKeepRunning

java.lang.Object

de.ipcon.db.ExecutionPolicy

de.ipcon.db.ExecutionPolicyKeepRunning

All Implemented Interfaces:

java.lang.Runnable

public class ExecutionPolicyKeepRunning
extends ExecutionPolicy
implements java.lang.Runnable

This ExecutionPolicy is for BS that needs to keep running and/or handle their scheduling by themself. If a Service using this Policy quits due to an exception, it is restarted again immediately. disable() to stop the service and keep it from restarting.

 
 <ExecutionPolicy>
   <KeepRunning timeout="60"/>
 </ExecutionPolicy>
 
 

timeout - If element available, abort a running ServiceInstanceI after at most [value] seconds, causing it to be restarted. Default: Disabled.

Constructor Summary

Constructors

Constructor and Description
ExecutionPolicyKeepRunning(ServiceInstanceI _si, electric.xml.Element _confRoot, ServiceI _service, java.lang.String _description)

Method Summary

Modifier and Type	Method and Description
void	disable() Disables a running Service and stops its worker thread.
void	enable() Enables and starts this Executionpolicy, causing the BS to be executed at the next scheduled time.
void	run() From Runnable Interface.
boolean	tryRestart(java.lang.Throwable re) Tries to restart this service after an Exception a few times and returns true if the restart was successful.

Methods inherited from class de.ipcon.db.ExecutionPolicy

finish, getConfRoot, getDescription, getInstance, getService, getSi, getWDTimeoutMillis, resetUnrecoverableError, setConfRoot, setDescription, setService, setSi, setWDTimeoutMillis, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ExecutionPolicyKeepRunning

public ExecutionPolicyKeepRunning(ServiceInstanceI _si,
                                  electric.xml.Element _confRoot,
                                  ServiceI _service,
                                  java.lang.String _description)

Method Detail

enable

public void enable()

Description copied from class: ExecutionPolicy

Enables and starts this Executionpolicy, causing the BS to be executed at the next scheduled time.

Overrides:

enable in class ExecutionPolicy

run

public void run()

From Runnable Interface. Is called automatically after calling enable() and executes the BusinessService until disable() has been called (asynchronously) or the service quits with an Exception. If the Service quit with an Exception, then a new ExecutionPolicy for this ServiceInstanceI is initialized and this old ExecutionPolicy is stopped.

Specified by:

run in interface java.lang.Runnable

tryRestart

public boolean tryRestart(java.lang.Throwable re)

Tries to restart this service after an Exception a few times and returns true if the restart was successful. False otherwise. If restart was successful, then a new ExecutionPolicy has been created for the same ServiceInstanceI (and different ServiceI) that is executing our service.

Parameters:

re -

Returns:

true, if restarting this service was successful, false otherwise.

disable

public void disable()

Description copied from class: ExecutionPolicy

Disables a running Service and stops its worker thread.

Overrides:

disable in class ExecutionPolicy