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