org.mule.routing

Class EventProcessingThread

java.lang.Object

java.lang.Thread

org.mule.routing.EventProcessingThread

All Implemented Interfaces:

Runnable

public abstract class EventProcessingThread
extends Thread

A thread that detects and processes events.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected long	delayTime
protected Object	lock
protected Log	logger
protected boolean	stopRequested

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
EventProcessingThread(String name, long delayTime)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	delay(long timeToDelay)
protected abstract void	doRun() Detect and process events
void	processNow()
void	run()
void	stopProcessing() Stops the monitoring of the expired groups.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final Log logger

stopRequested

protected volatile boolean stopRequested

delayTime

protected long delayTime

lock

protected Object lock

Constructor Detail

EventProcessingThread

public EventProcessingThread(String name,
                     long delayTime)

Method Detail

processNow

public void processNow()

stopProcessing

public void stopProcessing()

Stops the monitoring of the expired groups.

delay

protected boolean delay(long timeToDelay)

run

public final void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

doRun

protected abstract void doRun()

Detect and process events