@DisallowConcurrentExecution public class MessageConsumerDaemon extends Object implements org.quartz.Job
Constructor and Description |
---|
MessageConsumerDaemon() |
Modifier and Type | Method and Description |
---|---|
void |
execute(org.quartz.JobExecutionContext jobExecutionContext) |
protected void |
processMessages(String messagingSystemName,
GrouperMessagingSystem grouperMessageSystem,
String messageQueueType,
String queueTopicName,
Collection<GrouperMessage> grouperMessages,
String configName) |
public void execute(org.quartz.JobExecutionContext jobExecutionContext) throws org.quartz.JobExecutionException
execute
in interface org.quartz.Job
org.quartz.JobExecutionException
Job.execute(JobExecutionContext)
protected void processMessages(String messagingSystemName, GrouperMessagingSystem grouperMessageSystem, String messageQueueType, String queueTopicName, Collection<GrouperMessage> grouperMessages, String configName)
messagingSystemName
- grouperMessageSystem
- messageQueueType
- queueTopicName
- grouperMessages
- configName
- Copyright © 2016 Internet2. All rights reserved.