Package org.odpi.openmetadata.frameworkservices.omf.outtopic

Class OpenMetadataOutTopicPublisher

java.lang.Object

org.odpi.openmetadata.frameworkservices.omf.outtopic.OpenMetadataOutTopicPublisher

public class OpenMetadataOutTopicPublisher
extends Object

OpenMetadataOutTopicPublisher is responsible for sending events on the Open Metadata Store's out topic. It is called from the Open MetadataStore's OMRS Topic Listener.

Constructor Summary

Constructors

Constructor	Description
OpenMetadataOutTopicPublisher(OMFOutTopicServerConnector outTopicServerConnector, String outTopicName, AuditLog outTopicAuditLog, OMRSRepositoryHelper repositoryHelper, String serviceName, String serverName)	Constructor for the publisher.

Method Summary

Modifier and Type	Method	Description
void	disconnect()	Shutdown the publishing process.
void	publishEntityEvent(OpenMetadataEventType eventType, EntityDetail entity, EntityDetail previousEntity, Classification newClassification, Classification previousClassification)	Send the event to the embedded event bus connector(s).
void	publishEntityEvent(EntityDetail entity, OpenMetadataEventType eventType)	Send the event to the embedded event bus connector(s).
void	publishRelationshipEvent(OpenMetadataEventType eventType, Relationship relationship, Relationship previousRelationship, EntityDetail end1, EntityDetail end2)	Send the event to the embedded event bus connector(s).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OpenMetadataOutTopicPublisher

public OpenMetadataOutTopicPublisher(OMFOutTopicServerConnector outTopicServerConnector,
 String outTopicName,
 AuditLog outTopicAuditLog,
 OMRSRepositoryHelper repositoryHelper,
 String serviceName,
 String serverName)

Constructor for the publisher.

Parameters:

outTopicServerConnector - connector to the out topic

outTopicName - name of the out topic

outTopicAuditLog - logging destination if anything goes wrong.

repositoryHelper - helper object to parse entity/relationship objects

serviceName - name of this component

serverName - local server name

Method Details

publishEntityEvent

public void publishEntityEvent(EntityDetail entity,
 OpenMetadataEventType eventType)

Send the event to the embedded event bus connector(s).

Parameters:

entity - entity that is the subject of the event

eventType - type of event

publishEntityEvent

public void publishEntityEvent(OpenMetadataEventType eventType,
 EntityDetail entity,
 EntityDetail previousEntity,
 Classification newClassification,
 Classification previousClassification)

Send the event to the embedded event bus connector(s).

Parameters:

entity - entity that is the subject of the event

previousEntity - previous version of the entity

eventType - type of event

newClassification - latest classification information (if the event relates to a classification)

previousClassification - previous classification information (if the event relates to a classification)

publishRelationshipEvent

public void publishRelationshipEvent(OpenMetadataEventType eventType,
 Relationship relationship,
 Relationship previousRelationship,
 EntityDetail end1,
 EntityDetail end2)

Send the event to the embedded event bus connector(s).

Parameters:

eventType - type of event

relationship - relationship that is the subject of the event

previousRelationship - previous version of the relationship

end1 - entity from end 1 of the relationship

end2 - entity from end 2 of the relationship

disconnect

public void disconnect()

Shutdown the publishing process.