Package akka.persistence.journal.inmem

Interface InmemMessages

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)
void	highestSequenceNumbers_$eq(scala.collection.immutable.Map<java.lang.String,java.lang.Object> x$1)
scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.Vector<scala.Tuple2<PersistentRepr,<any>>>>	messages()
void	messages_$eq(scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.Vector<scala.Tuple2<PersistentRepr,<any>>>> x$1)
scala.collection.immutable.Seq<scala.Tuple2<PersistentRepr,<any>>>	read(java.lang.String pid, long fromSnr, long toSnr, long max)
int	safeLongToInt(long l)

Method Detail

add

void add(PersistentRepr p)

delete

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

highestSequenceNr

long highestSequenceNr(java.lang.String pid)

highestSequenceNumbers_$eq

void highestSequenceNumbers_$eq(scala.collection.immutable.Map<java.lang.String,java.lang.Object> x$1)

messages

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

messages_$eq

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

read

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

safeLongToInt

int safeLongToInt(long l)