server/io.spine.server.storage.memory/InMemoryInboxStorage

InMemoryInboxStorage

public final class InMemoryInboxStorage extends AbstractStorage<I, M, R> implements InboxStorage

In-memory implementation of messages stored in Inbox.

Mutating operations are made synchronized to avoid simultaneous updates of the same records. That allows to operate in a concurrency-heavy environment notwithstanding the thread-safety of the underlying storage.

Constructors

public void InMemoryInboxStorage(boolean multitenant)

Functions

index

public Iterator<InboxMessageId> index()

Returns an iterator over identifiers of records in the storage.

newestMessageToDeliver

public Optional<InboxMessage> newestMessageToDeliver(ShardIndex index)

Finds the newest message to deliver in the given shard.

read

public Optional<InboxMessage> read(InboxReadRequest request)

Reads a record from the storage by the specified request.

readAll

public Page<InboxMessage> readAll(ShardIndex index, int pageSize)

Reads the contents of the storage by the given shard index and returns the first page of the results.

removeAll

public synchronized void removeAll(Iterable<InboxMessage> messages)

Removes the passed messages from the storage.

write

public synchronized void write(InboxMessage message)

Writes a message to the storage.

public synchronized void write(InboxMessageId id, InboxMessage record)

Writes a record into the storage.

writeAll

public synchronized void writeAll(Iterable<InboxMessage> messages)

Writes several messages to the storage.

Inherited functions

checkNotClosed

protected void checkNotClosed()

protected void checkNotClosed(String message)

Ensures the storage is not closed.

public void close()

Closes the storage.

public abstract void close()

isClosed

public boolean isClosed()

Tests whether the storage is closed.

isMultitenant

public boolean isMultitenant()

Verifies whether the storage is multitenant.

isOpen

public boolean isOpen()

Tests whether the storage is open.