org.mule.util.monitor
Class ExpiryMonitor
java.lang.Object
org.mule.util.monitor.ExpiryMonitor
- All Implemented Interfaces:
- Runnable, Disposable
public class ExpiryMonitor
- extends Object
- implements Runnable, Disposable
ExpiryMonitor
can monitor objects beased on an expiry time and can
invoke a callback method once the object time has expired. If the object does
expire it is removed from this monitor.
Field Summary |
protected static Log |
logger
logger used by this class |
protected edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor |
scheduler
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
logger
protected static final Log logger
- logger used by this class
scheduler
protected edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor scheduler
ExpiryMonitor
public ExpiryMonitor(String name)
ExpiryMonitor
public ExpiryMonitor(String name,
int monitorFrequency)
ExpiryMonitor
public ExpiryMonitor(String name,
int monitorFrequency,
edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor scheduler)
init
protected void init()
addExpirable
public void addExpirable(long value,
edu.emory.mathcs.backport.java.util.concurrent.TimeUnit timeUnit,
Expirable expirable)
- Adds an expirable object to monitor. If the Object is already being monitored
it will be reset and the millisecond timeout will be ignored
- Parameters:
value
- the expiry valuetimeUnit
- The time unit of the Expiry valueexpirable
- the objec that will expire
isRegistered
public boolean isRegistered(Expirable expirable)
removeExpirable
public void removeExpirable(Expirable expirable)
resetExpirable
public void resetExpirable(Expirable expirable)
run
public void run()
- The action to be performed by this timer task.
- Specified by:
run
in interface Runnable
dispose
public void dispose()
- Description copied from interface:
Disposable
- A lifecycle method where implementor should free up any resources. If an
exception is thrown it should just be logged and processing should continue.
This method should not throw Runtime exceptions.
- Specified by:
dispose
in interface Disposable
Copyright © 2003-2009 MuleSource, Inc.. All Rights Reserved.