Package io.axoniq.framework.messaging.multitenancy.axonserver.eventsourcing

Class AxonServerTenantSnapshotStoreFactory

java.lang.Object
io.axoniq.framework.messaging.multitenancy.axonserver.eventsourcing.AxonServerTenantSnapshotStoreFactory
All Implemented Interfaces:
MultiTenantAwareComponent, TenantSnapshotStoreFactory, DescribableComponent
@Internal public class AxonServerTenantSnapshotStoreFactory extends Object implements TenantSnapshotStoreFactory, MultiTenantAwareComponent
Axon Server implementation of the TenantSnapshotStoreFactory, building one SnapshotStore per tenant against that tenant's Axon Server context.

Stores are created lazily and cached, and evicted on tenant removal, by a TenantScopedCache this factory holds. Following the tenant lifecycle is delegated to that cache through MultiTenantAwareComponent. The underlying connection is owned by the connection manager, which disconnects it on tenant removal, so eviction only drops the stale store and a re-added tenant rebuilds a fresh one.

Since:
5.3.0
Author:
Jakob Hatzl, Laura Devriendt

  • Constructor Details

    • AxonServerTenantSnapshotStoreFactory

      public AxonServerTenantSnapshotStoreFactory(Configuration configuration)
      Constructs an AxonServerTenantSnapshotStoreFactory, resolving the connection manager and converter from the given configuration.
      Parameters:
      configuration - the configuration providing the connection manager and converter

    • AxonServerTenantSnapshotStoreFactory

      public AxonServerTenantSnapshotStoreFactory(AxonServerConnectionManager connectionManager, Converter converter)
      Constructs an AxonServerTenantSnapshotStoreFactory.
      Parameters:
      connectionManager - the connection manager providing each tenant's Axon Server connection
      converter - the converter used to (de)serialize snapshot payloads

  • Method Details

    • storeFor

      public SnapshotStore storeFor(TenantDescriptor tenant)
      Description copied from interface: TenantSnapshotStoreFactory
      Returns the SnapshotStore of the given tenant.
      Specified by:
      storeFor in interface TenantSnapshotStoreFactory
      Parameters:
      tenant - the tenant to return the snapshot store for
      Returns:
      the tenant's SnapshotStore

    • registerTenant

      public Registration registerTenant(TenantDescriptor tenantDescriptor)
      Description copied from interface: MultiTenantAwareComponent
      Registers the given tenantDescriptor as a known tenant with this multi-tenant aware component.

      The caller must retain the returned Registration and cancel it when the tenant is removed, since releasing the component's per-tenant resources rides on that cancellation.

      Specified by:
      registerTenant in interface MultiTenantAwareComponent
      Parameters:
      tenantDescriptor - The TenantDescriptor to register with this component.
      Returns:
      A Registration used to deregister the given tenantDescriptor.

    • registerAndStartTenant

      public Registration registerAndStartTenant(TenantDescriptor tenantDescriptor)
      Description copied from interface: MultiTenantAwareComponent
      Registers the given tenantDescriptor as a known tenant with this multi-tenant aware component. If applicable, this task will construct a tenant segment and start it.
      Specified by:
      registerAndStartTenant in interface MultiTenantAwareComponent
      Parameters:
      tenantDescriptor - The TenantDescriptor to register with this component.
      Returns:
      A Registration used to deregister the given tenantDescriptor.

    • describeTo

      public void describeTo(ComponentDescriptor descriptor)
      Description copied from interface: DescribableComponent
      Describe the properties of this DescribableComponent with the given descriptor.

      Components should call the appropriate describeProperty methods on the descriptor to register their properties. The descriptor is responsible for determining how these properties are formatted and structured in the final output.

      Best Practices: As a general rule, all relevant fields of a DescribableComponent implementation should be described in this method. However, developers have discretion to include only the fields that make sense in the context. Not every field may be meaningful for description purposes, especially internal implementation details. Furthermore, components might want to expose different information based on their current state. The final decision on what properties to include lies with the person implementing the describeTo method, who should focus on providing information that is useful for understanding the component's configuration and state.

      Example implementation: 

       public void describeTo(ComponentDescriptor descriptor) {
     descriptor.describeProperty("name", this.name);
     descriptor.describeProperty("enabled", this.enabled);
     descriptor.describeProperty("configuration", this.configuration); // A nested component
     descriptor.describeProperty("handlers", this.eventHandlers);      // A collection
 }
      Specified by:
      describeTo in interface DescribableComponent
      Parameters:
      descriptor - The component descriptor to describe this DescribableComponentn its properties in.