http://git-wip-us.apache.org/repos/asf/atlas/blob/b0ecc36a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/OMRSEventPublisher.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/OMRSEventPublisher.java b/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/OMRSEventPublisher.java deleted file mode 100644 index 12be782..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/OMRSEventPublisher.java +++ /dev/null @@ -1,1955 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * <p/> - * http://www.apache.org/licenses/LICENSE-2.0 - * <p/> - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.atlas.omrs.eventmanagement; - -import org.apache.atlas.ocf.properties.beans.Connection; -import org.apache.atlas.omrs.admin.properties.OpenMetadataEventProtocolVersion; -import org.apache.atlas.omrs.auditlog.*; -import org.apache.atlas.omrs.eventmanagement.events.*; -import org.apache.atlas.omrs.ffdc.OMRSErrorCode; -import org.apache.atlas.omrs.ffdc.exception.OMRSLogicErrorException; -import org.apache.atlas.omrs.metadatacollection.properties.instances.EntityDetail; -import org.apache.atlas.omrs.metadatacollection.properties.instances.InstanceProvenanceType; -import org.apache.atlas.omrs.metadatacollection.properties.instances.Relationship; -import org.apache.atlas.omrs.metadatacollection.properties.typedefs.AttributeTypeDef; -import org.apache.atlas.omrs.metadatacollection.properties.typedefs.TypeDef; -import org.apache.atlas.omrs.metadatacollection.properties.typedefs.TypeDefPatch; -import org.apache.atlas.omrs.metadatacollection.properties.typedefs.TypeDefSummary; -import org.apache.atlas.omrs.topicconnectors.OMRSTopicConnector; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.util.ArrayList; -import java.util.Date; -import java.util.List; - - -/** - * OMRSEventPublisher publishes OMRS Events to the supplied OMRSTopicConnector. - */ -public class OMRSEventPublisher implements OMRSRegistryEventProcessor, OMRSTypeDefEventProcessor, OMRSInstanceEventProcessor -{ - private static final OMRSAuditLog auditLog = new OMRSAuditLog(OMRSAuditingComponent.EVENT_PUBLISHER); - - private static final Logger log = LoggerFactory.getLogger(OMRSEventPublisher.class); - - private String publisherName = null; - private OMRSTopicConnector omrsTopicConnector = null; - private OpenMetadataEventProtocolVersion eventProtocolVersion = null; - - - /** - * Typical constructor sets up the local metadata collection id for events. - * - * @param publisherName - name of the cohort (or enterprise virtual repository) that this event publisher - * is sending events to. - * @param localProtocolVersion - protocol version to use - * @param topicConnector - OMRS Topic to send requests on - */ - public OMRSEventPublisher(String publisherName, - OpenMetadataEventProtocolVersion localProtocolVersion, - OMRSTopicConnector topicConnector) - { - String actionDescription = "Initialize event publisher"; - - /* - * Save the publisherName and protocol version - */ - this.eventProtocolVersion = localProtocolVersion; - this.publisherName = publisherName; - - /* - * The topic connector is needed to publish events. - */ - if (topicConnector == null) - { - if (log.isDebugEnabled()) - { - log.debug("Null topic connector"); - } - - OMRSErrorCode errorCode = OMRSErrorCode.NULL_TOPIC_CONNECTOR; - String errorMessage = errorCode.getErrorMessageId() - + errorCode.getFormattedErrorMessage(publisherName); - - throw new OMRSLogicErrorException(errorCode.getHTTPErrorCode(), - this.getClass().getName(), - actionDescription, - errorMessage, - errorCode.getSystemAction(), - errorCode.getUserAction()); - - } - - this.omrsTopicConnector = topicConnector; - - - if (log.isDebugEnabled()) - { - log.debug("New Event Publisher: " + publisherName); - } - } - - - /** - * Send the registry event to the OMRS Topic connector and manage errors - * - * @param registryEvent - properties of the event to send - * @return boolean flag to report if the call succeeded or not. - */ - private boolean sendRegistryEvent(OMRSRegistryEvent registryEvent) - { - String actionDescription = "Send Registry Event"; - boolean successFlag = false; - - if (log.isDebugEnabled()) - { - log.debug("Sending registryEvent for cohort: " + publisherName); - log.debug("topicConnector: " + omrsTopicConnector); - log.debug("registryEvent: " + registryEvent); - log.debug("localEventOriginator: " + registryEvent.getEventOriginator()); - } - - try - { - if (eventProtocolVersion == OpenMetadataEventProtocolVersion.V1) - { - omrsTopicConnector.sendEvent(registryEvent.getOMRSEventV1()); - successFlag = true; - } - } - catch (Throwable error) - { - OMRSAuditCode auditCode = OMRSAuditCode.SEND_REGISTRY_EVENT_ERROR; - - auditLog.logException(actionDescription, - auditCode.getLogMessageId(), - auditCode.getSeverity(), - auditCode.getFormattedLogMessage(publisherName), - "registryEvent : " + registryEvent.toString(), - auditCode.getSystemAction(), - auditCode.getUserAction(), - error); - - if (log.isDebugEnabled()) - { - log.debug("Exception: ", error, registryEvent); - } - } - - return successFlag; - } - - - /** - * Send the TypeDef event to the OMRS Topic connector (providing TypeDef Events are enabled). - * - * @param typeDefEvent - properties of the event to send - * @return boolean flag to report if the call succeeded or not. - */ - private boolean sendTypeDefEvent(OMRSTypeDefEvent typeDefEvent) - { - String actionDescription = "Send TypeDef Event"; - boolean successFlag = false; - - if (log.isDebugEnabled()) - { - log.debug("Sending typeDefEvent for cohort: " + publisherName); - log.debug("topicConnector: ", omrsTopicConnector); - log.debug("typeDefEvent: ", typeDefEvent); - log.debug("localEventOriginator: ", typeDefEvent.getEventOriginator()); - } - - try - { - if (eventProtocolVersion == OpenMetadataEventProtocolVersion.V1) - { - omrsTopicConnector.sendEvent(typeDefEvent.getOMRSEventV1()); - successFlag = true; - } - } - catch (Throwable error) - { - OMRSAuditCode auditCode = OMRSAuditCode.SEND_TYPEDEF_EVENT_ERROR; - - auditLog.logException(actionDescription, - auditCode.getLogMessageId(), - auditCode.getSeverity(), - auditCode.getFormattedLogMessage(publisherName), - "typeDefEvent {" + typeDefEvent.toString() + "}", - auditCode.getSystemAction(), - auditCode.getUserAction(), - error); - - if (log.isDebugEnabled()) - { - log.debug("Exception: ", error); - } - } - - return successFlag; - } - - - /** - * Set the instance event to the OMRS Topic connector if the instance - * event is of the permitted type. - * - * @param instanceEvent - properties of the event to send - * @return boolean flag to report if the call succeeded or not. - * */ - private boolean sendInstanceEvent(OMRSInstanceEvent instanceEvent) - { - String actionDescription = "Send Instance Event"; - boolean successFlag = false; - - if (log.isDebugEnabled()) - { - log.debug("Sending instanceEvent for cohort: " + publisherName); - log.debug("topicConnector: ", omrsTopicConnector); - log.debug("instanceEvent: ", instanceEvent); - log.debug("localEventOriginator: ", instanceEvent.getEventOriginator()); - } - - try - { - if (eventProtocolVersion == OpenMetadataEventProtocolVersion.V1) - { - omrsTopicConnector.sendEvent(instanceEvent.getOMRSEventV1()); - successFlag = true; - } - } - catch (Throwable error) - { - OMRSAuditCode auditCode = OMRSAuditCode.SEND_INSTANCE_EVENT_ERROR; - - auditLog.logException(actionDescription, - auditCode.getLogMessageId(), - auditCode.getSeverity(), - auditCode.getFormattedLogMessage(publisherName), - "instanceEvent {" + instanceEvent.toString() + "}", - auditCode.getSystemAction(), - auditCode.getUserAction(), - error); - - if (log.isDebugEnabled()) - { - log.debug("Exception: ", error); - } - } - - return successFlag; - } - - - /** - * Introduces the local server/repository to the metadata repository cohort. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param metadataCollectionId - unique identifier for the metadata collection that is registering with the cohort. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param registrationTimestamp - the time that the server/repository issued the registration request. - * @param remoteConnection - the Connection properties for the connector used to call the registering server. - */ - public boolean processRegistrationEvent(String sourceName, - String metadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - Date registrationTimestamp, - Connection remoteConnection) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(metadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSRegistryEvent registryEvent = new OMRSRegistryEvent(OMRSRegistryEventType.REGISTRATION_EVENT, - registrationTimestamp, - remoteConnection); - - registryEvent.setEventOriginator(eventOriginator); - - return sendRegistryEvent(registryEvent); - } - - - /** - * Requests that the other servers in the cohort send re-registration events. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - */ - public boolean processRegistrationRefreshRequest(String sourceName, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSRegistryEvent registryEvent = new OMRSRegistryEvent(OMRSRegistryEventType.REFRESH_REGISTRATION_REQUEST); - - registryEvent.setEventOriginator(eventOriginator); - - return sendRegistryEvent(registryEvent); - } - - - /** - * Refreshes the other servers in the cohort with the local server's registration. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param metadataCollectionId - unique identifier for the metadata collection that is registering with the cohort. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param registrationTimestamp - the time that the server/repository first registered with the cohort. - * @param remoteConnection - the Connection properties for the connector used to call the registering server. - */ - public boolean processReRegistrationEvent(String sourceName, - String metadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - Date registrationTimestamp, - Connection remoteConnection) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(metadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSRegistryEvent registryEvent = new OMRSRegistryEvent(OMRSRegistryEventType.RE_REGISTRATION_EVENT, - registrationTimestamp, - remoteConnection); - - registryEvent.setEventOriginator(eventOriginator); - - return sendRegistryEvent(registryEvent); - } - - - /** - * A server/repository is being removed from the metadata repository cohort. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param metadataCollectionId - unique identifier for the metadata collection that is registering with the cohort. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - */ - public boolean processUnRegistrationEvent(String sourceName, - String metadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(metadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSRegistryEvent registryEvent = new OMRSRegistryEvent(OMRSRegistryEventType.UN_REGISTRATION_EVENT); - - registryEvent.setEventOriginator(eventOriginator); - - return sendRegistryEvent(registryEvent); - } - - - /** - * There is more than one member of the open metadata repository cohort that is using the same metadata - * collection Id. This means that their metadata instances can be updated in more than one server and there - * is a potential for data integrity issues. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param conflictingMetadataCollectionId - unique identifier for the remote metadata collection that is - * registering with the cohort. - * @param errorMessage - details of the conflict - */ - public void processConflictingCollectionIdEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - String conflictingMetadataCollectionId, - String errorMessage) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSRegistryEvent registryEvent = new OMRSRegistryEvent(OMRSRegistryEventErrorCode.CONFLICTING_COLLECTION_ID, - errorMessage, - conflictingMetadataCollectionId, - null); - - registryEvent.setEventOriginator(eventOriginator); - - sendRegistryEvent(registryEvent); - } - - - /** - * A connection to one of the members of the open metadata repository cohort is not usable by one of the members. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param targetMetadataCollectionId - Id for the repository with the bad remote connection. - * @param remoteConnection - the Connection properties for the connector used to call the registering server. - * @param errorMessage - details of the error that occurs when the connection is used. - */ - public void processBadConnectionEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - String targetMetadataCollectionId, - Connection remoteConnection, - String errorMessage) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSRegistryEvent registryEvent = new OMRSRegistryEvent(OMRSRegistryEventErrorCode.CONFLICTING_COLLECTION_ID, - errorMessage, - targetMetadataCollectionId, - remoteConnection); - - registryEvent.setEventOriginator(eventOriginator); - - sendRegistryEvent(registryEvent); - } - - - /** - * A new TypeDef has been defined. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param typeDef - details of the new TypeDef - */ - public void processNewTypeDefEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - TypeDef typeDef) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSTypeDefEvent typeDefEvent = new OMRSTypeDefEvent(OMRSTypeDefEventType.NEW_TYPEDEF_EVENT, typeDef); - - typeDefEvent.setEventOriginator(eventOriginator); - - this.sendTypeDefEvent(typeDefEvent); - } - - /** - * A new AttributeTypeDef has been defined in an open metadata repository. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param attributeTypeDef - details of the new AttributeTypeDef. - */ - public void processNewAttributeTypeDefEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - AttributeTypeDef attributeTypeDef) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSTypeDefEvent typeDefEvent = new OMRSTypeDefEvent(OMRSTypeDefEventType.NEW_ATTRIBUTE_TYPEDEF_EVENT, attributeTypeDef); - - typeDefEvent.setEventOriginator(eventOriginator); - - this.sendTypeDefEvent(typeDefEvent); - } - - - /** - * An existing TypeDef has been updated. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param typeDefPatch - details of the new version of the TypeDef - */ - public void processUpdatedTypeDefEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - TypeDefPatch typeDefPatch) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSTypeDefEvent typeDefEvent = new OMRSTypeDefEvent(OMRSTypeDefEventType.UPDATED_TYPEDEF_EVENT, typeDefPatch); - - typeDefEvent.setEventOriginator(eventOriginator); - - this.sendTypeDefEvent(typeDefEvent); - } - - - /** - * An existing TypeDef has been deleted. Both the name and the GUID are provided to ensure the right TypeDef is - * deleted in remote repositories. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param typeDefGUID - unique identifier of the TypeDef - * @param typeDefName - unique name of the TypeDef - */ - public void processDeletedTypeDefEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - String typeDefGUID, - String typeDefName) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSTypeDefEvent typeDefEvent = new OMRSTypeDefEvent(OMRSTypeDefEventType.DELETED_TYPEDEF_EVENT, - typeDefGUID, - typeDefName); - - typeDefEvent.setEventOriginator(eventOriginator); - - this.sendTypeDefEvent(typeDefEvent); - } - - - /** - * An existing AttributeTypeDef has been deleted in an open metadata repository. Both the name and the - * GUID are provided to ensure the right AttributeTypeDef is deleted in other cohort member repositories. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param attributeTypeDefGUID - unique identifier of the AttributeTypeDef - * @param attributeTypeDefName - unique name of the AttributeTypeDef - */ - public void processDeletedAttributeTypeDefEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - String attributeTypeDefGUID, - String attributeTypeDefName) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSTypeDefEvent typeDefEvent = new OMRSTypeDefEvent(OMRSTypeDefEventType.DELETED_ATTRIBUTE_TYPEDEF_EVENT, - attributeTypeDefGUID, - attributeTypeDefName); - - typeDefEvent.setEventOriginator(eventOriginator); - - this.sendTypeDefEvent(typeDefEvent); - } - - - /** - * The guid or name of an existing TypeDef has been changed to a new value. This is used if two different - * Typedefs are discovered to have either the same guid or, most likely, the same name. This type of conflict - * is rare but typically occurs when a new repository joins the cohort. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param originalTypeDefSummary - the details for the original TypeDef. - * @param typeDef - updated TypeDef with new identifiers - */ - public void processReIdentifiedTypeDefEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - TypeDefSummary originalTypeDefSummary, - TypeDef typeDef) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - - OMRSTypeDefEvent typeDefEvent = new OMRSTypeDefEvent(OMRSTypeDefEventType.RE_IDENTIFIED_TYPEDEF_EVENT, - originalTypeDefSummary, - typeDef); - - typeDefEvent.setEventOriginator(eventOriginator); - - this.sendTypeDefEvent(typeDefEvent); - } - - /** - * Process an event that changes either the name or guid of an AttributeTypeDef. - * It is resolving a Conflicting AttributeTypeDef Error. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param originalAttributeTypeDef - description of original AttributeTypeDef - * @param attributeTypeDef - updated AttributeTypeDef with new identifiers inside. - */ - public void processReIdentifiedAttributeTypeDefEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - AttributeTypeDef originalAttributeTypeDef, - AttributeTypeDef attributeTypeDef) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - - OMRSTypeDefEvent typeDefEvent = new OMRSTypeDefEvent(OMRSTypeDefEventType.RE_IDENTIFIED_ATTRIBUTE_TYPEDEF_EVENT, - originalAttributeTypeDef, - attributeTypeDef); - - typeDefEvent.setEventOriginator(eventOriginator); - - this.sendTypeDefEvent(typeDefEvent); - } - - - /** - * Process a detected conflict in type definitions (TypeDefs) used in the cohort. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param originatorTypeDefSummary - details of the TypeDef in the event originator - * @param otherMetadataCollectionId - the metadataCollection using the conflicting TypeDef - * @param conflictingTypeDefSummary - the details of the TypeDef in the other metadata collection - * @param errorMessage - details of the error that occurs when the connection is used. - */ - public void processTypeDefConflictEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - TypeDefSummary originatorTypeDefSummary, - String otherMetadataCollectionId, - TypeDefSummary conflictingTypeDefSummary, - String errorMessage) - - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSTypeDefEvent typeDefEvent = new OMRSTypeDefEvent(OMRSTypeDefEventErrorCode.CONFLICTING_TYPEDEFS, - errorMessage, - originatorMetadataCollectionId, - originatorTypeDefSummary, - conflictingTypeDefSummary); - - typeDefEvent.setEventOriginator(eventOriginator); - - this.sendTypeDefEvent(typeDefEvent); - } - - - /** - * Process a detected conflict in the attribute type definitions (AttributeTypeDefs) used in the cohort. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param originatorAttributeTypeDef- description of the AttributeTypeDef in the event originator. - * @param otherMetadataCollectionId - the metadataCollection using the conflicting AttributeTypeDef. - * @param conflictingAttributeTypeDef - description of the AttributeTypeDef in the other metadata collection. - * @param errorMessage - details of the error that occurs when the connection is used. - */ - public void processAttributeTypeDefConflictEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - AttributeTypeDef originatorAttributeTypeDef, - String otherMetadataCollectionId, - AttributeTypeDef conflictingAttributeTypeDef, - String errorMessage) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSTypeDefEvent typeDefEvent = new OMRSTypeDefEvent(OMRSTypeDefEventErrorCode.CONFLICTING_ATTRIBUTE_TYPEDEFS, - errorMessage, - originatorMetadataCollectionId, - originatorAttributeTypeDef, - conflictingAttributeTypeDef); - - typeDefEvent.setEventOriginator(eventOriginator); - - this.sendTypeDefEvent(typeDefEvent); - } - - - /** - * A TypeDef from another member in the cohort is at a different version than the local repository. This may - * create some inconsistencies in the different copies of instances of this type in different members of the - * cohort. The recommended action is to update all TypeDefs to the latest version. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param targetMetadataCollectionId - identifier of the metadata collection that is reporting a TypeDef at a - * different level to the local repository. - * @param targetTypeDefSummary - details of the TypeDef being patched - * @param otherTypeDef - details of the TypeDef in the local repository. - */ - public void processTypeDefPatchMismatchEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - String targetMetadataCollectionId, - TypeDefSummary targetTypeDefSummary, - TypeDef otherTypeDef, - String errorMessage) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - - - OMRSTypeDefEvent typeDefEvent = new OMRSTypeDefEvent(OMRSTypeDefEventErrorCode.TYPEDEF_PATCH_MISMATCH, - errorMessage, - targetMetadataCollectionId, - targetTypeDefSummary, - otherTypeDef); - - typeDefEvent.setEventOriginator(eventOriginator); - - this.sendTypeDefEvent(typeDefEvent); - } - - - /** - * A new entity has been created. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param entity - details of the new entity - */ - public void processNewEntityEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - EntityDetail entity) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.NEW_ENTITY_EVENT, - entity); - - - instanceEvent.setEventOriginator(eventOriginator); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * An existing entity has been updated. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param entity - details of the new version of the entity. - */ - public void processUpdatedEntityEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - EntityDetail entity) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.UPDATED_ENTITY_EVENT, - entity); - - - instanceEvent.setEventOriginator(eventOriginator); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * An update to an entity has been undone. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param entity - details of the version of the entity that has been restored. - */ - public void processUndoneEntityEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - EntityDetail entity) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.UNDONE_ENTITY_EVENT, - entity); - - - instanceEvent.setEventOriginator(eventOriginator); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * A new classification has been added to an entity. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param entity - details of the entity with the new classification added. - */ - public void processClassifiedEntityEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - EntityDetail entity) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.CLASSIFIED_ENTITY_EVENT, - entity); - - - instanceEvent.setEventOriginator(eventOriginator); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * A classification has been removed from an entity. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param entity - details of the entity after the classification has been removed. - */ - public void processDeclassifiedEntityEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - EntityDetail entity) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.DECLASSIFIED_ENTITY_EVENT, - entity); - - - instanceEvent.setEventOriginator(eventOriginator); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * An existing classification has been changed on an entity. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param entity - details of the entity after the classification has been changed. - */ - public void processReclassifiedEntityEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - EntityDetail entity) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.RECLASSIFIED_ENTITY_EVENT, - entity); - - - instanceEvent.setEventOriginator(eventOriginator); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * An existing entity has been deleted. This is a soft delete. This means it is still in the repository - * but it is no longer returned on queries. - * - * All relationships to the entity are also soft-deleted and will no longer be usable. These deleted relationships - * will be notified through separate events. - * - * Details of the TypeDef are included with the entity's unique id (guid) to ensure the right entity is deleted in - * the remote repositories. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param entity - deleted entity - */ - public void processDeletedEntityEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - EntityDetail entity) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.DELETED_ENTITY_EVENT, - entity); - - instanceEvent.setEventOriginator(eventOriginator); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * A deleted entity has been permanently removed from the repository. This request can not be undone. - * - * Details of the TypeDef are included with the entity's unique id (guid) to ensure the right entity is purged in - * the remote repositories. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param typeDefGUID - unique identifier for this entity's TypeDef - * @param typeDefName - name of this entity's TypeDef - * @param instanceGUID - unique identifier for the entity - */ - public void processPurgedEntityEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - String typeDefGUID, - String typeDefName, - String instanceGUID) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.PURGED_ENTITY_EVENT, - typeDefGUID, - typeDefName, - instanceGUID); - - instanceEvent.setEventOriginator(eventOriginator); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * A deleted entity has been restored to the state it was before it was deleted. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param entity - details of the version of the entity that has been restored. - */ - public void processRestoredEntityEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - EntityDetail entity) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.RESTORED_ENTITY_EVENT, - entity); - - - instanceEvent.setEventOriginator(eventOriginator); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * The guid of an existing entity has been changed to a new value. This is used if two different - * entities are discovered to have the same guid. This is extremely unlikely but not impossible so - * the open metadata protocol has provision for this. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param originalEntityGUID - the existing identifier for the entity. - * @param entity - new values for this entity, including the new guid. - */ - public void processReIdentifiedEntityEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - String originalEntityGUID, - EntityDetail entity) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.RE_IDENTIFIED_ENTITY_EVENT, - entity); - - instanceEvent.setEventOriginator(eventOriginator); - instanceEvent.setOriginalInstanceGUID(originalEntityGUID); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * An existing entity has had its type changed. Typically this action is taken to move an entity's - * type to either a super type (so the subtype can be deleted) or a new subtype (so additional properties can be - * added.) However, the type can be changed to any compatible type. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param originalTypeDefSummary - original details for this entity's TypeDef. - * @param entity - new values for this entity, including the new type information. - */ - public void processReTypedEntityEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - TypeDefSummary originalTypeDefSummary, - EntityDetail entity) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.RETYPED_ENTITY_EVENT, - entity); - - instanceEvent.setEventOriginator(eventOriginator); - instanceEvent.setOriginalTypeDefSummary(originalTypeDefSummary); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * An existing entity has changed home repository. This action is taken for example, if a repository - * becomes permanently unavailable, or if the user community updating this entity move to working - * from a different repository in the open metadata repository cohort. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param originalHomeMetadataCollectionId - unique identifier for the original home repository. - * @param entity - new values for this entity, including the new home information. - */ - public void processReHomedEntityEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - String originalHomeMetadataCollectionId, - EntityDetail entity) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.RE_HOMED_ENTITY_EVENT, - entity); - - instanceEvent.setEventOriginator(eventOriginator); - instanceEvent.setOriginalHomeMetadataCollectionId(originalHomeMetadataCollectionId); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * The local repository is requesting that an entity from another repository's metadata collection is - * refreshed so the local repository can create a reference copy. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param typeDefGUID - - unique identifier for this entity's TypeDef - * @param typeDefName - name of this entity's TypeDef - * @param instanceGUID - unique identifier for the entity - * @param homeMetadataCollectionId - metadata collection id for the home of this instance. - */ - public void processRefreshEntityRequested(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - String typeDefGUID, - String typeDefName, - String instanceGUID, - String homeMetadataCollectionId) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.REFRESH_ENTITY_REQUEST, - typeDefGUID, - typeDefName, - instanceGUID); - - instanceEvent.setEventOriginator(eventOriginator); - instanceEvent.setHomeMetadataCollectionId(homeMetadataCollectionId); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * A remote repository in the cohort has sent entity details in response to a refresh request. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param entity - details of the requested entity - */ - public void processRefreshEntityEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - EntityDetail entity) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.REFRESHED_ENTITY_EVENT, - entity); - - instanceEvent.setEventOriginator(eventOriginator); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * A new relationship has been created. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param relationship - details of the new relationship - */ - public void processNewRelationshipEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - Relationship relationship) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.NEW_RELATIONSHIP_EVENT, - relationship); - - instanceEvent.setEventOriginator(eventOriginator); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * An existing relationship has been updated. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param relationship - details of the new version of the relationship. - */ - public void processUpdatedRelationshipEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - Relationship relationship) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.UPDATED_RELATIONSHIP_EVENT, - relationship); - - instanceEvent.setEventOriginator(eventOriginator); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * An update to a relationship has been undone. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param relationship - details of the version of the relationship that has been restored. - */ - public void processUndoneRelationshipEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - Relationship relationship) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.UNDONE_RELATIONSHIP_EVENT, - relationship); - - instanceEvent.setEventOriginator(eventOriginator); - - this.sendInstanceEvent(instanceEvent); - } - - /** - * An existing relationship has been deleted. This is a soft delete. This means it is still in the repository - * but it is no longer returned on queries. - * - * Details of the TypeDef are included with the relationship's unique id (guid) to ensure the right - * relationship is deleted in the remote repositories. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param relationship - deleted relationship - */ - public void processDeletedRelationshipEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - Relationship relationship) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.DELETED_RELATIONSHIP_EVENT, - relationship); - - instanceEvent.setEventOriginator(eventOriginator); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * A deleted relationship has been permanently removed from the repository. This request can not be undone. - * - * Details of the TypeDef are included with the relationship's unique id (guid) to ensure the right - * relationship is purged in the remote repositories. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @param originatorMetadataCollectionId - unique identifier for the metadata collection hosted by the server that - * sent the event. - * @param originatorServerName - name of the server that the event came from. - * @param originatorServerType - type of server that the event came from. - * @param originatorOrganizationName - name of the organization that owns the server that sent the event. - * @param typeDefGUID - unique identifier for this relationship's TypeDef. - * @param typeDefName - name of this relationship's TypeDef. - * @param instanceGUID - unique identifier for the relationship. - */ - public void processPurgedRelationshipEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - String typeDefGUID, - String typeDefName, - String instanceGUID) - { - OMRSEventOriginator eventOriginator = new OMRSEventOriginator(); - - eventOriginator.setMetadataCollectionId(originatorMetadataCollectionId); - eventOriginator.setServerName(originatorServerName); - eventOriginator.setServerType(originatorServerType); - eventOriginator.setOrganizationName(originatorOrganizationName); - - OMRSInstanceEvent instanceEvent = new OMRSInstanceEvent(OMRSInstanceEventType.PURGED_RELATIONSHIP_EVENT, - typeDefGUID, - typeDefName, - instanceGUID); - - instanceEvent.setEventOriginator(eventOriginator); - - this.sendInstanceEvent(instanceEvent); - } - - - /** - * A deleted relationship has been restored to the state it was before it was deleted. - * - * @param sourceName - name of the source of the event. It may be the cohort name for incoming events or the - * local repository, or event mapper name. - * @pa
<TRUNCATED>
