public class EsbConsumer extends ChangeLogConsumerBase
Modifier and Type | Class and Description |
---|---|
static class |
EsbConsumer.EsbConsumerTestingData |
Modifier and Type | Field and Description |
---|---|
EsbConsumer.EsbConsumerTestingData |
internal_esbConsumerTestingData
testing data for unit tests
|
Constructor and Description |
---|
EsbConsumer() |
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
|
ChangeLogProcessorMetadata |
getChangeLogProcessorMetadata() |
Map<String,Object> |
getDebugMapOverall() |
EsbListenerBase |
getEsbPublisherBase() |
void |
initEsbPublisherBase() |
boolean |
isDebugConsumer() |
static void |
logIntegerIfNotZero(Map<String,Object> debugMap,
String label,
Integer theInt)
add something to the log if its not zero (so we dont have noise).
|
static void |
logObjectIfNotNull(Map<String,Object> debugMap,
String label,
Object theObject)
add something to the log if its not null (so we dont have noise).
|
static void |
main(String[] args) |
static boolean |
matchesFilter(EsbEvent esbEvent,
String filterString)
see if the esb event matches an EL filter.
|
long |
processChangeLogEntries(List<ChangeLogEntry> changeLogEntryList,
ChangeLogProcessorMetadata changeLogProcessorMetadata1)
process the change logs
|
Runnable |
provisioningHeartbeatLogic() |
void |
setChangeLogProcessorMetadata(ChangeLogProcessorMetadata changeLogProcessorMetadata1) |
getConsumerName, setConsumerName
public EsbConsumer.EsbConsumerTestingData internal_esbConsumerTestingData
public Integer getBatchSize()
ChangeLogConsumerBase
getBatchSize
in class ChangeLogConsumerBase
public boolean callAtLeastOnce()
callAtLeastOnce
in class ChangeLogConsumerBase
public static void main(String[] args)
args
- public static void logIntegerIfNotZero(Map<String,Object> debugMap, String label, Integer theInt)
debugMap
- label
- theInt
- public static void logObjectIfNotNull(Map<String,Object> debugMap, String label, Object theObject)
debugMap
- label
- theInt
- public Runnable provisioningHeartbeatLogic()
public boolean isDebugConsumer()
public ChangeLogProcessorMetadata getChangeLogProcessorMetadata()
public void setChangeLogProcessorMetadata(ChangeLogProcessorMetadata changeLogProcessorMetadata1)
changeLogProcessorMetadata1
- public long processChangeLogEntries(List<ChangeLogEntry> changeLogEntryList, ChangeLogProcessorMetadata changeLogProcessorMetadata1)
ChangeLogConsumerBase
processChangeLogEntries
in class ChangeLogConsumerBase
changeLogEntryList
- NOTE, DO NOT CHANGE OR EDIT THE OBJECTS IN THIS LIST, THEY MIGHT BE SHARED!ChangeLogConsumerBase.processChangeLogEntries(List, ChangeLogProcessorMetadata)
public void initEsbPublisherBase()
public EsbListenerBase getEsbPublisherBase()
public static boolean matchesFilter(EsbEvent esbEvent, String filterString)
filterString
- esbEvent
- Copyright © 2016 Internet2. All rights reserved.