|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jacorb.notification.engine.DefaultTaskProcessor
public class DefaultTaskProcessor
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface org.jacorb.notification.interfaces.JMXManageable |
---|
JMXManageable.JMXCallback |
Constructor Summary | |
---|---|
DefaultTaskProcessor(org.apache.avalon.framework.configuration.Configuration config,
TaskFactory taskFactory)
Start ClockDaemon Set up TaskExecutors Set up TaskFactory |
Method Summary | |
---|---|
void |
dispose()
shutdown this TaskProcessor. |
java.util.concurrent.ScheduledFuture |
executeTaskAfterDelay(long delay,
java.lang.Runnable task)
|
java.util.concurrent.ScheduledFuture |
executeTaskPeriodically(long intervall,
java.lang.Runnable task,
boolean startImmediately)
|
int |
getFilterWorkerPoolSize()
|
java.lang.String[] |
getJMXNotificationTypes()
|
java.lang.String |
getJMXObjectName()
|
int |
getPullWorkerPoolSize()
|
TaskFactory |
getTaskFactory()
|
void |
processMessage(Message mesg)
process a Message. |
protected void |
processMessageInternal(Message event)
process a Message. |
void |
registerDisposable(Disposable disposable)
the hooks registered by this method will be run when dispose is called. |
void |
scheduleTimedPullTask(MessageSupplier messageSupplier)
Schedule ProxyPullConsumer for pull-Operation. |
void |
setJMXCallback(JMXManageable.JMXCallback callback)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public DefaultTaskProcessor(org.apache.avalon.framework.configuration.Configuration config, TaskFactory taskFactory)
Method Detail |
---|
public TaskFactory getTaskFactory()
getTaskFactory
in interface TaskProcessor
public void dispose()
dispose
in interface org.picocontainer.Disposable
public void processMessage(Message mesg)
processMessage
in interface TaskProcessor
protected void processMessageInternal(Message event)
public void scheduleTimedPullTask(MessageSupplier messageSupplier)
scheduleTimedPullTask
in interface TaskProcessor
public java.util.concurrent.ScheduledFuture executeTaskPeriodically(long intervall, java.lang.Runnable task, boolean startImmediately)
executeTaskPeriodically
in interface TaskProcessor
public java.util.concurrent.ScheduledFuture executeTaskAfterDelay(long delay, java.lang.Runnable task)
executeTaskAfterDelay
in interface TaskProcessor
public java.lang.String getJMXObjectName()
getJMXObjectName
in interface JMXManageable
public void registerDisposable(Disposable disposable)
NotifyingDisposable
registerDisposable
in interface NotifyingDisposable
public java.lang.String[] getJMXNotificationTypes()
getJMXNotificationTypes
in interface JMXManageable
public void setJMXCallback(JMXManageable.JMXCallback callback)
setJMXCallback
in interface JMXManageable
public int getFilterWorkerPoolSize()
getFilterWorkerPoolSize
in interface DefaultTaskProcessorMBean
public int getPullWorkerPoolSize()
getPullWorkerPoolSize
in interface DefaultTaskProcessorMBean
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |