Package akka.persistence.journal.inmem
Interface InmemMessages
-
- All Known Implementing Classes:
InmemJournal
public interface InmemMessages
INTERNAL API.
-
-
Method Summary
All Methods Instance Methods Abstract Methods 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)
-
-