akka.persistence.journal.inmem
Interface InmemMessages

All Known Implementing Classes:

InmemStore

public interface InmemMessages

INTERNAL API.

Method Summary

void	add(PersistentRepr p)
void	delete(java.lang.String pid, long snr)
long	highestSequenceNr(java.lang.String pid)
scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.Vector<PersistentRepr>>	messages()
scala.collection.immutable.Seq<PersistentRepr>	read(java.lang.String pid, long fromSnr, long toSnr, long max)
int	safeLongToInt(long l)
void	update(java.lang.String pid, long snr, scala.Function1<PersistentRepr,PersistentRepr> f)

Method Detail

messages

scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.Vector<PersistentRepr>> messages()

add

void add(PersistentRepr p)

update

void update(java.lang.String pid,
            long snr,
            scala.Function1<PersistentRepr,PersistentRepr> f)

delete

void delete(java.lang.String pid,
            long snr)

read

scala.collection.immutable.Seq<PersistentRepr> read(java.lang.String pid,
                                                    long fromSnr,
                                                    long toSnr,
                                                    long max)

highestSequenceNr

long highestSequenceNr(java.lang.String pid)

safeLongToInt

int safeLongToInt(long l)