public interface InmemMessages
Modifier and Type | Method and 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() |
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) |
scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.Vector<PersistentRepr>> messages()
void add(PersistentRepr p)
void update(java.lang.String pid, long snr, scala.Function1<PersistentRepr,PersistentRepr> f)
void delete(java.lang.String pid, long snr)
scala.collection.immutable.Seq<PersistentRepr> read(java.lang.String pid, long fromSnr, long toSnr, long max)
long highestSequenceNr(java.lang.String pid)
int safeLongToInt(long l)