Event Listeners
and the Event Bus
.See: Description
Interface | Description |
---|---|
DomainEventData<T> |
Interface describing the properties of serialized Domain Event Messages.
|
DomainEventMessage<T> |
Represents a Message that wraps a DomainEvent and an Event representing an important change in the Domain.
|
DomainEventSequenceAware |
Contract describing a component which is aware of
DomainEventMessage their sequences and is capable of
providing the last known sequence number for a given Aggregate identifier. |
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.
|
EventBusSpanFactory |
Span factory that creates spans for the
EventBus . |
EventData<T> |
Interface describing the properties of serialized Event Messages.
|
EventHandlerInvoker |
Interface for an event message handler that defers handling to one or more other handlers.
|
EventMessage<T> |
Represents a Message wrapping an Event, which is represented by its payload.
|
EventMessageHandler |
Interface to be implemented by classes that can handle events.
|
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.
|
EventProcessorSpanFactory |
Span factory that creates spans for the
EventProcessor implementations. |
EventTrackerStatus |
Interface describing the status of a
Segment of a TrackingEventProcessor . |
EventTrackerStatusChangeListener |
Represent a listener that is notified whenever the
Map of EventTrackerStatus ' in the TrackingEventProcessor this component is registered to has changed. |
ListenerInvocationErrorHandler |
Interface of an error handler that is invoked when an exception is triggered as result of an
EventMessageHandler handling an event. |
StreamingEventProcessor |
An
EventProcessor which processes an event stream in segments. |
TrackedEventData<T> |
Interface describing the properties of serialized Event Messages containing a
TrackingToken . |
TrackedEventMessage<T> |
Represents an
EventMessage containing a TrackingToken . |
TrackingEventStream |
Describes a stream of
TrackedEventMessages . |
TrackingToken |
Tag interface identifying a token that is used to identify the position of an event in an event stream.
|
WrappedToken |
Interface marking a token that wraps another token.
|
Class | Description |
---|---|
AbstractDomainEventEntry<T> |
Abstract base class of a serialized domain event.
|
AbstractEventBus |
Base class for the Event Bus.
|
AbstractEventBus.Builder |
Abstract Builder class to instantiate
AbstractEventBus implementations. |
AbstractEventEntry<T> |
Abstract base class of a serialized event.
|
AbstractEventProcessor |
Abstract implementation of an
EventProcessor . |
AbstractEventProcessor.Builder |
Abstract Builder class to instantiate a
AbstractEventProcessor . |
AbstractSequencedDomainEventEntry<T> |
Abstract base class of a serialized domain event.
|
AddedTrackerStatus |
References a new
EventTrackerStatus which work just has started on. |
AnnotationEventHandlerAdapter |
Adapter that turns any bean with
EventHandler annotated methods into an EventMessageHandler . |
ConcludesBatchParameterResolverFactory |
Parameter resolver factory for boolean event handler parameters annotated with
ConcludesBatch . |
DefaultEventBusSpanFactory |
Default implementation of the
EventBusSpanFactory . |
DefaultEventBusSpanFactory.Builder |
Builder class to instantiate a
DefaultEventBusSpanFactory . |
DefaultEventProcessorSpanFactory |
Default implementation of the
EventProcessorSpanFactory . |
DefaultEventProcessorSpanFactory.Builder |
Builder class to instantiate a
DefaultEventProcessorSpanFactory . |
ErrorContext |
Describes the context of an error.
|
EventUtils |
Utility class for dealing with events.
|
GapAwareTrackingToken |
Implementation of a
TrackingToken that uses the global insertion sequence number of the event to determine
tracking order and additionally stores a set of possible gaps that have been detected while tracking the event
store. |
GenericDomainEventEntry<T> |
Generic implementation of a serialized domain event entry.
|
GenericDomainEventMessage<T> |
Generic implementation of a
DomainEventMessage . |
GenericEventMessage<T> |
Generic implementation of the EventMessage interface.
|
GenericTrackedDomainEventMessage<T> |
Generic implementation of a
DomainEventMessage that is also a TrackedEventMessage . |
GenericTrackedEventMessage<T> |
Generic implementation of a
TrackedEventMessage . |
GlobalSequenceTrackingToken |
Tracking token based on the global sequence number of an event.
|
LoggingErrorHandler |
Implementation of a
ListenerInvocationErrorHandler that logs exceptions as errors but otherwise does nothing
to prevent event handling from continuing. |
MergedTrackingToken |
Special Wrapped Token implementation that keeps track of two separate tokens, of which the streams have been merged
into a single one.
|
MultiEventHandlerInvoker |
Implementation of
EventHandlerInvoker with capabilities to invoke several different invokers. |
MultiSourceTrackingToken |
A
TrackingToken implementation combining several TrackingTokens into one. |
MultiStreamableMessageSource |
Implementation which allows for tracking processors to process messages from an arbitrary number of sources.
|
MultiStreamableMessageSource.Builder |
Builder class to instantiate a
MultiStreamableMessageSource . |
RemovedTrackerStatus |
References an
EventTrackerStatus which no active work is occurring on. |
ReplayToken |
Token keeping track of the position before a reset was triggered.
|
Segment |
A representation of a segment and corresponding mask with various capabilities.
|
SequenceNumberParameterResolverFactory |
An extension of the AbstractAnnotatedParameterResolverFactory that accepts parameters of a
Long type
annotated with the SequenceNumber annotation and assigns the sequenceNumber of the DomainEventMessage. |
SequenceNumberParameterResolverFactory.SequenceNumberParameterResolver |
ParameterResolver that resolves SequenceNumber parameters
|
SimpleEventBus |
Implementation of the
EventBus that dispatches events in the thread the publishes them. |
SimpleEventBus.Builder |
Builder class to instantiate a
SimpleEventBus . |
SimpleEventHandlerInvoker |
Implementation of an
EventHandlerInvoker that forwards events to a list of registered EventMessageHandler . |
SimpleEventHandlerInvoker.Builder<B extends SimpleEventHandlerInvoker.Builder<?>> |
Builder class to instantiate a
SimpleEventHandlerInvoker . |
SubscribingEventProcessor |
Event processor implementation that
subscribes to the EventBus for
events. |
SubscribingEventProcessor.Builder |
Builder class to instantiate a
SubscribingEventProcessor . |
TimestampParameterResolverFactory | |
TrackedDomainEventData<T> |
Specialization of the DomainEventData class that includes the Token representing the position of this event in
a stream.
|
TrackerStatus |
Implementation of the
EventTrackerStatus , providing simply modification methods to switch from one EventTrackerStatus value object to another. |
TrackingEventProcessor |
EventProcessor implementation that tracks events from a
StreamableMessageSource . |
TrackingEventProcessor.Builder |
Builder class to instantiate a
TrackingEventProcessor . |
TrackingEventProcessorConfiguration |
Configuration object for the
TrackingEventProcessor . |
TrackingTokenParameterResolverFactory |
Implementation of a
ParameterResolverFactory that resolves the TrackingToken of an event message
if that message is a TrackedEventMessage . |
WrappedTrackerStatus |
Wrapper around an
EventTrackerStatus , delegating all calls to a delegate . |
Enum | Description |
---|---|
DirectEventProcessingStrategy |
Event processing strategy that directly initiates event processing.
|
PropagatingErrorHandler |
Singleton ErrorHandler implementation that does not do anything.
|
ReplayStatus |
Type that can be used as parameter of Event Handler methods that indicates whether a message is delivered as part of
a replay, or in regular operations.
|
TrackingEventProcessor.State |
Enum representing the possible states of the Processor
|
Exception | Description |
---|---|
EventProcessingException |
Exception thrown when an
EventProcessor failed to handle a batch of events. |
ResetNotSupportedException |
Exception indicating that a reset is not supported by a component.
|
TransactionMethodExecutionException |
Wrapper for exceptions that occurred while calling an @BeforeTransaction or @AfterTransaction annotated method.
|
Annotation Type | Description |
---|---|
AllowReplay |
Annotation marking a Handler (or class) as being capable of handling replays, or not, depending on the value passed.
|
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. |
DisallowReplay |
Annotation marking a Handler (or class) as not being able to handle replays
When placed on the type (class) level, the setting applies to all handlers that don't explicitly override it
on the method level.
|
EventHandler |
Annotation to be placed on methods that can handle events.
|
ResetHandler |
Annotation that can be placed on a method that is to be invoked when a reset is being prepared.
|
SequenceNumber |
Annotation indicating that a parameter on an Event Handler method should be injected with the SequenceNumber of
a DomainEventMessage.
|
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–2025. All rights reserved.