...
| Code Block |
|---|
log4j.logger.edu.internet2.middleware.grouper.messaging.GrouperBuiltinMessagingSystemTest = DEBUG |
Example to get messages
| Code Block |
|---|
String messageSystemConfigName = "someConfigName";
String queueName = "someQueue";
GrouperMessageReceiveResult grouperMessageReceiveResult = GrouperMessagingEngine.receive(new GrouperMessageReceiveParam()
.assignGrouperMessageSystemName(messageSystemConfigName)
.assignGrouperMessageQueueParam(new GrouperMessageQueueParam().assignQueueOrTopicName(queueName).assignQueueType(GrouperMessageQueueType.queue))
.assignMaxMessagesToReceiveAtOnce(20));
for (GrouperMessage grouperMessage : grouperMessageReceiveResult.getGrouperMessages()) {
String body = grouperMessage.getMessageBody();
//do something with message
GrouperMessagingEngine.acknowledge(new GrouperMessageAcknowledgeParam()
.assignGrouperMessageSystemName(messageSystemConfigName)
.assignGrouperMessageQueueParam(new GrouperMessageQueueParam().assignQueueOrTopicName(queueName).assignQueueType(GrouperMessageQueueType.queue))
.assignAcknowledgeType(GrouperMessageAcknowledgeType.mark_as_processed)
.assignGrouperMessages(GrouperClientUtils.toSet(grouperMessage)));
}
|
See Also
...