Interface RecordConsumer
-
- All Known Implementing Classes:
ClusterNode
public interface RecordConsumerListener 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 voidconsume(Record record)Consume a record.StringgetId()Return the unique identifier of the records this consumer will be able to handle.longgetRevision()Return the revision this consumer has last seen.voidsetRevision(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
-
-