InMemoryCatchUpStorage

An in-memory implementation of CatchUpStorage.

Constructors

public void InMemoryCatchUpStorage(boolean multitenant)

public Iterator<CatchUpId> index()

Returns an iterator over identifiers of records in the storage.

Reads a record from the storage by the specified request.

public Iterable<CatchUp> readAll()

Returns an Iterable over all the stored catch-up processes.

public Iterable<CatchUp> readByType(TypeUrl projectionType)

Reads all the catch-up processes which update the projection of the specified type.

public void write(CatchUp message)

Writes a message to the storage.

public void write(CatchUpId id, CatchUp record)

Writes a record into the storage.

protected void checkNotClosed()

protected void checkNotClosed(String message)

Ensures the storage is not closed.

public void close()

Closes the storage.

public abstract void close()

public boolean isClosed()

Tests whether the storage is closed.

public boolean isMultitenant()

Verifies whether the storage is multitenant.

public boolean isOpen()

Tests whether the storage is open.