Package | Description |
---|---|
org.axonframework.axonserver.connector.event.axon | |
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 |
---|---|
TrackedEventMessage<?> |
EventBuffer.nextAvailable() |
Modifier and Type | Method and Description |
---|---|
Optional<TrackedEventMessage<?>> |
EventBuffer.peek() |
Modifier and Type | Method and Description |
---|---|
default EventProcessingConfigurer |
EventProcessingConfigurer.registerTrackingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source)
|
EventProcessingConfigurer |
EventProcessingConfigurer.registerTrackingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration)
Registers a
TrackingEventProcessor with given name , source and processorConfiguration within this Configurer. |
EventProcessingConfigurer |
EventProcessingModule.registerTrackingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration) |
Modifier and Type | Class and Description |
---|---|
class |
GenericTrackedDomainEventMessage<T>
Generic implementation of a
DomainEventMessage that is also a TrackedEventMessage . |
class |
GenericTrackedEventMessage<T>
Generic implementation of a
TrackedEventMessage . |
Modifier and Type | Method and Description |
---|---|
static <T> TrackedEventMessage<T> |
EventUtils.asTrackedEventMessage(EventMessage<T> eventMessage,
TrackingToken trackingToken)
|
Modifier and Type | Method and Description |
---|---|
static Stream<TrackedEventMessage<?>> |
EventUtils.upcastAndDeserializeTrackedEvents(Stream<? extends TrackedEventData<?>> eventEntryStream,
Serializer serializer,
EventUpcaster upcasterChain)
Upcasts and deserializes the given
eventEntryStream using the given serializer and
upcasterChain . |
Modifier and Type | Method and Description |
---|---|
TrackingEventProcessor.Builder |
TrackingEventProcessor.Builder.messageSource(StreamableMessageSource<TrackedEventMessage<?>> messageSource)
Sets the
StreamableMessageSource (e.g. |
Modifier and Type | Method and Description |
---|---|
Stream<? extends TrackedEventMessage<?>> |
FilteringEventStorageEngine.readEvents(TrackingToken trackingToken,
boolean mayBlock) |
Modifier and Type | Method and Description |
---|---|
Stream<? extends TrackedEventMessage<?>> |
AbstractEventStorageEngine.readEvents(TrackingToken trackingToken,
boolean mayBlock) |
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.
|
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.