Uses of Interface
org.axonframework.common.Registration

Packages that use Registration

Package	Description
io.axoniq.framework.axonserver.connector.event	Part of the Axon Server Connector module.
io.axoniq.framework.messaging.multitenancy.api	Contains the multi-tenancy API, like the tenant descriptor, tenant provider, and tenant resolution contracts.
io.axoniq.framework.messaging.multitenancy.axonserver.api	Part of the Axoniq Framework multi-tenancy module.
io.axoniq.framework.messaging.multitenancy.axonserver.commandhandling	Part of the Axoniq Framework multi-tenancy module.
io.axoniq.framework.messaging.multitenancy.axonserver.eventsourcing	Part of the Axoniq Framework multi-tenancy 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.multitenancy.axonserver.queryhandling	Part of the Axoniq Framework multi-tenancy module.
io.axoniq.framework.messaging.multitenancy.eventsourcing	Package containing multitenancy support for event sourcing components.
io.axoniq.framework.messaging.queryhandling.distributed	Part of the Axon Messaging module.
io.axoniq.framework.messaging.transformation.events	Part of the Axoniq Messaging folder.
org.axonframework.common.caching	Caching abstractions and helpers.
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.core	Classes related to message processing in Axon Framework.
org.axonframework.messaging.eventhandling	Package for event handling components in Axon Framework.
org.axonframework.messaging.eventhandling.tracing	Tracing decorators for event handling components.
org.axonframework.test.fixture	Part of the Axon Test module.

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

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

Modifier and Type	Method	Description
Registration	PersistentStreamEventSource.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

Uses of Registration in io.axoniq.framework.messaging.multitenancy.api

Methods in io.axoniq.framework.messaging.multitenancy.api that return Registration

Modifier and Type	Method	Description
Registration	MultiTenantAwareComponent.registerAndStartTenant(TenantDescriptor tenantDescriptor)	Registers the given tenantDescriptor as a known tenant with this multi-tenant aware component.
Registration	TenantScopedCache.registerAndStartTenant(TenantDescriptor tenantDescriptor)	Behaves identically to TenantScopedCache.registerTenant(TenantDescriptor): components are created lazily on first use, so there is nothing to start eagerly.
Registration	MultiTenantAwareComponent.registerTenant(TenantDescriptor tenantDescriptor)	Registers the given tenantDescriptor as a known tenant with this multi-tenant aware component.
Registration	TenantScopedCache.registerTenant(TenantDescriptor tenantDescriptor)
Registration	TenantProvider.subscribe(MultiTenantAwareComponent component)	Subscribes the given component with this provider.

Uses of Registration in io.axoniq.framework.messaging.multitenancy.axonserver.api

Methods in io.axoniq.framework.messaging.multitenancy.axonserver.api that return Registration

Modifier and Type	Method	Description
Registration	AxonServerTenantProvider.subscribe(MultiTenantAwareComponent component)

Uses of Registration in io.axoniq.framework.messaging.multitenancy.axonserver.commandhandling

Methods in io.axoniq.framework.messaging.multitenancy.axonserver.commandhandling that return Registration

Modifier and Type	Method	Description
Registration	MultiTenantAxonServerCommandBusConnector.registerAndStartTenant(TenantDescriptor tenantDescriptor)
Registration	MultiTenantAxonServerCommandBusConnector.registerTenant(TenantDescriptor tenantDescriptor)

Uses of Registration in io.axoniq.framework.messaging.multitenancy.axonserver.eventsourcing

Methods in io.axoniq.framework.messaging.multitenancy.axonserver.eventsourcing that return Registration

Modifier and Type	Method	Description
Registration	AxonServerTenantEventStorageEngineFactory.registerAndStartTenant(TenantDescriptor tenantDescriptor)
Registration	AxonServerTenantSnapshotStoreFactory.registerAndStartTenant(TenantDescriptor tenantDescriptor)
Registration	AxonServerTenantEventStorageEngineFactory.registerTenant(TenantDescriptor tenantDescriptor)
Registration	AxonServerTenantSnapshotStoreFactory.registerTenant(TenantDescriptor tenantDescriptor)

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

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

Modifier and Type	Method	Description
Registration	MultiTenantPersistentStreamEventSource.registerAndStartTenant(TenantDescriptor tenantDescriptor)	Behaves identically to MultiTenantPersistentStreamEventSource.registerTenant(TenantDescriptor), which already opens the tenant's stream: this source is only registered with the TenantProvider while it has a consumer to feed, so there is no registered-but-not-started state to distinguish.
Registration	MultiTenantPersistentStreamEventSource.registerTenant(TenantDescriptor tenantDescriptor)	Opens the persistent stream of the given tenantDescriptor and joins it to the subscribed consumer.
Registration	MultiTenantPersistentStreamEventSource.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)	Subscribes the given eventsBatchConsumer to the persistent stream of every tenant, opening a stream for each tenant known to the TenantProvider and for every tenant added while the subscription lasts.

Uses of Registration in io.axoniq.framework.messaging.multitenancy.axonserver.queryhandling

Methods in io.axoniq.framework.messaging.multitenancy.axonserver.queryhandling that return Registration

Modifier and Type	Method	Description
Registration	MultiTenantAxonServerQueryBusConnector.registerAndStartTenant(TenantDescriptor tenantDescriptor)
Registration	MultiTenantAxonServerQueryBusConnector.registerTenant(TenantDescriptor tenantDescriptor)

Uses of Registration in io.axoniq.framework.messaging.multitenancy.eventsourcing

Methods in io.axoniq.framework.messaging.multitenancy.eventsourcing that return Registration

Modifier and Type	Method	Description
Registration	MultiTenantEventStorageEngine.registerAndStartTenant(TenantDescriptor tenantDescriptor)
Registration	MultiTenantEventStorageEngine.registerTenant(TenantDescriptor tenantDescriptor)
Registration	MultiTenantEventStorageEngine.subscribe(TenantChangeListener listener)	Subscribes the given listener to the changes of the tenants this engine holds.

Uses of Registration in io.axoniq.framework.messaging.queryhandling.distributed

Methods in io.axoniq.framework.messaging.queryhandling.distributed that return Registration

Modifier and Type	Method	Description
Registration	QueryBusConnector.Handler.registerUpdateHandler(QueryMessage subscriptionQueryMessage, QueryBusConnector.UpdateCallback updateCallback)	Registers an update handler for a given subscription query message and its associated update sender.

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

Methods in io.axoniq.framework.messaging.transformation.events that return Registration

Modifier and Type	Method	Description
Registration	TransformingEventStore.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

Uses of Registration in org.axonframework.common.caching

Methods in org.axonframework.common.caching that return Registration

Modifier and Type	Method	Description
protected abstract Registration	AbstractCacheAdapter.doRegisterListener(L listenerAdapter)	Registers the given listener with the cache implementation
protected Registration	EhCacheAdapter.doRegisterListener(org.ehcache.event.CacheEventListener listenerAdapter)
protected Registration	JCacheAdapter.doRegisterListener(javax.cache.configuration.CacheEntryListenerConfiguration<Object,Object> listenerAdapter)
Registration	AbstractCacheAdapter.registerCacheEntryListener(Cache.EntryListener entryListener)
Registration	Cache.registerCacheEntryListener(Cache.EntryListener cacheEntryListener)	Registers the given cacheEntryListener to listen for Cache changes.
Registration	NoCache.registerCacheEntryListener(Cache.EntryListener cacheEntryListener)
Registration	WeakReferenceCache.registerCacheEntryListener(Cache.EntryListener entryListener)

Uses of Registration in org.axonframework.eventsourcing.eventstore

Methods in org.axonframework.eventsourcing.eventstore that return Registration

Modifier and Type	Method	Description
Registration	InterceptingEventStore.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)
Registration	StorageEngineBackedEventStore.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

Constructor parameters in org.axonframework.eventsourcing.eventstore with type arguments of type Registration

Modifier	Constructor	Description
	ContinuousMessageStream(Supplier<List<E>> fetcher, Function<E,MessageStream.Entry<EventMessage>> converter, BiFunction<ContinuousMessageStream<?>,Runnable,Registration> callbackTracker)	Creates a new ContinuousMessageStream instance configured with the given strategies.

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

Methods in org.axonframework.eventsourcing.eventstore.tracing that return Registration

Modifier and Type	Method	Description
Registration	TracingEventStore.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

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

Methods in org.axonframework.extension.spring.messaging that return Registration

Modifier and Type	Method	Description
Registration	InboundEventMessageChannelAdapter.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

Uses of Registration in org.axonframework.messaging.core

Methods in org.axonframework.messaging.core that return Registration

Modifier and Type	Method	Description
Registration	SubscribableEventSource.subscribe(BiFunction<List<? extends EventMessage>,@Nullable ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)	Subscribe the given eventsBatchConsumer to this event source.

Uses of Registration in org.axonframework.messaging.eventhandling

Methods in org.axonframework.messaging.eventhandling that return Registration

Modifier and Type	Method	Description
Registration	DelegatingEventBus.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)
Registration	InterceptingEventBus.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)
Registration	SimpleEventBus.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

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

Methods in org.axonframework.messaging.eventhandling.tracing that return Registration

Modifier and Type	Method	Description
Registration	TracingEventBus.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

Uses of Registration in org.axonframework.test.fixture

Methods in org.axonframework.test.fixture that return Registration

Modifier and Type	Method	Description
Registration	RecordingEventBus.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)
Registration	RecordingEventStore.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)