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
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)

Constructor Detail

DefaultTaskProcessor

public DefaultTaskProcessor(Configuration config, TaskFactory taskFactory)

Start ClockDaemon Set up TaskExecutors Set up TaskFactory

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)