public abstract class EsbListenerBase extends Object
Constructor and Description |
---|
EsbListenerBase() |
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.
|
EsbEvents |
convertEventsToNoSensitiveData(EsbEvents events,
boolean noSensitiveData)
convert events to events with no sensitive data
|
String |
convertEventsToString(EsbEvents events)
convert events to json.
|
abstract void |
disconnect()
disconnect if needed
|
abstract boolean |
dispatchEvent(String eventJsonString,
String consumerName) |
ProvisioningSyncConsumerResult |
dispatchEventList(List<EsbEventContainer> esbEventContainers)
implement this instead of dispatchEvent if you want objects instead of json string
|
ProvisioningSyncConsumerResult |
dispatchEventList(List<EsbEventContainer> esbEventContainers,
GrouperProvisioningProcessingResult grouperProvisioningProcessingResult)
Deprecated.
|
String |
encryptMessage(String message,
Class<GcEncryptionInterface> encryptionImplClass,
String encryptionKey,
boolean dontSendFirst4) |
Integer |
getBatchSize()
override the batch size configured in config file
|
ChangeLogProcessorMetadata |
getChangeLogProcessorMetadata()
get stuff like hib3 loader log
|
EsbConsumer |
getEsbConsumer()
ref to consumer
|
protected boolean |
isProcessObjectsInsteadOfJson()
return true if you want objects instead of json
|
void |
setChangeLogProcessorMetadata(ChangeLogProcessorMetadata changeLogProcessorMetadata1)
get stuff like hib3 loader log
|
void |
setEsbConsumer(EsbConsumer esbConsumer1)
ref to consumer
|
public EsbConsumer getEsbConsumer()
public void setEsbConsumer(EsbConsumer esbConsumer1)
esbConsumer1
- public ChangeLogProcessorMetadata getChangeLogProcessorMetadata()
public void setChangeLogProcessorMetadata(ChangeLogProcessorMetadata changeLogProcessorMetadata1)
changeLogProcessorMetadata1
- public abstract boolean dispatchEvent(String eventJsonString, String consumerName)
eventJsonString
- consumerName
- @Deprecated public ProvisioningSyncConsumerResult dispatchEventList(List<EsbEventContainer> esbEventContainers, GrouperProvisioningProcessingResult grouperProvisioningProcessingResult)
dispatchEventList(List)
esbEventContainers
- grouperProvisioningProcessingResult
- consumerName
- public ProvisioningSyncConsumerResult dispatchEventList(List<EsbEventContainer> esbEventContainers)
esbEventContainers
- grouperProvisioningProcessingResult
- consumerName
- public String encryptMessage(String message, Class<GcEncryptionInterface> encryptionImplClass, String encryptionKey, boolean dontSendFirst4)
public EsbEvents convertEventsToNoSensitiveData(EsbEvents events, boolean noSensitiveData)
esbEvents
- noSensitiveData
- public String convertEventsToString(EsbEvents events)
events
- public abstract void disconnect()
protected boolean isProcessObjectsInsteadOfJson()
public Integer getBatchSize()
public boolean callAtLeastOnce()
Copyright © 2016 Internet2. All rights reserved.