Class BatchEventsProcessor


  • public class BatchEventsProcessor
    extends Object
    This class transforms non-batched events to batch events It listens to usual SRepositoryListener events and groups them into SRepositoryEvents not thread-safe
    • Constructor Detail

      • BatchEventsProcessor

        public BatchEventsProcessor​(SRepository repository)
    • Method Detail

      • startBatching

        public void startBatching()
      • flush

        public List<SRepositoryEvent> flush()
        flushes all accumulated events stops listening to SRepository, if no new events are discovered
        Returns:
        result of batching: a list of SRepositoryEvents
      • finishBatching

        public void finishBatching()
      • dispose

        public void dispose()
      • init

        public void init()