public class DefaultTaskProcessor extends Object implements TaskProcessor, Disposable, JMXManageable
JMXManageable.JMXCallback
Constructor and Description |
---|
DefaultTaskProcessor(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,
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.
|
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(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, Runnable task, boolean startImmediately)
executeTaskPeriodically
in interface TaskProcessor
public ScheduledFuture executeTaskAfterDelay(long delay, Runnable task)
executeTaskAfterDelay
in interface TaskProcessor
public String getJMXObjectName()
getJMXObjectName
in interface JMXManageable
public void registerDisposable(Disposable disposable)
NotifyingDisposable
registerDisposable
in interface NotifyingDisposable
public String[] getJMXNotificationTypes()
getJMXNotificationTypes
in interface JMXManageable
public void setJMXCallback(JMXManageable.JMXCallback callback)
setJMXCallback
in interface JMXManageable
public int getFilterWorkerPoolSize()
public int getPullWorkerPoolSize()
Copyright © 2016 JacORB. All rights reserved.