|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jacorb.notification.engine.DefaultTaskProcessor
Nested Class Summary |
---|
Nested classes inherited from class 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. |
edu.emory.mathcs.backport.java.util.concurrent.ScheduledFuture |
executeTaskAfterDelay(long delay,
java.lang.Runnable task)
|
edu.emory.mathcs.backport.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. the various settings for the Message (timeout, starttime, stoptime) are checked and applied. |
protected void |
processMessageInternal(Message event)
process a Message. create FilterTask and schedule it. |
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) throws java.lang.InterruptedException
scheduleTimedPullTask
in interface TaskProcessor
java.lang.InterruptedException
public edu.emory.mathcs.backport.java.util.concurrent.ScheduledFuture executeTaskPeriodically(long intervall, java.lang.Runnable task, boolean startImmediately)
executeTaskPeriodically
in interface TaskProcessor
public edu.emory.mathcs.backport.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 |