io.micronaut.coherence.event

Class EventObserverSupport.UnsolicitedCommitEventHandler

java.lang.Object

io.micronaut.coherence.event.EventObserverSupport.UnsolicitedCommitEventHandler

All Implemented Interfaces:

com.tangosol.net.events.EventDispatcherAwareInterceptor<com.tangosol.net.events.partition.UnsolicitedCommitEvent>, com.tangosol.net.events.EventInterceptor<com.tangosol.net.events.partition.UnsolicitedCommitEvent>

Enclosing class:

EventObserverSupport

public static class EventObserverSupport.UnsolicitedCommitEventHandler
extends java.lang.Object

Handler for UnsolicitedCommitEvents.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.EnumSet<T>	eventTypes A set of event types the observer is interested in.
protected io.micronaut.coherence.event.ExecutableMethodEventObserver<E,?,?>	observer The observer method to delegate events to.
protected java.lang.String	serviceName

Constructor Summary

Constructors

Constructor and Description
UnsolicitedCommitEventHandler(io.micronaut.coherence.event.ExecutableMethodEventObserver<com.tangosol.net.events.partition.UnsolicitedCommitEvent,?,?> observer)

Method Summary

Modifier and Type	Method and Description
protected java.util.EnumSet<T>	eventTypes() Create a final set of event types to register this interceptor for.
java.lang.String	getScopeName() Return the name of the scope this interceptor should be registered with.
void	introduceEventDispatcher(java.lang.String identifier, com.tangosol.net.events.EventDispatcher dispatcher)
protected boolean	isApplicable(com.tangosol.net.events.EventDispatcher dispatcher, java.lang.String scopeName) Return true if this interceptor should be registered with a specified dispatcher.
void	onEvent(E event)
protected java.lang.String	removeScope(java.lang.String serviceName) Remove the scope prefix from a specified service name.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

serviceName

protected final java.lang.String serviceName

observer

protected final io.micronaut.coherence.event.ExecutableMethodEventObserver<E extends com.tangosol.net.events.Event<T>,?,?> observer

The observer method to delegate events to.

eventTypes

protected final java.util.EnumSet<T extends java.lang.Enum<T>> eventTypes

A set of event types the observer is interested in.

Constructor Detail

UnsolicitedCommitEventHandler

public UnsolicitedCommitEventHandler(io.micronaut.coherence.event.ExecutableMethodEventObserver<com.tangosol.net.events.partition.UnsolicitedCommitEvent,?,?> observer)

Method Detail

isApplicable

protected boolean isApplicable(com.tangosol.net.events.EventDispatcher dispatcher,
                               java.lang.String scopeName)

Return true if this interceptor should be registered with a specified dispatcher.

Parameters:

dispatcher - a dispatcher to register this interceptor with

scopeName - a scope name the observer is interested in, or null for all scopes

Returns:

true if this interceptor should be registered with a specified dispatcher; false otherwise

introduceEventDispatcher

public void introduceEventDispatcher(java.lang.String identifier,
                                     com.tangosol.net.events.EventDispatcher dispatcher)

Specified by:

introduceEventDispatcher in interface com.tangosol.net.events.EventDispatcherAwareInterceptor<E extends com.tangosol.net.events.Event<T>>

onEvent

public void onEvent(E event)

Specified by:

onEvent in interface com.tangosol.net.events.EventInterceptor<E extends com.tangosol.net.events.Event<T>>

eventTypes

protected java.util.EnumSet<T> eventTypes()

Create a final set of event types to register this interceptor for.

Returns:

a final set of event types to register this interceptor for

getScopeName

public java.lang.String getScopeName()

Return the name of the scope this interceptor should be registered with.

Returns:

the name of the scope this interceptor should be registered with

removeScope

protected java.lang.String removeScope(java.lang.String serviceName)

Remove the scope prefix from a specified service name.

Parameters:

serviceName - the service name to remove scope prefix from

Returns:

service name with scope prefix removed