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
|
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–2024. All rights reserved.