K
- type of the callback keypublic interface ScheduledCallback<K>
CallbackScheduler
is
reached. The CallbackScheduler
is available through
TaskContext.getCallbackScheduler()
.Modifier and Type | Method and Description |
---|---|
void |
onCallback(K key,
MessageCollector collector,
TaskCoordinator coordinator)
Invoked when the corresponding schedule time is reached.
|
void onCallback(K key, MessageCollector collector, TaskCoordinator coordinator)
key
- key for callbackcollector
- contains the means of sending message envelopes to the output stream.coordinator
- manages execution of tasks.