Package org.nuxeo.lib.stream.log.mem

Class MemLogPartition.MemPartitionTailer

java.lang.Object
org.nuxeo.lib.stream.log.mem.MemLogPartition.MemPartitionTailer
Enclosing class:
MemLogPartition
public class MemLogPartition.MemPartitionTailer extends Object
A tailer for a partition maintains an offset (current reading position).

  • Constructor Details

  • Method Details

    • read

      public MemLogPartition.BytesAndOffset read(String tag)
      Reads a message from the partition and increments the current offset.
      Parameters:
      tag - the required tag for the message
      Returns:
      the message, or null if there is no message at the current offset
      Throws:
      IllegalStateException - if the tag does not match

    • offset

      public long offset()

    • toStart

      public void toStart()

    • toEnd

      public void toEnd()

    • moveToOffset

      public boolean moveToOffset(long offset)

    • commit

      public void commit(long committed)

    • committed

      public long committed()

    • close

      public void close()