server/io.spine.server.storage.system/SystemAwareStorageFactory

SystemAwareStorageFactory

public final class SystemAwareStorageFactory implements StorageFactory

An implementation of StorageFactory which may produce an empty EventStore for system context.

Delegates storage creation to another factory.

When asked for a EventStore, creates an EmptyEventStore if the given context does not store events. Otherwise, delegates to the associated delegate factory.

Functions

public void close()

Closes the associated delegate factory.

createAggregateStorage

public AggregateStorage createAggregateStorage(ContextSpec context, Class<? extends Aggregate<I, ? extends Object, ? extends Object>> aggregateClass)

Creates a new AggregateStorage.

createCatchUpStorage

public CatchUpStorage createCatchUpStorage(boolean multitenant)

Creates a new CatchUpStorage.

createEventStore

public EventStore createEventStore(ContextSpec context)

Creates a new EventStore.

createInboxStorage

public InboxStorage createInboxStorage(boolean multitenant)

Creates a new InboxStorage.

createProjectionStorage

public ProjectionStorage createProjectionStorage(ContextSpec context, Class<? extends Projection<I, ? extends Object, ? extends Object>> projectionClass)

Creates a new ProjectionStorage.

createRecordStorage

public RecordStorage createRecordStorage(ContextSpec context, Class<? extends Entity<I, ? extends Object>> entityClass)

Creates a new RecordStorage.

delegate

public StorageFactory delegate()

Obtains the wrapped factory.

wrap

public static SystemAwareStorageFactory wrap(StorageFactory factory)

Wraps the given factory into a SystemAwareStorageFactory.