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
-
-