eu.xtreemos.xosd.crondaemon
Class CronDaemon
java.lang.Object
eu.xtreemos.system.eventmachine.stage.AbstractStage
eu.xtreemos.system.eventmachine.stage.AbstractReceivingStage
eu.xtreemos.system.eventmachine.stage.Abstract2wayStage
eu.xtreemos.xosd.crondaemon.CronDaemon
- All Implemented Interfaces:
- eu.xtreemos.system.eventmachine.queue.IEventHandler, eu.xtreemos.system.eventmachine.stage.IStage
public class CronDaemon
- extends eu.xtreemos.system.eventmachine.stage.Abstract2wayStage
Fields inherited from class eu.xtreemos.system.eventmachine.stage.Abstract2wayStage |
context, counter, curContext, sink |
Fields inherited from class eu.xtreemos.system.eventmachine.stage.AbstractReceivingStage |
queue |
Fields inherited from class eu.xtreemos.system.eventmachine.stage.AbstractStage |
handlerChain, handlerGroup, handlerThreads, name, running, serviceListeners |
Methods inherited from class eu.xtreemos.system.eventmachine.stage.Abstract2wayStage |
getContext, removeContext, SendException, SendException, SendException, SendReply, SendReply, SendReply, setSink |
Methods inherited from class eu.xtreemos.system.eventmachine.stage.AbstractReceivingStage |
dequeue, getSource |
Methods inherited from class eu.xtreemos.system.eventmachine.stage.AbstractStage |
addHandler, addHandler, addServiceListener, getName, getShortName, getThreadCount, init, notifyServiceInitialised, notifyServiceStarted, notifyServiceStopped, processEvent, removeHandler, removeServiceListener, setThreadCount, start, stop |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
entries
private java.util.ArrayList<CronDaemonEntry> entries
waitThread
private CronDaemon.WaiterThread waitThread
executionCoutner
private int executionCoutner
isPaused
private java.lang.Boolean isPaused
CronDaemon
public CronDaemon()
getDaemons
public java.util.ArrayList<CommunicationAddress> getDaemons()
updateWaitTime
private void updateWaitTime()
handleEntry
private CronDaemonEntry handleEntry(CronDaemonEntry entry)
insert
private boolean insert(CronDaemonEntry entry)
addEntry
public void addEntry(CronDaemonEntry entry)
executeTop
private void executeTop()
numExecutions
public int numExecutions()
killEntries
public void killEntries()
pause
public void pause(java.lang.Long ms)
resume
public void resume()
removeEntry
public void removeEntry(CronDaemonEntry entry)
groupByTag
private java.util.ArrayList<CronDaemonEntry> groupByTag(java.lang.String tag)
groupByTags
private java.util.ArrayList<CronDaemonEntry> groupByTags(java.util.ArrayList<java.lang.String> tags)
groupByTags
private java.util.ArrayList<CronDaemonEntry> groupByTags(java.lang.String tag,
java.lang.Object value)
groupByTags
private java.util.ArrayList<CronDaemonEntry> groupByTags(java.util.Hashtable<java.lang.String,java.util.ArrayList<java.lang.Object>> tags)
groupByUUID
private java.util.ArrayList<CronDaemonEntry> groupByUUID(java.lang.String uuid)
groupByUUIDs
private java.util.ArrayList<CronDaemonEntry> groupByUUIDs(java.util.ArrayList<java.lang.String> uuids)
remove
private void remove(java.util.ArrayList<CronDaemonEntry> entries)
removeUUID
public void removeUUID(java.lang.String uuid)
removeTaggedByStr
public void removeTaggedByStr(java.lang.String tag)
removeTaggedByArr
public void removeTaggedByArr(java.util.ArrayList<java.lang.String> tags)
removeTaggedByHash
public void removeTaggedByHash(java.util.Hashtable<java.lang.String,java.util.ArrayList<java.lang.Object>> tags)
getHandledEventType
public java.lang.String getHandledEventType()
- Specified by:
getHandledEventType
in class eu.xtreemos.system.eventmachine.stage.AbstractReceivingStage
handleEvent
public void handleEvent(java.lang.Object event)
throws java.lang.Exception
- Specified by:
handleEvent
in interface eu.xtreemos.system.eventmachine.queue.IEventHandler
- Specified by:
handleEvent
in class eu.xtreemos.system.eventmachine.stage.AbstractReceivingStage
- Throws:
java.lang.Exception
test1
public void test1(java.lang.String s1,
java.lang.String s2,
java.lang.String s3)