public interface TaskProcessor
Modifier and Type | Method and Description |
---|---|
ScheduledFuture |
executeTaskAfterDelay(long delay,
java.lang.Runnable task) |
ScheduledFuture |
executeTaskPeriodically(long intervall,
java.lang.Runnable task,
boolean startImmediately) |
TaskFactory |
getTaskFactory() |
void |
processMessage(Message mesg)
process a Message.
|
void |
scheduleTimedPullTask(MessageSupplier dest)
Schedule ProxyPullConsumer for pull-Operation.
|
TaskFactory getTaskFactory()
void processMessage(Message mesg)
void scheduleTimedPullTask(MessageSupplier dest)
ScheduledFuture executeTaskPeriodically(long intervall, java.lang.Runnable task, boolean startImmediately)
ScheduledFuture executeTaskAfterDelay(long delay, java.lang.Runnable task)