public class ChangeLogConsumerBaseImpl extends ChangeLogConsumerBase
Modifier and Type | Field and Description |
---|---|
static String |
CONFIG_FOLDER_NAME |
static String |
CONSUMER_CLASS_NAME
Property name for subclassed target consumer defined in changeLog.consumer.
|
static String |
SYNC_ATTRIBUTE_NAME
Property name for marker attribute defined in changeLog.consumer.
|
Constructor and Description |
---|
ChangeLogConsumerBaseImpl() |
Modifier and Type | Method and Description |
---|---|
protected void |
addGroup(Group group,
ChangeLogEntry changeLogEntry)
These methods are expected to be overidden in a subclass that is specific to a provisioning target.
|
protected void |
addGroupAndMemberships(Group group,
ChangeLogEntry changeLogEntry) |
protected void |
addMembership(Subject subject,
Group group,
ChangeLogEntry changeLogEntry) |
String |
getConsumerName()
consumer name in config file
|
protected boolean |
isFullSyncRunning(String consumerName)
expected to be overidden
|
long |
processChangeLogEntries(List<ChangeLogEntry> changeLogEntryList,
ChangeLogProcessorMetadata changeLogProcessorMetadata)
Process the list of changeLogEntries since the last time this consumer was run.
|
protected void |
removeDeletedGroup(PITGroup pitGroup,
ChangeLogEntry changeLogEntry) |
protected void |
removeGroup(Group group,
ChangeLogEntry changeLogEntry) |
protected void |
removeMembership(Subject subject,
Group group,
ChangeLogEntry changeLogEntry) |
protected void |
removeMovedGroup(String oldGroupName,
ChangeLogEntry changeLogEntry)
removeMovedGroup may be called for groups that have not previously been marked, need to check the target to be sure.
|
protected void |
renameGroup(String oldGroupName,
String newGroupName,
ChangeLogEntry changeLogEntry)
renameGroup may be called for groups that have not previously been marked, need to check the target to be sure.
|
protected void |
updateGroup(Group group,
ChangeLogEntry changeLogEntry) |
callAtLeastOnce, getBatchSize, setConsumerName
public static String CONFIG_FOLDER_NAME
public static String SYNC_ATTRIBUTE_NAME
public static String CONSUMER_CLASS_NAME
protected void addGroup(Group group, ChangeLogEntry changeLogEntry)
protected void updateGroup(Group group, ChangeLogEntry changeLogEntry)
protected void renameGroup(String oldGroupName, String newGroupName, ChangeLogEntry changeLogEntry)
protected void removeGroup(Group group, ChangeLogEntry changeLogEntry)
protected void removeMovedGroup(String oldGroupName, ChangeLogEntry changeLogEntry)
protected void removeDeletedGroup(PITGroup pitGroup, ChangeLogEntry changeLogEntry)
protected void addMembership(Subject subject, Group group, ChangeLogEntry changeLogEntry)
protected void removeMembership(Subject subject, Group group, ChangeLogEntry changeLogEntry)
protected void addGroupAndMemberships(Group group, ChangeLogEntry changeLogEntry)
public String getConsumerName()
ChangeLogConsumerBase
getConsumerName
in class ChangeLogConsumerBase
protected boolean isFullSyncRunning(String consumerName)
consumerName
- public long processChangeLogEntries(List<ChangeLogEntry> changeLogEntryList, ChangeLogProcessorMetadata changeLogProcessorMetadata)
processChangeLogEntries
in class ChangeLogConsumerBase
changeLogEntryList
- changeLogProcessorMetadata
- Copyright © 2016 Internet2. All rights reserved.