public interface EventProcessingStrategy
SubscribingEventProcessorto handle events directly (in the same thread) or asynchronously.
void handle(List<? extends EventMessage<?>> events, Consumer<List<? extends EventMessage<?>>> processor)
events. Once the strategy decides it is opportune to process the events it should pass them back to the given
Note that the strategy may call back to the processor more than once for a single invocation of this method. Also note that a batch of events passed back to the processor may be made up of events from different batches.
events- Events to be processed
processor- Callback method on the processor that carries out the actual processing of events
Copyright © 2010–2021. All rights reserved.