Uses of Interface
org.axonframework.messaging.SubscribableMessageSource

Packages that use SubscribableMessageSource

Package	Description
org.axonframework.amqp.eventhandling.spring
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.kafka.eventhandling.producer
org.axonframework.spring.messaging	Utility classes used to connect Axon Event publishing mechanisms to a Spring Messaging Channel.

Uses of SubscribableMessageSource in org.axonframework.amqp.eventhandling.spring

Classes in org.axonframework.amqp.eventhandling.spring that implement SubscribableMessageSource

Modifier and Type	Class and Description
class	SpringAMQPMessageSource MessageListener implementation that deserializes incoming messages and forwards them to one or more event processors.

Constructors in org.axonframework.amqp.eventhandling.spring with parameters of type SubscribableMessageSource

Constructor and Description
SpringAMQPPublisher(SubscribableMessageSource<EventMessage<?>> messageSource) Initialize this instance to publish message as they are published on the given messageSource.

Uses of SubscribableMessageSource in org.axonframework.config

Method parameters in org.axonframework.config with type arguments of type SubscribableMessageSource

Modifier and Type	Method and Description
EventProcessingConfiguration	EventProcessingConfiguration.registerSubscribingEventProcessor(String name, Function<Configuration,SubscribableMessageSource<? extends EventMessage<?>>> messageSource) Register a subscribing event processor with given name that subscribes to the given messageSource.
EventHandlingConfiguration	EventHandlingConfiguration.registerSubscribingEventProcessor(String name, Function<Configuration,SubscribableMessageSource<? extends EventMessage<?>>> messageSource) Deprecated. use EventProcessingConfiguration.registerSubscribingEventProcessor(String, Function) instead
static <S> SagaConfiguration<S>	SagaConfiguration.subscribingSagaManager(Class<S> sagaType, Function<Configuration,SubscribableMessageSource<EventMessage<?>>> messageSourceBuilder) Initialize a configuration for a Saga of given sagaType, using a Subscribing Event Processor to process incoming Events from the message source provided by given messageSourceBuilder
static <S> SagaConfiguration<S>	SagaConfiguration.subscribingSagaManager(Class<S> sagaType, Function<Configuration,SubscribableMessageSource<EventMessage<?>>> messageSourceBuilder, Function<Configuration,EventProcessingStrategy> eventProcessingStrategy) Initialize a configuration for a Saga of given sagaType, using a Subscribing Event Processor to process incoming Events from the message source provided by given messageSourceBuilder.
static <S> SagaConfiguration<S>	SagaConfiguration.subscribingSagaManager(Class<S> sagaType, String processingGroup, Function<Configuration,SubscribableMessageSource<EventMessage<?>>> messageSourceBuilder, Function<Configuration,EventProcessingStrategy> eventProcessingStrategy) Initialize a configuration for a Saga of given sagaType, using a Subscribing Event Processor (with provided name) to process incoming Events from the message source provided by given messageSourceBuilder.

Uses of SubscribableMessageSource in org.axonframework.eventhandling

Subinterfaces of SubscribableMessageSource in org.axonframework.eventhandling

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.

Classes in org.axonframework.eventhandling that implement SubscribableMessageSource

Modifier and Type	Class and Description
class	AbstractEventBus Base class for the Event Bus.
class	SimpleEventBus Implementation of the EventBus that supports streaming of events via SimpleEventBus.openStream(TrackingToken) but only of the most recently published events as it is not backed by a cache or event storage.

Constructors in org.axonframework.eventhandling with parameters of type SubscribableMessageSource

Constructor and Description
SubscribingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, RollbackConfiguration rollbackConfiguration, SubscribableMessageSource<? extends EventMessage<?>> messageSource, EventProcessingStrategy processingStrategy, ErrorHandler errorHandler, MessageMonitor<? super EventMessage<?>> messageMonitor) Initializes an EventProcessor with given name that subscribes to the given messageSource for events.
SubscribingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, SubscribableMessageSource<? extends EventMessage<?>> messageSource, EventProcessingStrategy processingStrategy, ErrorHandler errorHandler, MessageMonitor<? super EventMessage<?>> messageMonitor) Initializes an EventProcessor with given name that subscribes to the given messageSource for events.
SubscribingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, SubscribableMessageSource<EventMessage<?>> messageSource) Initializes an EventProcessor with given name that subscribes to the given messageSource for events.
SubscribingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, SubscribableMessageSource<EventMessage<?>> messageSource, EventProcessingStrategy processingStrategy, ErrorHandler errorHandler) Initializes an EventProcessor with given name that subscribes to the given messageSource for events.

Uses of SubscribableMessageSource in org.axonframework.eventsourcing.eventstore

Subinterfaces of SubscribableMessageSource in org.axonframework.eventsourcing.eventstore

Modifier and Type	Interface and Description
interface	EventStore Provides a mechanism to open streams from events in the the underlying event storage.

Classes in org.axonframework.eventsourcing.eventstore that implement SubscribableMessageSource

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.

Uses of SubscribableMessageSource in org.axonframework.kafka.eventhandling.producer

Methods in org.axonframework.kafka.eventhandling.producer that return SubscribableMessageSource

Modifier and Type	Method and Description
SubscribableMessageSource<EventMessage<?>>	KafkaPublisherConfiguration.getMessageSource()

Methods in org.axonframework.kafka.eventhandling.producer with parameters of type SubscribableMessageSource

Modifier and Type	Method and Description
KafkaPublisherConfiguration.Builder<K,V>	KafkaPublisherConfiguration.Builder.withMessageSource(SubscribableMessageSource<EventMessage<?>> messageSource) Configure SubscribableMessageSource.

Uses of SubscribableMessageSource in org.axonframework.spring.messaging

Classes in org.axonframework.spring.messaging that implement SubscribableMessageSource

Modifier and Type	Class and Description
class	InboundEventMessageChannelAdapter Adapter class that publishes Events from a Spring Messaging Message Channel on the Event Bus.

Constructors in org.axonframework.spring.messaging with parameters of type SubscribableMessageSource

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.