edu.internet2.middleware.grouper.changeLog.esb.consumer

Class RuleConsumer

java.lang.Object

edu.internet2.middleware.grouper.changeLog.ChangeLogConsumerBase

edu.internet2.middleware.grouper.changeLog.esb.consumer.RuleConsumer

public class RuleConsumer
extends ChangeLogConsumerBase

Class to dispatch individual events for rules

Constructor Summary

Constructors

Constructor and Description
RuleConsumer()

Method Summary

Modifier and Type	Method and Description
static void	fixVetoIfNotInFolder(Group group, Subject subject, String subjectSourceId)
long	processChangeLogEntries(List<ChangeLogEntry> changeLogEntryList, ChangeLogProcessorMetadata changeLogProcessorMetadata) process the change logs
static boolean	shouldContinueFixVetoIfNotInFolder(RuleDefinition definition)

Methods inherited from class edu.internet2.middleware.grouper.changeLog.ChangeLogConsumerBase

callAtLeastOnce, getBatchSize, getConsumerName, setConsumerName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RuleConsumer

public RuleConsumer()

Method Detail

shouldContinueFixVetoIfNotInFolder

public static boolean shouldContinueFixVetoIfNotInFolder(RuleDefinition definition)

fixVetoIfNotInFolder

public static void fixVetoIfNotInFolder(Group group,
                                        Subject subject,
                                        String subjectSourceId)

processChangeLogEntries

public long processChangeLogEntries(List<ChangeLogEntry> changeLogEntryList,
                                    ChangeLogProcessorMetadata changeLogProcessorMetadata)

Description copied from class: ChangeLogConsumerBase

process the change logs

Specified by:

processChangeLogEntries in class ChangeLogConsumerBase

Parameters:

changeLogEntryList - NOTE, DO NOT CHANGE OR EDIT THE OBJECTS IN THIS LIST, THEY MIGHT BE SHARED!

Returns:

which sequence number it got up to (which sequence number was the last one processed). or -1 if none processed

See Also:

ChangeLogConsumerBase.processChangeLogEntries(List, ChangeLogProcessorMetadata)