...
| Code Block |
|---|
##################################### ## Messaging listener using the messagingchange log consumer API ##################################### # note, change "messagingListenermessagingListenerChangeLogConsumer" in key to be the name of the listener. e.g. messaging.listener.myAzureListener.class # extends edu.internet2.middleware.grouper.messaging.MessagingListenerBase # keep this listenerclass willto just print out messages:be MessagingListenerToChangeLogConsumer messaging.listener.messagingListenerChangeLogConsumerPrint.class = edu.internet2.middleware.grouper.messaging.MessagingListenerPrint # MessagingListenerToChangeLogConsumer messaging.listener.messagingListenerSamplemessagingListenerChangeLogConsumerPrint.classchangeLogConsumerClass = edu.internet2.middleware.grouper.changeLog.messagingconsumer.MessagingListenerPrintPrintTest messaging.listener.messagingListenerSamplemessagingListenerChangeLogConsumerPrint.quartzCron = 0 * * * * ? messaging.listener.messagingListenerSamplemessagingListenerChangeLogConsumerPrint.messagingSystemName = grouperBuiltinMessaging messaging.listener.messagingListenerSamplemessagingListenerChangeLogConsumerPrint.queueName = sampleMessagingQueuesampleChangeLogMessagingQueue |
Create events via GSH
| Code Block |
|---|
GrouperSession grouperSession = GrouperSession.startRootSession();
Group group = new GroupSave(grouperSession).assignName("test:testGroup").assignCreateParentStemsIfNotExist(true).save();
addMember("test:testGroup", "GrouperSystem");
delMember("test:testGroup", "GrouperSystem"); |
See the output
| Code Block |
|---|
|
Query messages
| Code Block |
|---|
select * from grouper_message where queue_name = 'sampleChangeLogMessagingQueue' |
| Code Block |
Output
| Code Block |
|---|
ID SENT_TIME_MICROS GET_ATTEMPT_TIME_MILLIS GET_ATTEMPT_COUNT STATE GET_TIME_MILLIS FROM_MEMBER_ID QUEUE_NAME MESSAGE_BODY HIBERNATE_VERSION_NUMBER ATTEMPT_TIME_EXPIRES_MILLIS -------------------------------- ---------------- ----------------------- ----------------- ------------- --------------- -------------------------------- ----------------------------- --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- ------------------------ --------------------------- abf5c09d478c461cbdba383b8cc8c36b 1459135864111000 1459135866870 1 PROCESSED 1459135866908 12cf184d43d342a49c6a28c8a45c39ff sampleChangeLogMessagingQueue {"event":[{"changeLogTypeId":"67911ea515f7480bb8aa363913bae196","contextId":"fefeb029bad24a7bbbccd3c9ca730348","createdOnDb":1459135800303000,"sequenceNumber":519,"changeLogTypeCategory":"attributeDefName","changeLogTypeAction":"addAttributeDefName","field_id":"d5e2e4797f7f47d98cb4b1b128f11dcd","field_attributeDefId":"48194ee1d1fc490a8bf6cd519a4c569a","field_name":"etc:attribute:messages:grouperMessageQueues:sampleChangeLogMessagingQueue","field_stemId":"4f6befbf61e845048949c69988e97335"}]} 2 1459136160297 78a894922a7b4e2fbf773712e49366d9 1459135864197000 1459135866876 1 PROCESSED 1459135866918 12cf184d43d342a49c6a28c8a45c39ff sampleChangeLogMessagingQueue {"event":[{"changeLogTypeId":"bb3dd51d5a3b443bb33a76d55e42169a","contextId":"fefeb029bad24a7bbbccd3c9ca730348","createdOnDb":1459135800307000,"sequenceNumber":520,"changeLogTypeCategory":"attributeDefNameSet","changeLogTypeAction":"addAttributeDefNameSet","field_id":"52d8f023771a454b80e6b838212a1e41","field_type":"self","field_ifHasAttributeDefNameId":"d5e2e4797f7f47d98cb4b1b128f11dcd","field_thenHasAttributeDefNameId":"d5e2e4797f7f47d98cb4b1b128f11dcd","field_parentAttrDefNameSetId":"52d8f023771a454b80e6b838212a1e41","field_depth":"0"}]} 2 1459136160297 8c6ffc63b10c4062985cf4ea2642d771 1459135864200000 1459135866882 1 PROCESSED 1459135866925 12cf184d43d342a49c6a28c8a45c39ff sampleChangeLogMessagingQueue {"event":[{"changeLogTypeId":"0cb099fc58de4b4a9394c1fc26c30070","contextId":"8bd9d6ae6c3f4f1abe50f638d15db3ea","createdOnDb":1459135800484000,"sequenceNumber":521,"changeLogTypeCategory":"attributeAssign","changeLogTypeAction":"addAttributeAssign","field_id":"8a717241cb4c4333a6675580d86fe5a2","field_attributeDefNameId":"d5e2e4797f7f47d98cb4b1b128f11dcd","field_attributeAssignActionId":"7d282b660ef64bc68430a76c6d0d430c","field_assignType":"any_mem","field_ownerId1":"bd83c57c43e747b7b4055a29e51e7dce","field_ownerId2":"12cf184d43d342a49c6a28c8a45c39ff","field_attributeDefNameName":"etc:attribute:messages:grouperMessageQueues:sampleChangeLogMessagingQueue","field_action":"receive","field_disallowed":"F"}]} 2 1459136160297 a68b34e129564741bdb2c3ea0a43e7cb 1459135924023000 1459135927856 1 PROCESSED 1459135927992 12cf184d43d342a49c6a28c8a45c39ff sampleChangeLogMessagingQueue {"event":[{"changeLogTypeId":"0cb099fc58de4b4a9394c1fc26c30070","contextId":"737e0d0b0f944f7cbfc6e4db38072ccf","createdOnDb":1459135864098000,"sequenceNumber":522,"changeLogTypeCategory":"attributeAssign","changeLogTypeAction":"addAttributeAssign","field_id":"6fb44d44b24f41159ae0de234f73923c","field_attributeDefNameId":"d5e2e4797f7f47d98cb4b1b128f11dcd","field_attributeAssignActionId":"daffb9d7a18a432da05839565d189969","field_assignType":"any_mem","field_ownerId1":"bd83c57c43e747b7b4055a29e51e7dce","field_ownerId2":"12cf184d43d342a49c6a28c8a45c39ff","field_attributeDefNameName":"etc:attribute:messages:grouperMessageQueues:sampleChangeLogMessagingQueue","field_action":"send_to_queue","field_disallowed":"F"}]} 2 1459136210756 5ce8355fd09e4c54b2a73a3e3db2c71f 1459147264043000 1459147267614 1 GET_ATTEMPTED (null) 12cf184d43d342a49c6a28c8a45c39ff sampleChangeLogMessagingQueue Change log entry: membership -> addMembership, null Change log entry: {"event":[{"changeLogTypeId":"79fc53db683646f5a72b33fb60cb0fde","contextId":"3acb507a84c34935b788e2f9c2c4b0bfe8d766d21c5b462a81079072387500be","createdOnDb":14591334880550001459147220097000,"sequenceNumber":512523,"changeLogTypeCategory":"membership","changeLogTypeAction":"addMembership","field_id":"4c4dac01a91046059fdbaf209172ff5a3a2703bee8a24db5b8c1b6ed4ddc7e57","field_fieldName":"members","field_subjectId":"GrouperSystem","field_sourceId":"g:isa","field_membershipType":"flattened","field_groupId":"5b4f7610e2104aa295ddb58df237356f","field_groupName":"test:testGroup","field_memberId":"12cf184d43d342a49c6a28c8a45c39ff","field_fieldId":"48855dad8b58446fa9eee00dfd6ca211","field_subjectIdentifier0":"GrouperSystem"}]} Change log entry: membership -> deleteMembership, null Change log entry: 1 1459147547011 6d81706e4d264da0867a81b82838a02e 1459147264051000 1459147267661 1 GET_ATTEMPTED (null) 12cf184d43d342a49c6a28c8a45c39ff sampleChangeLogMessagingQueue {"event":[{"changeLogTypeId":"0d304c632bc34416a1f4fa3c7f4b11ef","contextId":"0a26c32974544c0995fd86ab39012ddcb1251f6de6794f8a9ec47edaef96af87","createdOnDb":14591334933600001459147225213000,"sequenceNumber":513524,"changeLogTypeCategory":"membership","changeLogTypeAction":"deleteMembership","field_id":"4c4dac01a91046059fdbaf209172ff5a3a2703bee8a24db5b8c1b6ed4ddc7e57","field_fieldName":"members","field_subjectId":"GrouperSystem","field_sourceId":"g:isa","field_membershipType":"flattened","field_groupId":"5b4f7610e2104aa295ddb58df237356f","field_groupName":"test:testGroup","field_memberId":"12cf184d43d342a49c6a28c8a45c39ff","field_fieldId":"48855dad8b58446fa9eee00dfd6ca211","field_subjectIdentifier0":"GrouperSystem"}]} 1 1459147547011 6 row(s) in 71 ms |