Package 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 Object
Handler for UnsolicitedCommitEvents.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected final EnumSet<com.tangosol.net.events.partition.UnsolicitedCommitEvent.Type>
    eventTypes
    A set of event types the observer is interested in.
    protected final io.micronaut.coherence.event.ExecutableMethodEventObserver<com.tangosol.net.events.partition.UnsolicitedCommitEvent,?,?>
    observer
    The observer method to delegate events to.
    protected final String
    serviceName
     

  • Constructor Summary

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

  • Method Summary

    Modifier and Type
    Method
    Description
    protected EnumSet<com.tangosol.net.events.partition.UnsolicitedCommitEvent.Type>
    eventTypes()
    Create a final set of event types to register this interceptor for.
    String
    getScopeName()
    Return the name of the scope this interceptor should be registered with.
    void
    introduceEventDispatcher(String identifier, com.tangosol.net.events.EventDispatcher dispatcher)
     
    protected boolean
    isApplicable(com.tangosol.net.events.EventDispatcher dispatcher, String scopeName)
     
    void
    onEvent(com.tangosol.net.events.partition.UnsolicitedCommitEvent event)
     
    protected String
    removeScope(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 Details

    • serviceName

      protected final String serviceName

    • observer

      protected final io.micronaut.coherence.event.ExecutableMethodEventObserver<com.tangosol.net.events.partition.UnsolicitedCommitEvent,?,?> observer
      The observer method to delegate events to.

    • eventTypes

      protected final EnumSet<com.tangosol.net.events.partition.UnsolicitedCommitEvent.Type> eventTypes
      A set of event types the observer is interested in.

  • Constructor Details

    • UnsolicitedCommitEventHandler

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

  • Method Details

    • isApplicable

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

    • introduceEventDispatcher

      public void introduceEventDispatcher(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(com.tangosol.net.events.partition.UnsolicitedCommitEvent event)
      Specified by:
      onEvent in interface com.tangosol.net.events.EventInterceptor<E extends com.tangosol.net.events.Event<T>>

    • eventTypes

      protected EnumSet<com.tangosol.net.events.partition.UnsolicitedCommitEvent.Type> 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 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 String removeScope(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