Class ListenerRegistry<E extends Event,​L extends EventListener<E>>

    • Field Detail

      • listeners

        protected final Set<L extends EventListener<E>> listeners
        Set of listeners that have registered.
    • Constructor Detail

      • ListenerRegistry

        public ListenerRegistry()
    • Method Detail

      • process

        public void process​(E event)
        Description copied from interface: EventSink
        Processes the specified event.
        Specified by:
        process in interface EventSink<E extends Event>
        event - event to be processed
      • onProcessLimit

        public void onProcessLimit()
        Description copied from interface: EventSink
        Handles notification that event processing time limit has been exceeded.
        Specified by:
        onProcessLimit in interface EventSink<E extends Event>
      • reportProblem

        protected void reportProblem​(E event,
                                     Throwable error)
        Reports a problem encountered while processing an event.
        event - event being processed
        error - error encountered while processing