Package | Description |
---|---|
org.axonframework.config | |
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.eventsourcing |
Classes related to event sourcing.
|
org.axonframework.eventsourcing.eventstore |
Definitions and implementations of the Event store, the mechanism that can load event streams and append events to
them.
|
org.axonframework.eventsourcing.eventstore.inmemory |
Modifier and Type | Method and Description |
---|---|
EventHandlingConfiguration |
EventHandlingConfiguration.registerTrackingProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source)
Registers a TrackingProcessor using the given
source to read messages from. |
EventHandlingConfiguration |
EventHandlingConfiguration.registerTrackingProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> sequencingPolicy)
Registers a TrackingProcessor with the given
name , reading from the given source and using the
given processorConfiguration . |
static <S> SagaConfiguration<S> |
SagaConfiguration.trackingSagaManager(Class<S> sagaType,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSourceBuilder)
Initialize a configuration for a Saga of given
sagaType , using a Tracking Event Processor to process
incoming Events from a Message Source provided by given messageSourceBuilder . |
Modifier and Type | Class and Description |
---|---|
class |
GenericTrackedEventMessage<T>
Generic implementation of a
TrackedEventMessage . |
Constructor and Description |
---|
TrackingEventProcessor(String name,
EventHandlerInvoker eventHandlerInvoker,
StreamableMessageSource<TrackedEventMessage<?>> messageSource,
TokenStore tokenStore,
TransactionManager transactionManager)
Initializes an EventProcessor with given
name that subscribes to the given messageSource for
events. |
TrackingEventProcessor(String name,
EventHandlerInvoker eventHandlerInvoker,
StreamableMessageSource<TrackedEventMessage<?>> messageSource,
TokenStore tokenStore,
TransactionManager transactionManager,
MessageMonitor<? super EventMessage<?>> messageMonitor)
Initializes an EventProcessor with given
name that subscribes to the given messageSource for
events. |
TrackingEventProcessor(String name,
EventHandlerInvoker eventHandlerInvoker,
StreamableMessageSource<TrackedEventMessage<?>> messageSource,
TokenStore tokenStore,
TransactionManager transactionManager,
MessageMonitor<? super EventMessage<?>> messageMonitor,
RollbackConfiguration rollbackConfiguration,
ErrorHandler errorHandler,
TrackingEventProcessorConfiguration config)
Initializes an EventProcessor with given
name that subscribes to the given messageSource for
events. |
Modifier and Type | Class and Description |
---|---|
class |
GenericTrackedDomainEventMessage<T>
Generic implementation of a
DomainEventMessage that is also a TrackedEventMessage . |
Modifier and Type | Method and Description |
---|---|
Stream<? extends TrackedEventMessage<?>> |
FilteringEventStorageEngine.readEvents(TrackingToken trackingToken,
boolean mayBlock) |
Modifier and Type | Method and Description |
---|---|
static <T> TrackedEventMessage<T> |
EventUtils.asTrackedEventMessage(EventMessage<T> eventMessage,
TrackingToken trackingToken)
|
Modifier and Type | Method and Description |
---|---|
Stream<? extends TrackedEventMessage<?>> |
SequenceEventStorageEngine.readEvents(TrackingToken trackingToken,
boolean mayBlock) |
Stream<? extends TrackedEventMessage<?>> |
EventStorageEngine.readEvents(TrackingToken trackingToken,
boolean mayBlock)
Open an event stream containing all events stored since given tracking token.
|
Stream<? extends TrackedEventMessage<?>> |
AbstractEventStorageEngine.readEvents(TrackingToken trackingToken,
boolean mayBlock) |
static Stream<TrackedEventMessage<?>> |
EventUtils.upcastAndDeserializeTrackedEvents(Stream<? extends TrackedEventData<?>> eventEntryStream,
Serializer serializer,
EventUpcaster upcasterChain,
boolean skipUnknownTypes)
Upcasts and deserializes the given
eventEntryStream using the given serializer and
upcasterChain . |
Modifier and Type | Method and Description |
---|---|
Stream<? extends TrackedEventMessage<?>> |
InMemoryEventStorageEngine.readEvents(TrackingToken trackingToken,
boolean mayBlock)
Open an event stream containing all events stored since given tracking token.
|
Copyright © 2010–2017. All rights reserved.