Uses of Interface
org.axonframework.messaging.core.SubscribableEventSource

Packages that use SubscribableEventSource

Package	Description
io.axoniq.framework.axonserver.connector.event	Part of the Axon Server Connector module.
io.axoniq.framework.messaging.multitenancy.axonserver.eventstreaming	Axon Server specific multi-tenant event streaming infrastructure, giving each tenant its own persistent stream and labelling the events it delivers with the tenant they belong to.
io.axoniq.framework.messaging.transformation.events	Part of the Axoniq Messaging folder.
io.axoniq.framework.workflow.runtime.test.utils	Test-only utility components used by the workflow test fixture and configuration, such as manual execution and scheduling controls, a mutable test clock, id generation, event publication helpers, and a pretty-printing recording event store.
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.tracing	Event-store tracing decorators and event-sourcing-specific SpanAttributesProvider implementations.
org.axonframework.extension.spring.messaging	Part of the Axon Extension module.
org.axonframework.messaging.eventhandling	Package for event handling components in Axon Framework.
org.axonframework.messaging.eventhandling.configuration	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.subscribing	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.tracing	Tracing decorators for event handling components.
org.axonframework.test.fixture	Part of the Axon Test module.

Uses of SubscribableEventSource in io.axoniq.framework.axonserver.connector.event

Classes in io.axoniq.framework.axonserver.connector.event that implement SubscribableEventSource

Modifier and Type	Class	Description
class	PersistentStreamEventSource	A SubscribableEventSource that receives events from a persistent stream on Axon Server.

Methods in io.axoniq.framework.axonserver.connector.event that return SubscribableEventSource

Modifier and Type	Method	Description
SubscribableEventSource	DefaultPersistentStreamEventSourceFactory.build(String name, io.axoniq.axonserver.connector.event.PersistentStreamProperties properties, Function<String,ScheduledExecutorService> schedulerFactory, int batchSize, Configuration configuration)
default SubscribableEventSource	PersistentStreamEventSourceFactory.build(String name, io.axoniq.axonserver.connector.event.PersistentStreamProperties properties, ScheduledExecutorService scheduler, int batchSize, Configuration configuration)	Builds the SubscribableEventSource consuming the persistent stream described by the given parameters, on the given, already created scheduler.
SubscribableEventSource	PersistentStreamEventSourceFactory.build(String name, io.axoniq.axonserver.connector.event.PersistentStreamProperties properties, Function<String,ScheduledExecutorService> schedulerFactory, int batchSize, Configuration configuration)	Builds the SubscribableEventSource consuming the persistent stream described by the given parameters, taking the ScheduledExecutorService instances it needs from the given schedulerFactory.

Uses of SubscribableEventSource in io.axoniq.framework.messaging.multitenancy.axonserver.eventstreaming

Classes in io.axoniq.framework.messaging.multitenancy.axonserver.eventstreaming that implement SubscribableEventSource

Modifier and Type	Class	Description
class	MultiTenantPersistentStreamEventSource	A SubscribableEventSource consuming one persistent stream per tenant, labelling every event it delivers with the tenant it came from.

Methods in io.axoniq.framework.messaging.multitenancy.axonserver.eventstreaming that return SubscribableEventSource

Modifier and Type	Method	Description
SubscribableEventSource	MultiTenantPersistentStreamEventSourceFactory.build(String name, io.axoniq.axonserver.connector.event.PersistentStreamProperties properties, ScheduledExecutorService scheduler, int batchSize, Configuration configuration)	Always throws, since a single ScheduledExecutorService shared across every tenant would defeat the per-tenant thread isolation this factory exists to provide.
SubscribableEventSource	MultiTenantPersistentStreamEventSourceFactory.build(String name, io.axoniq.axonserver.connector.event.PersistentStreamProperties properties, Function<String,ScheduledExecutorService> schedulerFactory, int batchSize, Configuration configuration)	Builds the SubscribableEventSource consuming the persistent stream described by the given parameters, taking the ScheduledExecutorService instances it needs from the given schedulerFactory.

Uses of SubscribableEventSource in io.axoniq.framework.messaging.transformation.events

Classes in io.axoniq.framework.messaging.transformation.events that implement SubscribableEventSource

Modifier and Type	Class	Description
final class	TransformingEventStore	EventStore decorator that applies an EventTransformerChain to every read path (entity loads, DCB reads, tracking-processor reads, ...).

Uses of SubscribableEventSource in io.axoniq.framework.workflow.runtime.test.utils

Classes in io.axoniq.framework.workflow.runtime.test.utils that implement SubscribableEventSource

Modifier and Type	Class	Description
class	PrettyPrintingRecordingEventStore	Pretty printing event store used for testing.

Uses of SubscribableEventSource in org.axonframework.eventsourcing.eventstore

Subinterfaces of SubscribableEventSource in org.axonframework.eventsourcing.eventstore

Modifier and Type	Interface	Description
interface	EventStore	Infrastructure component providing the means to start an EventStoreTransaction to append events and event source models from the underlying storage solution.

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

Modifier and Type	Class	Description
class	InterceptingEventStore	Decorator around the EventStore intercepting all events before they are appended or published with dispatch interceptors.
class	StorageEngineBackedEventStore	An EventStore implementation which uses an EventStorageEngine as its storage solution.

Uses of SubscribableEventSource in org.axonframework.eventsourcing.eventstore.tracing

Classes in org.axonframework.eventsourcing.eventstore.tracing that implement SubscribableEventSource

Modifier and Type	Class	Description
final class	TracingEventStore	Type-preserving tracing decorator for EventStore.

Uses of SubscribableEventSource in org.axonframework.extension.spring.messaging

Classes in org.axonframework.extension.spring.messaging that implement SubscribableEventSource

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.extension.spring.messaging with parameters of type SubscribableEventSource

Modifier	Constructor	Description
	ApplicationContextEventPublisher(SubscribableEventSource messageSource)	Initialize the publisher to forward events received from the given messageSource to the application context that this bean is part of.
	OutboundEventMessageChannelAdapter(SubscribableEventSource eventSource, org.springframework.messaging.MessageChannel channel)	Initialize an adapter to forward messages from the given eventSource to the given channel.
	OutboundEventMessageChannelAdapter(SubscribableEventSource eventSource, org.springframework.messaging.MessageChannel channel, Predicate<? super EventMessage> filter)	Initialize an adapter to forward messages from the given eventSource to the given channel.
	OutboundEventMessageChannelAdapter(SubscribableEventSource eventSource, org.springframework.messaging.MessageChannel channel, Predicate<? super EventMessage> filter, EventMessageConverter eventMessageConverter)	Initialize an adapter to forward messages from the given eventSource to the given channel.

Uses of SubscribableEventSource in org.axonframework.messaging.eventhandling

Subinterfaces of SubscribableEventSource in org.axonframework.messaging.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.messaging.eventhandling that implement SubscribableEventSource

Modifier and Type	Class	Description
class	DelegatingEventBus	Abstract implementation of an EventBus that delegates all calls to a given delegate.
class	InterceptingEventBus	Decorator around the EventBus interceptors all events before they are published with dispatch interceptors.
class	SimpleEventBus	Simple implementation of the EventBus that provides synchronous event publication with optional ProcessingContext integration for transactional event handling.

Uses of SubscribableEventSource in org.axonframework.messaging.eventhandling.configuration

Methods in org.axonframework.messaging.eventhandling.configuration that return SubscribableEventSource

Modifier and Type	Method	Description
SubscribableEventSource	SubscribableEventSourceDefinition.create(Configuration configuration)	Creates a SubscribableEventSource based on this definition and the provided configuration.

Uses of SubscribableEventSource in org.axonframework.messaging.eventhandling.processing.subscribing

Methods in org.axonframework.messaging.eventhandling.processing.subscribing that return SubscribableEventSource

Modifier and Type	Method	Description
SubscribableEventSource	SubscribingEventProcessorConfiguration.eventSource()	Returns the SubscribableEventSource to which this processor subscribes.

Methods in org.axonframework.messaging.eventhandling.processing.subscribing with parameters of type SubscribableEventSource

Modifier and Type	Method	Description
SubscribingEventProcessorConfiguration	SubscribingEventProcessorConfiguration.eventSource(SubscribableEventSource eventSource)	Sets the SubscribableEventSource (e.g. the EventBus) to which this EventProcessor implementation will subscribe itself to receive EventMessages.

Uses of SubscribableEventSource in org.axonframework.messaging.eventhandling.tracing

Classes in org.axonframework.messaging.eventhandling.tracing that implement SubscribableEventSource

Modifier and Type	Class	Description
final class	TracingEventBus	Type-preserving tracing decorator for EventBus.

Uses of SubscribableEventSource in org.axonframework.test.fixture

Classes in org.axonframework.test.fixture that implement SubscribableEventSource

Modifier and Type	Class	Description
class	RecordingEventBus	An EventBus implementation recording all the events that are published.
class	RecordingEventStore	An EventStore implementation recording all the events that are published.