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.eventstore |
Definitions and implementations of the Event store, the mechanism that can load event streams and append events to
them.
|
org.axonframework.spring.messaging |
Utility classes used to connect Axon Event publishing mechanisms to a Spring Messaging Channel.
|
Modifier and Type | Class and Description |
---|---|
class |
AxonServerEventStore
Axon EventStore implementation that connects to the AxonIQ AxonServer Server to store and retrieve Events.
|
Modifier and Type | Method and Description |
---|---|
EventProcessingConfigurer |
EventProcessingModule.configureDefaultSubscribableMessageSource(Function<Configuration,SubscribableMessageSource<EventMessage<?>>> defaultSource) |
EventProcessingConfigurer |
EventProcessingConfigurer.configureDefaultSubscribableMessageSource(Function<Configuration,SubscribableMessageSource<EventMessage<?>>> defaultSource)
Configures which
SubscribableMessageSource to use for Subscribing Event Processors if none was explicitly
provided. |
EventProcessingConfigurer |
EventProcessingModule.registerSubscribingEventProcessor(String name,
Function<Configuration,SubscribableMessageSource<? extends EventMessage<?>>> messageSource) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerSubscribingEventProcessor(String name,
Function<Configuration,SubscribableMessageSource<? extends EventMessage<?>>> messageSource)
|
Modifier and Type | Interface and Description |
---|---|
interface |
EventBus
Specification of the mechanism on which the Event Listeners can subscribe for events and event publishers can publish
their events.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractEventBus
Base class for the Event Bus.
|
class |
SimpleEventBus
Implementation of the
EventBus that dispatches events in the thread the publishes them. |
Modifier and Type | Method and Description |
---|---|
SubscribableMessageSource<? extends EventMessage<?>> |
SubscribingEventProcessor.getMessageSource()
Returns the message source from which this processor receives its events
|
Modifier and Type | Method and Description |
---|---|
SubscribingEventProcessor.Builder |
SubscribingEventProcessor.Builder.messageSource(SubscribableMessageSource<? extends EventMessage<?>> messageSource)
Sets the
SubscribableMessageSource (e.g. |
Modifier and Type | Interface and Description |
---|---|
interface |
EventStore
Provides a mechanism to open streams from events in the the underlying event storage.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractEventStore
Abstract implementation of an
EventStore that uses a EventStorageEngine to store and load events. |
class |
EmbeddedEventStore
Implementation of an
EventStore that stores and fetches events using an EventStorageEngine . |
Modifier and Type | Class and Description |
---|---|
class |
InboundEventMessageChannelAdapter
Adapter class that publishes Events from a Spring Messaging Message Channel on the Event Bus.
|
Constructor and Description |
---|
ApplicationContextEventPublisher(SubscribableMessageSource<? extends EventMessage<?>> messageSource)
Initialize the publisher to forward events received from the given
messageSource to the application
context that this bean is part of. |
OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource,
org.springframework.messaging.MessageChannel channel)
Initialize an adapter to forward messages from the given
messageSource to the given channel . |
OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource,
org.springframework.messaging.MessageChannel channel,
Predicate<? super EventMessage<?>> filter)
Initialize an adapter to forward messages from the given
messageSource to the given channel . |
OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource,
org.springframework.messaging.MessageChannel channel,
Predicate<? super EventMessage<?>> filter,
EventMessageConverter eventMessageConverter)
Initialize an adapter to forward messages from the given
messageSource to the given channel . |
Copyright © 2010–2020. All rights reserved.