@PersistJobDataAfterExecution @DisallowConcurrentExecution public class GrouperDigitalMarketplaceMessageConsumer extends Object implements org.quartz.Job
Constructor and Description |
---|
GrouperDigitalMarketplaceMessageConsumer() |
Modifier and Type | Method and Description |
---|---|
void |
execute(org.quartz.JobExecutionContext arg0) |
static void |
incrementalSync()
do an incrementalsync
|
static boolean |
isIncrementalRefreshInProgress()
if incremental refresh is in progress
|
static void |
main(String[] args) |
static void |
processMessage(EsbEvent esbEvent)
process message
|
static void |
processMessage(String eventType,
String groupName,
String sourceId,
String subjectId,
String subjectAttributeValue)
process message
|
static void |
waitForIncrementalRefreshToEnd()
wait for full refresh to end
|
public GrouperDigitalMarketplaceMessageConsumer()
public static void main(String[] args)
args
- public static boolean isIncrementalRefreshInProgress()
public static void waitForIncrementalRefreshToEnd()
public static void incrementalSync()
public static void processMessage(EsbEvent esbEvent)
esbEvent
- public static void processMessage(String eventType, String groupName, String sourceId, String subjectId, String subjectAttributeValue)
eventType
- groupName
- sourceId
- subjectId
- subjectAttributeValue
- public void execute(org.quartz.JobExecutionContext arg0) throws org.quartz.JobExecutionException
execute
in interface org.quartz.Job
org.quartz.JobExecutionException
Job.execute(org.quartz.JobExecutionContext)
Copyright © 2016 Internet2. All rights reserved.