Package edu.internet2.middleware.grouper.app.remedy.digitalMarketplace

Class GrouperDigitalMarketplaceMessageConsumer

java.lang.Object

edu.internet2.middleware.grouper.app.remedy.digitalMarketplace.GrouperDigitalMarketplaceMessageConsumer

All Implemented Interfaces:

org.quartz.Job

@PersistJobDataAfterExecution
@DisallowConcurrentExecution
public class GrouperDigitalMarketplaceMessageConsumer
extends Object
implements org.quartz.Job

Constructor Summary

Constructors

Constructor	Description
GrouperDigitalMarketplaceMessageConsumer()

Method Summary

Modifier and Type	Method	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

Methods inherited from class java.lang.Object

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

Constructor Details

GrouperDigitalMarketplaceMessageConsumer

public GrouperDigitalMarketplaceMessageConsumer()

Method Details

main

public static void main(String[] args)

Parameters:

args -

isIncrementalRefreshInProgress

public static boolean isIncrementalRefreshInProgress()

if incremental refresh is in progress

Returns:

the fullRefreshInProgress

waitForIncrementalRefreshToEnd

public static void waitForIncrementalRefreshToEnd()

wait for full refresh to end

incrementalSync

public static void incrementalSync()

do an incrementalsync

processMessage

public static void processMessage(EsbEvent esbEvent)

process message

Parameters:

esbEvent -

processMessage

public static void processMessage(String eventType,
 String groupName,
 String sourceId,
 String subjectId,
 String subjectAttributeValue)

process message

Parameters:

eventType -

groupName -

sourceId -

subjectId -

subjectAttributeValue -

execute

public void execute(org.quartz.JobExecutionContext arg0)
             throws org.quartz.JobExecutionException

Specified by:

execute in interface org.quartz.Job

Throws:

org.quartz.JobExecutionException

See Also:

• Job.execute(org.quartz.JobExecutionContext)