Modifier and Type | Class and Description |
---|---|
static interface |
EventProcessorTask.ShutdownCallback
Callback that allows the SequenceManager to receive a notification when this scheduler finishes processing
events.
|
Constructor and Description |
---|
EventProcessorTask(Executor executor,
EventProcessorTask.ShutdownCallback shutDownCallback)
Initialize a scheduler using the given
executor . |
Modifier and Type | Method and Description |
---|---|
void |
run() |
boolean |
scheduleEvents(List<? extends EventMessage<?>> events,
Consumer<List<? extends EventMessage<?>>> processor)
Schedules a batch of events for processing.
|
public EventProcessorTask(Executor executor, EventProcessorTask.ShutdownCallback shutDownCallback)
executor
. This scheduler uses an unbounded queue to schedule
events.executor
- The executor service that will process the eventsshutDownCallback
- The callback to notify when the scheduler finishes processing eventspublic boolean scheduleEvents(List<? extends EventMessage<?>> events, Consumer<List<? extends EventMessage<?>>> processor)
events
- the events to scheduleprocessor
- the component that will do the actual processing of the eventsIllegalStateException
- if the queue in this scheduler does not have the capacity to add this eventCopyright © 2010–2019. All rights reserved.