org.seedstack.business.util.inmemory

Class BaseInMemoryRepository<A extends AggregateRoot<I>,I>

java.lang.Object

org.seedstack.business.domain.BaseRepository<A,I>

org.seedstack.business.util.inmemory.BaseInMemoryRepository<A,I>

All Implemented Interfaces:

Repository<A,I>

Direct Known Subclasses:

DefaultInMemoryRepository

public abstract class BaseInMemoryRepository<A extends AggregateRoot<I>,I>
extends BaseRepository<A,I>

An helper base class that can be extended to create an in-memory implementation of a Repository. It is backed by a ConcurrentHashMap per aggregate root class. As such, insertion order is NOT guaranteed to be maintained through the repository lifecycle.

Nested Class Summary

Nested classes/interfaces inherited from interface org.seedstack.business.domain.Repository

Repository.Option

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BaseInMemoryRepository() Creates a base in-memory repository.
protected	BaseInMemoryRepository(Class<A> aggregateRootClass, Class<I> idClass) Creates a base in-memory repository.

Method Summary

Modifier and Type	Method and Description
void	add(A a) Adds an aggregate to the repository.
Stream<A>	get(Specification<A> specification, Repository.Option... options) Finds all aggregates in the repository satisfying the given specification.
long	remove(Specification<A> specification) Removes all aggregates in the repository satisfying the given specification.

Methods inherited from class org.seedstack.business.domain.BaseRepository

getAggregateRootClass, getIdentifierClass, getSpecificationBuilder

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.seedstack.business.domain.Repository

addOrUpdate, clear, contains, contains, contains, count, get, isEmpty, remove, remove, size, update

Constructor Detail

BaseInMemoryRepository

protected BaseInMemoryRepository()

Creates a base in-memory repository. Actual classes managed by the repository are determined by reflection.

BaseInMemoryRepository

protected BaseInMemoryRepository(Class<A> aggregateRootClass,
                                 Class<I> idClass)

Creates a base in-memory repository. Actual classes managed by the repository are specified explicitly.

Parameters:

aggregateRootClass - the actual aggregate root class.

idClass - the actual aggregate identifier class.

Method Detail

add

public void add(A a)
         throws AggregateExistsException

Description copied from interface: Repository

Adds an aggregate to the repository.

Parameters:

a - the aggregate to add.

Throws:

AggregateExistsException - if the repository already contains the aggregate.

get

public Stream<A> get(Specification<A> specification,
                     Repository.Option... options)

Description copied from interface: Repository

Finds all aggregates in the repository satisfying the given specification. Options can be specified to alter the returned stream (order, limits, ...).

Parameters:

specification - the specification aggregates must satisfy.

options - result options.

Returns:

a stream of aggregates.

See Also:

Repository.Option

remove

public long remove(Specification<A> specification)

Description copied from interface: Repository

Removes all aggregates in the repository satisfying the given specification.

Parameters:

specification - the specification aggregates must satisfy.

Returns:

the number of aggregates removed from the repository.