@PersistJobDataAfterExecution @DisallowConcurrentExecution public class GrouperRemedyMessageConsumer extends Object implements org.quartz.Job
| Constructor and Description |
|---|
GrouperRemedyMessageConsumer() |
| 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 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.Joborg.quartz.JobExecutionExceptionJob.execute(org.quartz.JobExecutionContext)Copyright © 2016 Internet2. All rights reserved.