Class DataManagerOutTopicPublisher


public class DataManagerOutTopicPublisher extends Object
DataManagerOutTopicPublisher is responsible for sending events on the Data Manager OMAS's out topic. It is called from the Data Manager OMAS's OMRS Topic Listener.
  • Constructor Details

    • DataManagerOutTopicPublisher

      public DataManagerOutTopicPublisher(DataManagerOutTopicServerConnector outTopicServerConnector, String outTopicName, AuditLog outTopicAuditLog)
      Constructor for the publisher.
      outTopicServerConnector - connector to the out topic
      outTopicName - name of the out topic
      outTopicAuditLog - logging destination if anything goes wrong.
  • Method Details

    • sendEntityEvent

      public void sendEntityEvent(DataManagerOutboundEventType eventType, String elementGUID, String elementTypeName, String classificationName, ElementStub elementStub)
      Send an event that relates to an entity.
      eventType - type of change to the entity
      elementGUID - unique identifier for the entity
      elementTypeName - type of entity
      classificationName - if a classification has changed this identifies which classification
      elementStub - encoded header of the entity
    • sendRelationshipEvent

      public void sendRelationshipEvent(DataManagerOutboundEventType eventType, String relationshipGUID, String relationshipTypeName, ElementStub relationshipElementStub, ElementStub endOneElementStub, ElementStub endTwoElementStub)
      Send an event that relates to a relationship.
      eventType - type of change to the relationship
      relationshipGUID - unique identifier for the relationship
      relationshipTypeName - type of relationship
      relationshipElementStub - encoded header of the relationship
      endOneElementStub - encoded header of the entity at end 1 of the relationship
      endTwoElementStub - encoded header of the entity at end 2 of the relationship
    • disconnect

      public void disconnect()
      Shutdown the publishing process.