Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
#####################################
## Messaging integration with change log
#####################################
# note, change "messagingSample" in key to be the name of the consumer.  e.g. changeLog.consumer.someNameAnyName.class
changeLog.consumer.rabbitMqMessagingSample.class = edu.internet2.middleware.grouper.changeLog.esb.consumer.EsbConsumer

changeLog.consumer.rabbitMqMessagingSample.publisher.class = edu.internet2.middleware.grouper.changeLog.esb.consumer.EsbMessagingPublisher
changeLog.consumer.rabbitMqMessagingSample.publisher.messagingSystemName = rabbitmq
## queue or topic
changeLog.consumer.rabbitMqMessagingSample.publisher.messageQueueType = queue
changeLog.consumer.rabbitMqMessagingSample.publisher.queueOrTopicName = sampleQueue
## this is optional if not using "id" for subjectId, need to be a subject attribute in the sources.xml
#changeLog.consumer.rabbitMqMessagingSample.publisher.addSubjectAttributes = email

Note, you need to create the rabbitmq queue (you can do this with the admin console: http://localhost:15672/#/queues

Image Added

Messages

Here are some sample messages from the ESB connector

Code Block
{  
  "encrypted":false,
  "esbEvent":[  
    {  
      "changeOccurred":false,
      "createdOnMicros":1502100000596000,
      "eventType":"MEMBERSHIP_ADD",
      "fieldName":"members",
      "groupId":"ccf74f3b4d0743428f7d72a14d8d81db",
      "groupName":"test:testLoader",
      "id":"484190ca24e54ea7a6ac9e7d26089afa",
      "membershipType":"flattened",
      "sequenceNumber":"790",
      "sourceId":"jdbc",
      "subjectId":"test.subject.2"
    }
  ]
}
Code Block
{  
  "encrypted":false,
  "esbEvent":[  
    {  
      "changeOccurred":false,
      "createdOnMicros":1502133203662000,
      "displayName":"etc:sysadminReadonly",
      "eventType":"GROUP_ADD",
      "id":"ae0dde273bd0472c8257f36ffccf20ad",
      "name":"etc:sysadminReadonly",
      "parentStemId":"4fd44656ad6f423eaaddbd896fdc1aaa",
      "sequenceNumber":"793"
    }
  ]
}

 

Install this connector

...

via the installer

Get the latest installer, run it, install, you can skip most stuff, rabbitmq is at the end

...