public abstract class ChangeLogConsumerBase extends Object
Constructor and Description |
---|
ChangeLogConsumerBase() |
Modifier and Type | Method and Description |
---|---|
boolean |
callAtLeastOnce()
some change log consumers might want to be called even if nothing happened in change log
e.g.
|
Integer |
getBatchSize()
override the batch size configured in config file
|
String |
getConsumerName()
consumer name in config file
|
abstract long |
processChangeLogEntries(List<ChangeLogEntry> changeLogEntryList,
ChangeLogProcessorMetadata changeLogProcessorMetadata)
process the change logs
|
void |
setConsumerName(String consumerName)
consumer name in config file
|
public String getConsumerName()
public void setConsumerName(String consumerName)
consumerName
- public abstract long processChangeLogEntries(List<ChangeLogEntry> changeLogEntryList, ChangeLogProcessorMetadata changeLogProcessorMetadata)
changeLogEntryList
- NOTE, DO NOT CHANGE OR EDIT THE OBJECTS IN THIS LIST, THEY MIGHT BE SHARED!changeLogProcessorMetadata
- public Integer getBatchSize()
public boolean callAtLeastOnce()
Copyright © 2016 Internet2. All rights reserved.