Interface InmemMessages


public interface InmemMessages
INTERNAL API.
  • Method Details

    • add

      void add(PersistentRepr p)
    • delete

      void delete(String pid, long snr)
    • highestSequenceNr

      long highestSequenceNr(String pid)
    • highestSequenceNumbers_$eq

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

      scala.collection.immutable.Map<String,scala.collection.immutable.Vector<scala.Tuple2<PersistentRepr,<any>>>> messages()
    • messages_$eq

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

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

      int safeLongToInt(long l)