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 anEventInterceptor
forFederatedChangeEvent
s 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 aChangeRecordUpdater
which will be called to update eachChangeRecord
.void
introduceEventDispatcher(String sIdentifier, EventDispatcher dispatcher)
Introduce and possibly bind thisEventInterceptor
to the specifiedEventDispatcher
.void
onEvent(FederatedChangeEvent event)
Perform necessary processing of the specifiedEvent
.
-
-
-
Method Detail
-
onEvent
public void onEvent(FederatedChangeEvent event)
Perform necessary processing of the specifiedEvent
.- Specified by:
onEvent
in 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 thisEventInterceptor
to 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:
introduceEventDispatcher
in interfaceEventDispatcherAwareInterceptor<K>
- Parameters:
sIdentifier
- the unique name identifying this interceptordispatcher
- the dispatcher being introduced
-
getChangeRecordUpdater
public abstract ChangeRecordUpdater<K,V> getChangeRecordUpdater()
Return aChangeRecordUpdater
which will be called to update eachChangeRecord
.- Returns:
- a ChangeRecordUpdater
-
-