Package org.axonframework.eventhandling
package org.axonframework.eventhandling
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus.-
ClassDescriptionAbstract base class of a serialized domain event.Base class for the Event Bus.Abstract Builder class to instantiate
AbstractEventBusimplementations.Abstract base class of a serialized event.Abstract implementation of anEventProcessor.Abstract Builder class to instantiate aAbstractEventProcessor.Abstract base class of a serialized domain event.References a newEventTrackerStatuswhich work just has started on.Annotation marking a Handler (or class) as being capable of handling replays, or not, depending on the value passed.Adapter that turns any bean withEventHandlerannotated methods into anEventMessageHandler.Annotation indication that a parameter on anEventHandlermethod should be injected with a value that informs whether the event is the last event of a processed batch of events.Parameter resolver factory for boolean event handler parameters annotated withConcludesBatch.Default implementation of theEventBusSpanFactory.Builder class to instantiate aDefaultEventBusSpanFactory.Default implementation of theEventProcessorSpanFactory.Builder class to instantiate aDefaultEventProcessorSpanFactory.Event processing strategy that directly initiates event processing.Annotation marking a Handler (or class) as not being able to handle replaysInterface describing the properties of serialized Domain Event Messages.Represents a Message that wraps a DomainEvent and an Event representing an important change in the Domain.Contract describing a component which is aware ofDomainEventMessagetheir sequences and is capable of providing the last known sequence number for a given Aggregate identifier.Describes the context of an error.Interface of the error handler that will be invoked if event processing fails.Specification of the mechanism on which the Event Listeners can subscribe for events and event publishers can publish their events.Span factory that creates spans for theEventBus.EventData<T>Interface describing the properties of serialized Event Messages.Annotation to be placed on methods that can handle events.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.Interface to be implemented by classes that can handle events.Exception thrown when anEventProcessorfailed to handle a batch of events.Interface describing a strategy for the processing of a batch of events.An Event Processor processes event messages from an event queue or event bus.Span factory that creates spans for theEventProcessorimplementations.Interface describing the status of aSegmentof aTrackingEventProcessor.Represent a listener that is notified whenever theMapofEventTrackerStatus' in theTrackingEventProcessorthis component is registered to has changed.Utility class for dealing with events.Implementation of aTrackingTokenthat 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.Generic implementation of a serialized domain event entry.Generic implementation of aDomainEventMessage.Generic implementation of the EventMessage interface.Generic implementation of aDomainEventMessagethat is also aTrackedEventMessage.Generic implementation of aTrackedEventMessage.Tracking token based on the global sequence number of an event.Interface of an error handler that is invoked when an exception is triggered as result of anEventMessageHandlerhandling an event.Implementation of aListenerInvocationErrorHandlerthat logs exceptions as errors but otherwise does nothing to prevent event handling from continuing.Special Wrapped Token implementation that keeps track of two separate tokens, of which the streams have been merged into a single one.Implementation ofEventHandlerInvokerwith capabilities to invoke several different invokers.ATrackingTokenimplementation combining severalTrackingTokensinto one.Implementation which allows for tracking processors to process messages from an arbitrary number of sources.Builder class to instantiate aMultiStreamableMessageSource.Singleton ErrorHandler implementation that does not do anything.References anEventTrackerStatuswhich no active work is occurring on.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.Token keeping track of the position before a reset was triggered.Annotation that can be placed on a method that is to be invoked when a reset is being prepared.Exception indicating that a reset is not supported by a component.A representation of a segment and corresponding mask with various capabilities.Annotation indicating that a parameter on an Event Handler method should be injected with the SequenceNumber of a DomainEventMessage.An extension of the AbstractAnnotatedParameterResolverFactory that accepts parameters of aLongtype annotated with theSequenceNumberannotation and assigns the sequenceNumber of the DomainEventMessage.ParameterResolver that resolves SequenceNumber parametersImplementation of theEventBusthat dispatches events in the thread the publishes them.Builder class to instantiate aSimpleEventBus.Implementation of anEventHandlerInvokerthat forwards events to a list of registeredEventMessageHandler.Builder class to instantiate aSimpleEventHandlerInvoker.AnEventProcessorwhich processes an event stream in segments.Event processor implementation thatsubscribesto theEventBusfor events.Builder class to instantiate aSubscribingEventProcessor.Annotation indication that a parameter on an Event Handler method should be injected with the Timestamp of an Event Message.Specialization of the DomainEventData class that includes the Token representing the position of this event in a stream.Interface describing the properties of serialized Event Messages containing aTrackingToken.Represents anEventMessagecontaining aTrackingToken.Implementation of theEventTrackerStatus, providing simply modification methods to switch from oneEventTrackerStatusvalue object to another.EventProcessor implementation that tracks events from aStreamableMessageSource.Builder class to instantiate aTrackingEventProcessor.Enum representing the possible states of the ProcessorConfiguration object for theTrackingEventProcessor.Describes a stream ofTrackedEventMessages.Tag interface identifying a token that is used to identify the position of an event in an event stream.Implementation of aParameterResolverFactorythat resolves theTrackingTokenof an event message if that message is aTrackedEventMessage.Wrapper for exceptions that occurred while calling an @BeforeTransaction or @AfterTransaction annotated method.Interface marking a token that wraps another token.Wrapper around anEventTrackerStatus, delegating all calls to adelegate.