Package org.odpi.openmetadata.repositoryservices.eventmanagement

Class OMRSRepositoryEventPublisher

java.lang.Object

org.odpi.openmetadata.repositoryservices.connectors.stores.metadatacollectionstore.repositoryeventmapper.OMRSRepositoryEventProcessor

org.odpi.openmetadata.repositoryservices.eventmanagement.OMRSRepositoryEventBuilder

org.odpi.openmetadata.repositoryservices.eventmanagement.OMRSRepositoryEventPublisher

All Implemented Interfaces:

OMRSInstanceEventProcessorClassificationExtension, OMRSInstanceEventProcessorInterface, OMRSTypeDefEventProcessorInterface

public class OMRSRepositoryEventPublisher
extends OMRSRepositoryEventBuilder

OMRSRepositoryEventPublisher publishes TypeDef and Instance OMRS Events to the supplied OMRSTopicConnector.

Field Summary

Fields inherited from class org.odpi.openmetadata.repositoryservices.connectors.stores.metadatacollectionstore.repositoryeventmapper.OMRSRepositoryEventProcessor

eventProcessorName

Constructor Summary

Constructors

Constructor	Description
OMRSRepositoryEventPublisher(String publisherName, List<OMRSTopicConnector> typesTopicConnectors, List<OMRSTopicConnector> instancesTopicConnectors, AuditLog auditLog)	Typical constructor sets up the local metadata collection id for events.
OMRSRepositoryEventPublisher(String publisherName, OMRSTopicConnector topicConnector, AuditLog auditLog)	Typical constructor sets up the local metadata collection id for events.

Method Summary

Modifier and Type	Method	Description
void	sendInstanceEvent(String sourceName, OMRSInstanceEvent instanceEvent)	Set the instance event to the OMRS Topic connector if the instance event is of the permitted type.
void	sendTypeDefEvent(String sourceName, OMRSTypeDefEvent typeDefEvent)	Send the TypeDef event to the OMRS Topic connector (providing TypeDef Events are enabled).
void	setSecurityVerifier(OpenMetadataEventsSecurity securityVerifier)	Set up a new security verifier (the handler runs with a default verifier until this method is called).

Methods inherited from class org.odpi.openmetadata.repositoryservices.eventmanagement.OMRSRepositoryEventBuilder

processAttributeTypeDefConflictEvent, processClassifiedEntityEvent, processClassifiedEntityEvent, processConflictingInstancesEvent, processConflictingTypeEvent, processDeclassifiedEntityEvent, processDeclassifiedEntityEvent, processDeletedAttributeTypeDefEvent, processDeletedEntityEvent, processDeletedRelationshipEvent, processDeletedTypeDefEvent, processDeletePurgedEntityEvent, processDeletePurgedRelationshipEvent, processInstanceBatchEvent, processNewAttributeTypeDefEvent, processNewEntityEvent, processNewRelationshipEvent, processNewTypeDefEvent, processPurgedEntityEvent, processPurgedEntityEvent, processPurgedRelationshipEvent, processPurgedRelationshipEvent, processReclassifiedEntityEvent, processReclassifiedEntityEvent, processRefreshEntityEvent, processRefreshEntityRequested, processRefreshRelationshipEvent, processRefreshRelationshipRequest, processReHomedEntityEvent, processReHomedRelationshipEvent, processReIdentifiedAttributeTypeDefEvent, processReIdentifiedEntityEvent, processReIdentifiedRelationshipEvent, processReIdentifiedTypeDefEvent, processRestoredEntityEvent, processRestoredRelationshipEvent, processReTypedEntityEvent, processReTypedRelationshipEvent, processTypeDefConflictEvent, processTypeDefPatchMismatchEvent, processUndoneEntityEvent, processUndoneRelationshipEvent, processUpdatedEntityEvent, processUpdatedRelationshipEvent, processUpdatedTypeDefEvent

Methods inherited from class org.odpi.openmetadata.repositoryservices.connectors.stores.metadatacollectionstore.repositoryeventmapper.OMRSRepositoryEventProcessor

getEventProcessorName, processClassifiedEntityEvent, processDeclassifiedEntityEvent, processReclassifiedEntityEvent

Methods inherited from class java.lang.Object

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

Constructor Details

OMRSRepositoryEventPublisher

public OMRSRepositoryEventPublisher(String publisherName,
 OMRSTopicConnector topicConnector,
 AuditLog auditLog)

Typical constructor sets up the local metadata collection id for events.

Parameters:

publisherName - name of the cohort (or enterprise virtual repository) that this event publisher is sending events to.

topicConnector - OMRS Topic to send requests on

auditLog - audit log for this component.

OMRSRepositoryEventPublisher

public OMRSRepositoryEventPublisher(String publisherName,
 List<OMRSTopicConnector> typesTopicConnectors,
 List<OMRSTopicConnector> instancesTopicConnectors,
 AuditLog auditLog)

Typical constructor sets up the local metadata collection id for events.

Parameters:

publisherName - name of the cohort (or enterprise virtual repository) that this event publisher is sending events to.

typesTopicConnectors - list of OMRS Topic connectors to send type requests on

instancesTopicConnectors - list of OMRS Topic connectors to send type requests on

auditLog - audit log for this component.

Method Details

setSecurityVerifier

public void setSecurityVerifier(OpenMetadataEventsSecurity securityVerifier)

Set up a new security verifier (the handler runs with a default verifier until this method is called). The security verifier provides authorization checks for whether individual events should be sent/received. Authorization checks are enabled through the OpenMetadataServerSecurityConnector.

Parameters:

securityVerifier - new security verifier

sendTypeDefEvent

public void sendTypeDefEvent(String sourceName,
 OMRSTypeDefEvent typeDefEvent)

Send the TypeDef event to the OMRS Topic connector (providing TypeDef Events are enabled).

Parameters:

sourceName - name of caller

typeDefEvent - properties of the event to send

sendInstanceEvent

public void sendInstanceEvent(String sourceName,
 OMRSInstanceEvent instanceEvent)

Set the instance event to the OMRS Topic connector if the instance event is of the permitted type.

Parameters:

sourceName - name of caller

instanceEvent - properties of the event to send