Event Aggregator

The event aggregator periodically collects, modifies and finally aggregates file system events. After connecting an INode, it is started and running. It can be accessed as shown in the following example:

import org.rmatil.sync.event.aggregator.api.IEventAggregator;
import org.rmatil.sync.event.aggregator.api.IEventListener;
import org.rmatil.sync.event.aggregator.core.modifier.IModifier;


// ...
// Connect resp. bootstrap the node before
// ...



  // get event aggregator to dynamically add/remove listeners, modifiers and aggregators
  IEventAggregator eventAggregator = sync.getEventAggregator();

  // add a new Modifier
  IModifier modifier = ...
  eventAggregator.addModifier(modifier);

  // add listener which should be notified about file system changes
  IEventListener eventListener = ...
  eventAggregator.addListener(eventListener);

  // the interval in which events are modified and aggregated
  long aggregationInterval = eventAggregator.getAggregationInterval();