Package akka.persistence.journal.inmem

Interface InmemMessages

All Known Implementing Classes:

InmemJournal

public interface InmemMessages

INTERNAL API.

Method Summary

Modifier and Type	Method	Description
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()
void	messages_$eq(scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.Vector<PersistentRepr>> x$1)
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

add

void add(PersistentRepr p)

delete

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

highestSequenceNr

long highestSequenceNr(java.lang.String pid)

messages

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

messages_$eq

void messages_$eq(scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.Vector<PersistentRepr>> x$1)

read

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

safeLongToInt

int safeLongToInt(long l)

update

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