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.
Constructor Summary |
ExpiryMonitor(MuleContext muleContext,
boolean onPollingNodeOnly)
|
ExpiryMonitor(String name,
int monitorFrequency,
ClassLoader contextClassLoader,
MuleContext muleContext,
boolean onPollingNodeOnly)
|
ExpiryMonitor(String name,
int monitorFrequency,
MuleContext muleContext,
boolean onPollingNodeOnly)
|
ExpiryMonitor(String name,
int monitorFrequency,
ScheduledThreadPoolExecutor scheduler,
MuleContext muleContext,
boolean onPollingNodeOnly)
|
ExpiryMonitor(String name,
MuleContext muleContext,
boolean onPollingNodeOnly)
|
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 ScheduledThreadPoolExecutor scheduler
ExpiryMonitor
public ExpiryMonitor(MuleContext muleContext,
boolean onPollingNodeOnly)
ExpiryMonitor
public ExpiryMonitor(String name,
MuleContext muleContext,
boolean onPollingNodeOnly)
ExpiryMonitor
public ExpiryMonitor(String name,
int monitorFrequency,
MuleContext muleContext,
boolean onPollingNodeOnly)
ExpiryMonitor
public ExpiryMonitor(String name,
int monitorFrequency,
ClassLoader contextClassLoader,
MuleContext muleContext,
boolean onPollingNodeOnly)
ExpiryMonitor
public ExpiryMonitor(String name,
int monitorFrequency,
ScheduledThreadPoolExecutor scheduler,
MuleContext muleContext,
boolean onPollingNodeOnly)
init
protected void init()
addExpirable
public void addExpirable(long value,
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-2012 MuleSoft, Inc.. All Rights Reserved.