Class AbstractFederatedInterceptor<K,V>
- java.lang.Object
-
- com.tangosol.coherence.federation.events.AbstractFederatedInterceptor<K,V>
-
- All Implemented Interfaces:
EventDispatcherAwareInterceptor<FederatedChangeEvent>,EventInterceptor<FederatedChangeEvent>
public abstract class AbstractFederatedInterceptor<K,V> extends Object implements EventDispatcherAwareInterceptor<FederatedChangeEvent>
An abstract implementation of anEventInterceptorforFederatedChangeEvents applicable to remote participants.- Author:
- cl 2014.06.09
-
-
Constructor Summary
Constructors Constructor Description AbstractFederatedInterceptor()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description abstract ChangeRecordUpdater<K,V>getChangeRecordUpdater()Return aChangeRecordUpdaterwhich will be called to update eachChangeRecord.voidintroduceEventDispatcher(String sIdentifier, EventDispatcher dispatcher)Introduce and possibly bind thisEventInterceptorto the specifiedEventDispatcher.voidonEvent(FederatedChangeEvent event)Perform necessary processing of the specifiedEvent.
-
-
-
Method Detail
-
onEvent
public void onEvent(FederatedChangeEvent event)
Perform necessary processing of the specifiedEvent.- Specified by:
onEventin interfaceEventInterceptor<K>- Parameters:
event- the Event to be processed- See Also:
Event.nextInterceptor()
-
introduceEventDispatcher
public void introduceEventDispatcher(String sIdentifier, EventDispatcher dispatcher)
Introduce and possibly bind thisEventInterceptorto the specifiedEventDispatcher.Note that EventInterceptors are responsible for determining whether they should be registered with an EventDispatcher by calling
EventDispatcher.addEventInterceptor(com.tangosol.net.events.EventInterceptor<E>).- Specified by:
introduceEventDispatcherin interfaceEventDispatcherAwareInterceptor<K>- Parameters:
sIdentifier- the unique name identifying this interceptordispatcher- the dispatcher being introduced
-
getChangeRecordUpdater
public abstract ChangeRecordUpdater<K,V> getChangeRecordUpdater()
Return aChangeRecordUpdaterwhich will be called to update eachChangeRecord.- Returns:
- a ChangeRecordUpdater
-
-