public class NullStoreEventDispatcher<K,V> extends java.lang.Object implements StoreEventDispatcher<K,V>
Constructor and Description |
---|
NullStoreEventDispatcher() |
Modifier and Type | Method and Description |
---|---|
void |
addEventFilter(StoreEventFilter<K,V> eventFilter)
Adds an event filter.
|
void |
addEventListener(StoreEventListener<K,V> eventListener) |
StoreEventSink<K,V> |
eventSink()
Hands over an event sink for recording store events.
|
boolean |
isEventOrdering()
Indicates if the related
Store is delivering events ordered or not. |
static <K,V> StoreEventDispatcher<K,V> |
nullStoreEventDispatcher() |
void |
releaseEventSink(StoreEventSink<K,V> eventSink)
Releases the event sink after normal completion of an operation.
|
void |
releaseEventSinkAfterFailure(StoreEventSink<K,V> eventSink,
java.lang.Throwable throwable)
Releases the event sink after failure of an operation.
|
void |
removeEventListener(StoreEventListener<K,V> eventListener) |
void |
reset(StoreEventSink<K,V> eventSink)
Reset an event sink by dropping all queued events.
|
void |
setEventOrdering(boolean ordering)
Toggles event ordering.
|
void |
setSynchronous(boolean synchronous)
Toggles event synchronicity.
|
public static <K,V> StoreEventDispatcher<K,V> nullStoreEventDispatcher()
public StoreEventSink<K,V> eventSink()
StoreEventDispatcher
eventSink
in interface StoreEventDispatcher<K,V>
public void releaseEventSink(StoreEventSink<K,V> eventSink)
StoreEventDispatcher
releaseEventSink
in interface StoreEventDispatcher<K,V>
eventSink
- the event sink to releasepublic void releaseEventSinkAfterFailure(StoreEventSink<K,V> eventSink, java.lang.Throwable throwable)
StoreEventDispatcher
releaseEventSinkAfterFailure
in interface StoreEventDispatcher<K,V>
eventSink
- the event sink to releasethrowable
- the exceptionpublic void reset(StoreEventSink<K,V> eventSink)
StoreEventDispatcher
reset
in interface StoreEventDispatcher<K,V>
eventSink
- the event sink to resetpublic void addEventListener(StoreEventListener<K,V> eventListener)
addEventListener
in interface StoreEventSource<K,V>
public void removeEventListener(StoreEventListener<K,V> eventListener)
removeEventListener
in interface StoreEventSource<K,V>
public void addEventFilter(StoreEventFilter<K,V> eventFilter)
StoreEventSource
When multiple event filters are added, an event must be accepted by all to be valid.
addEventFilter
in interface StoreEventSource<K,V>
eventFilter
- the event filterpublic void setEventOrdering(boolean ordering)
StoreEventSource
If true
it means events will respect ordering of operations on a key basis.
setEventOrdering
in interface StoreEventSource<K,V>
ordering
- true
if ordering is desired, false
for no orderingpublic void setSynchronous(boolean synchronous)
StoreEventSource
If true
it means events will be fire synchronously.
setSynchronous
in interface StoreEventSource<K,V>
synchronous
- true
if synchronicity is desired, false
for asynchronous.public boolean isEventOrdering()
StoreEventSource
Store
is delivering events ordered or not.isEventOrdering
in interface StoreEventSource<K,V>
true
if ordering is on, false
otherwise