public class DefaultTaskProcessor extends java.lang.Object implements TaskProcessor, Disposable, JMXManageable, DefaultTaskProcessorMBean
JMXManageable.JMXCallback
Constructor and Description |
---|
DefaultTaskProcessor(org.jacorb.config.Configuration config,
TaskFactory taskFactory)
Start ClockDaemon Set up TaskExecutors Set up TaskFactory
|
Modifier and Type | Method and Description |
---|---|
void |
dispose()
shutdown this TaskProcessor.
|
ScheduledFuture |
executeTaskAfterDelay(long delay,
java.lang.Runnable task) |
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) |
public DefaultTaskProcessor(org.jacorb.config.Configuration config, TaskFactory taskFactory)
public TaskFactory getTaskFactory()
getTaskFactory
in interface TaskProcessor
public void dispose()
public void processMessage(Message mesg)
processMessage
in interface TaskProcessor
protected void processMessageInternal(Message event)
public void scheduleTimedPullTask(MessageSupplier messageSupplier)
scheduleTimedPullTask
in interface TaskProcessor
public ScheduledFuture executeTaskPeriodically(long intervall, java.lang.Runnable task, boolean startImmediately)
executeTaskPeriodically
in interface TaskProcessor
public 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