Event Listeners
and the Event Bus
.See: Description
Interface | Description |
---|---|
ErrorHandler |
Interface of the error handler that will be invoked if event processing fails.
|
EventBus |
Specification of the mechanism on which the Event Listeners can subscribe for events and event publishers can publish
their events.
|
EventHandlerInvoker |
Interface for an event message handler that defers handling to one or more other handlers.
|
EventListener |
Interface to be implemented by classes that can handle events.
|
EventListenerProxy |
Specialist interface for implementations of an event listener that redirect actual processing to another instance.
|
EventMessage<T> |
Represents a Message wrapping an Event, which is represented by its payload.
|
EventProcessingStrategy |
Interface describing a strategy for the processing of a batch of events.
|
EventProcessor |
An Event Processor processes event messages from an event queue or event bus.
|
ListenerInvocationErrorHandler |
Interface of an error handler that is invoked when an exception is triggered as result of an
EventListener
handling an event. |
TrackedEventMessage<T> |
Represents an
EventMessage containing a TrackingToken . |
Class | Description |
---|---|
AbstractEventBus |
Base class for the Event Bus.
|
AbstractEventProcessor |
Abstract implementation of an
EventProcessor . |
AnnotationEventListenerAdapter |
Adapter that turns any bean with
EventHandler annotated methods into an EventListener . |
ConcludesBatchParameterResolverFactory |
Paramater resolver factory for boolean event handler parameters annotated with
ConcludesBatch . |
ErrorContext |
Describes the context of an error.
|
GenericEventMessage<T> |
Generic implementation of the EventMessage interface.
|
GenericTrackedEventMessage<T> |
Generic implementation of a
TrackedEventMessage . |
LoggingErrorHandler |
Implementation of a
ListenerInvocationErrorHandler that logs exceptions as errors but otherwise does nothing to
prevent event handling from continuing. |
Segment |
A representation of a segment and corresponding mask with various capabilities.
|
SimpleEventBus |
Implementation of the
EventBus that supports streaming of events via SimpleEventBus.openStream(TrackingToken) but
only of the most recently published events as it is not backed by a cache or event storage. |
SimpleEventHandlerInvoker |
Implementation of an
EventHandlerInvoker that forwards events to a list of registered EventListeners . |
SubscribingEventProcessor |
Event processor implementation that
subscribes to the EventBus for
events. |
TimestampParameterResolverFactory | |
TrackingEventProcessor |
EventProcessor implementation that tracks events from a
StreamableMessageSource . |
TrackingEventProcessorConfiguration |
Configuration object for the
TrackingEventProcessor . |
Enum | Description |
---|---|
DirectEventProcessingStrategy |
Event processing strategy that directly initiates event processing.
|
PropagatingErrorHandler |
Singleton ErrorHandler implementation that does not do anything.
|
ThrowingListenerErrorHandler |
Implementation that simply throws the reported exception.
|
TrackingEventProcessor.State |
Exception | Description |
---|---|
EventProcessingException |
Exception thrown when an
EventProcessor failed to handle a batch of events. |
TransactionMethodExecutionException |
Wrapper for exceptions that occurred while calling an @BeforeTransaction or @AfterTransaction annotated method.
|
Annotation Type | Description |
---|---|
ConcludesBatch |
Annotation indication that a parameter on an
EventHandler method should be
injected with a value that informs whether the event is the last event of a processed batch of events. |
EventHandler |
Annotation to be placed on methods that can handle events.
|
Timestamp |
Annotation indication that a parameter on an Event Handler method should be injected with the Timestamp of an Event
Message.
|
Event Listeners
and the Event Bus
.Copyright © 2010–2017. All rights reserved.