Uses of Interface
org.axonframework.messaging.SubscribableMessageSource

Packages that use SubscribableMessageSource

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.eventsourcing.eventstore.legacyjpa
org.axonframework.spring.messaging	Utility classes used to connect Axon Event publishing mechanisms to a Spring Messaging Channel.

Uses of SubscribableMessageSource in org.axonframework.axonserver.connector.event.axon

Classes in org.axonframework.axonserver.connector.event.axon that implement SubscribableMessageSource

Modifier and Type	Class	Description
class	AxonServerEventStore	Axon EventStore implementation that connects to the AxonIQ AxonServer Server to store and retrieve Events.
class	PersistentStreamMessageSource	A SubscribableMessageSource that receives event from a persistent stream from Axon Server.

Methods in org.axonframework.axonserver.connector.event.axon that return SubscribableMessageSource

Modifier and Type	Method	Description
SubscribableMessageSource<EventMessage<?>>	PersistentStreamMessageSourceDefinition.create(Configuration configuration)

Uses of SubscribableMessageSource in org.axonframework.config

Methods in org.axonframework.config that return SubscribableMessageSource

Modifier and Type	Method	Description
SubscribableMessageSource<M>	SubscribableMessageSourceDefinition.create(Configuration configuration)	Creates a SubscribableMessageSource based on this definition and the provided configuration.

Methods in org.axonframework.config with parameters of type SubscribableMessageSource

Modifier and Type	Method	Description
protected EventProcessor	EventProcessingModule.subscribingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, SubscribableMessageSource<? extends EventMessage<?>> messageSource)	Default SubscribingEventProcessor configuration based on this configure module.

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

Modifier and Type	Method	Description
EventProcessingConfigurer	EventProcessingConfigurer.configureDefaultSubscribableMessageSource(Function<Configuration,SubscribableMessageSource<EventMessage<?>>> defaultSource)	Configures which SubscribableMessageSource to use for Subscribing Event Processors if none was explicitly provided.
EventProcessingConfigurer	EventProcessingModule.configureDefaultSubscribableMessageSource(Function<Configuration,SubscribableMessageSource<EventMessage<?>>> defaultSource)
EventProcessingConfigurer	EventProcessingConfigurer.registerSubscribingEventProcessor(String name, Function<Configuration,SubscribableMessageSource<? extends EventMessage<?>>> messageSource)	Registers a SubscribingEventProcessor with given name and messageSource within this Configuration.
EventProcessingConfigurer	EventProcessingModule.registerSubscribingEventProcessor(String name, Function<Configuration,SubscribableMessageSource<? extends EventMessage<?>>> messageSource)

Uses of SubscribableMessageSource in org.axonframework.eventhandling

Subinterfaces of SubscribableMessageSource in org.axonframework.eventhandling

Modifier and Type	Interface	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	Description
class	AbstractEventBus	Base class for the Event Bus.
class	SimpleEventBus	Implementation of the EventBus that dispatches events in the thread the publishes them.

Methods in org.axonframework.eventhandling that return SubscribableMessageSource

Modifier and Type	Method	Description
SubscribableMessageSource<? extends EventMessage<?>>	SubscribingEventProcessor.getMessageSource()	Returns the message source from which this processor receives its events

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

Modifier and Type	Method	Description
SubscribingEventProcessor.Builder	SubscribingEventProcessor.Builder.messageSource(SubscribableMessageSource<? extends EventMessage<?>> messageSource)	Sets the SubscribableMessageSource (e.g. the EventBus) to which this EventProcessor implementation will subscribe itself to receive EventMessages.

Uses of SubscribableMessageSource in org.axonframework.eventsourcing.eventstore

Subinterfaces of SubscribableMessageSource in org.axonframework.eventsourcing.eventstore

Modifier and Type	Interface	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	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.eventsourcing.eventstore.legacyjpa

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

Modifier and Type	Class	Description
class	EmbeddedEventStore	Deprecated. in favor of using EmbeddedEventStore which moved to jakarta.

Uses of SubscribableMessageSource in org.axonframework.spring.messaging

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

Modifier and Type	Class	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

Modifier	Constructor	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.