Interface RecordConsumer

  • All Known Implementing Classes:
    ClusterNode

    public interface RecordConsumer
    Listener interface on a journal that gets called back for records that should be consumed.
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void consume​(Record record)
      Consume a record.
      String getId()
      Return the unique identifier of the records this consumer will be able to handle.
      long getRevision()
      Return the revision this consumer has last seen.
      void setRevision​(long revision)
      Set the revision this consumer has last seen.
    • Method Detail

      • getId

        String getId()
        Return the unique identifier of the records this consumer will be able to handle.
        Returns:
        unique identifier
      • getRevision

        long getRevision()
        Return the revision this consumer has last seen.
        Returns:
        revision
      • consume

        void consume​(Record record)
        Consume a record.
        Parameters:
        record - record to consume
      • setRevision

        void setRevision​(long revision)
        Set the revision this consumer has last seen.
        Parameters:
        revision - revision