Class MessageConsumerDaemon
java.lang.Object
edu.internet2.middleware.grouper.app.messaging.MessageConsumerDaemon
- All Implemented Interfaces:
org.quartz.Job
@DisallowConcurrentExecution
public class MessageConsumerDaemon
extends Object
implements org.quartz.Job
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
execute
(org.quartz.JobExecutionContext jobExecutionContext) protected void
processMessages
(String messagingSystemName, GrouperMessagingSystem grouperMessageSystem, String messageQueueType, String queueTopicName, Collection<GrouperMessage> grouperMessages, String configName)
-
Constructor Details
-
MessageConsumerDaemon
public MessageConsumerDaemon()
-
-
Method Details
-
execute
public void execute(org.quartz.JobExecutionContext jobExecutionContext) throws org.quartz.JobExecutionException - Specified by:
execute
in interfaceorg.quartz.Job
- Throws:
org.quartz.JobExecutionException
- See Also:
-
Job.execute(JobExecutionContext)
-
processMessages
protected void processMessages(String messagingSystemName, GrouperMessagingSystem grouperMessageSystem, String messageQueueType, String queueTopicName, Collection<GrouperMessage> grouperMessages, String configName) - Parameters:
messagingSystemName
-grouperMessageSystem
-messageQueueType
-queueTopicName
-grouperMessages
-configName
-
-