org.jacorb.notification.engine

Class DefaultTaskProcessor

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 $

Author: Alphonse Bendt

UNKNOWN:

Constructor Summary
DefaultTaskProcessor(Configuration config, TaskFactory taskFactory)
Start ClockDaemon Set up TaskExecutors Set up TaskFactory
Method Summary
voiddispose()
shutdown this TaskProcessor.
ScheduledFutureexecuteTaskAfterDelay(long delay, Runnable task)
ScheduledFutureexecuteTaskPeriodically(long intervall, Runnable task, boolean startImmediately)
intgetFilterWorkerPoolSize()
String[]getJMXNotificationTypes()
StringgetJMXObjectName()
intgetPullWorkerPoolSize()
TaskFactorygetTaskFactory()
voidprocessMessage(Message mesg)
process a Message. the various settings for the Message (timeout, starttime, stoptime) are checked and applied.
protected voidprocessMessageInternal(Message event)
process a Message. create FilterTask and schedule it.
voidregisterDisposable(Disposable disposable)
voidscheduleTimedPullTask(MessageSupplier messageSupplier)
Schedule ProxyPullConsumer for pull-Operation.
voidsetJMXCallback(JMXCallback callback)

Constructor Detail

DefaultTaskProcessor

public DefaultTaskProcessor(Configuration config, TaskFactory taskFactory)
Start ClockDaemon Set up TaskExecutors Set up TaskFactory

Method Detail

dispose

public void dispose()
shutdown this TaskProcessor. The TaskExecutors will be shutdown, the running Threads interrupted and all allocated ressources will be freed. As the active Threads will be interrupted pending Events will be discarded.

executeTaskAfterDelay

public ScheduledFuture executeTaskAfterDelay(long delay, Runnable task)

executeTaskPeriodically

public ScheduledFuture executeTaskPeriodically(long intervall, Runnable task, boolean startImmediately)

getFilterWorkerPoolSize

public int getFilterWorkerPoolSize()

UNKNOWN: description = "FilterPoolWorkers are used to invoke the Filters attached to Proxies and Admins" access = "read-only"

getJMXNotificationTypes

public String[] getJMXNotificationTypes()

getJMXObjectName

public String getJMXObjectName()

getPullWorkerPoolSize

public int getPullWorkerPoolSize()

UNKNOWN: description = "PullWorkers are used to invoke try_pull on PushSupplier-Clients" access = "read-only"

getTaskFactory

public TaskFactory getTaskFactory()

processMessage

public void processMessage(Message mesg)
process a Message. the various settings for the Message (timeout, starttime, stoptime) are checked and applied.

processMessageInternal

protected void processMessageInternal(Message event)
process a Message. create FilterTask and schedule it.

registerDisposable

public void registerDisposable(Disposable disposable)

scheduleTimedPullTask

public void scheduleTimedPullTask(MessageSupplier messageSupplier)
Schedule ProxyPullConsumer for pull-Operation. If a Supplier connects to a ProxyPullConsumer the ProxyPullConsumer needs to regularely poll the Supplier. This method queues a Task to run runPullEvent on the specified TimerEventSupplier

setJMXCallback

public void setJMXCallback(JMXCallback callback)