org.jacorb.notification.engine
public class DefaultTaskProcessor extends Object implements TaskProcessor, Disposable, JMXManageable, DefaultTaskProcessorMBean
Version: $Id: DefaultTaskProcessor.java,v 1.14 2006/07/07 12:38:44 alphonse.bendt Exp $
UNKNOWN:
Constructor Summary | |
---|---|
DefaultTaskProcessor(Configuration config, TaskFactory taskFactory)
Start ClockDaemon Set up TaskExecutors Set up TaskFactory |
Method Summary | |
---|---|
void | dispose()
shutdown this TaskProcessor. |
ScheduledFuture | executeTaskAfterDelay(long delay, Runnable task) |
ScheduledFuture | executeTaskPeriodically(long intervall, Runnable task, boolean startImmediately) |
int | getFilterWorkerPoolSize() |
String[] | getJMXNotificationTypes() |
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) |
void | scheduleTimedPullTask(MessageSupplier messageSupplier)
Schedule ProxyPullConsumer for pull-Operation. |
void | setJMXCallback(JMXCallback callback) |
UNKNOWN: description = "FilterPoolWorkers are used to invoke the Filters attached to Proxies and Admins" access = "read-only"
UNKNOWN: description = "PullWorkers are used to invoke try_pull on PushSupplier-Clients" access = "read-only"