http://git-wip-us.apache.org/repos/asf/atlas/blob/b0ecc36a/omrs/src/main/java/org/apache/atlas/omrs/enterprise/repositoryconnector/EnterpriseOMRSRepositoryConnector.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/enterprise/repositoryconnector/EnterpriseOMRSRepositoryConnector.java b/omrs/src/main/java/org/apache/atlas/omrs/enterprise/repositoryconnector/EnterpriseOMRSRepositoryConnector.java deleted file mode 100644 index 996ca27..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/enterprise/repositoryconnector/EnterpriseOMRSRepositoryConnector.java +++ /dev/null @@ -1,473 +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.enterprise.repositoryconnector; - -import org.apache.atlas.ocf.Connector; -import org.apache.atlas.ocf.ffdc.ConnectorCheckedException; -import org.apache.atlas.omrs.auditlog.OMRSAuditCode; -import org.apache.atlas.omrs.auditlog.OMRSAuditLog; -import org.apache.atlas.omrs.auditlog.OMRSAuditingComponent; -import org.apache.atlas.omrs.enterprise.connectormanager.OMRSConnectorConsumer; -import org.apache.atlas.omrs.enterprise.connectormanager.OMRSConnectorManager; -import org.apache.atlas.omrs.ffdc.exception.RepositoryErrorException; -import org.apache.atlas.omrs.localrepository.repositorycontentmanager.OMRSRepositoryHelper; -import org.apache.atlas.omrs.localrepository.repositorycontentmanager.OMRSRepositoryValidator; -import org.apache.atlas.omrs.metadatacollection.OMRSMetadataCollection; -import org.apache.atlas.omrs.metadatacollection.properties.instances.InstanceHeader; -import org.apache.atlas.omrs.metadatacollection.repositoryconnector.OMRSRepositoryConnector; -import org.apache.atlas.omrs.ffdc.OMRSErrorCode; -import org.apache.atlas.omrs.ffdc.exception.OMRSRuntimeException; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.util.ArrayList; -import java.util.Iterator; -import java.util.List; - -/** - * EnterpriseOMRSRepositoryConnector supports federating calls to multiple metadata repositories. As a result, - * its OMRSMetadataCollection (EnterpriseOMRSMetadataCollection) returns metadata from all repositories in the - * connected open metadata repository cohort(s). - * <p> - * An instance of the EnterpriseOMRSRepositoryConnector is created by each Open Metadata Access Service (OMAS) - * using the OCF ConnectorBroker. They use its metadata collection to retrieve and send the metadata they need. - * </p> - * <p> - * Each EnterpriseOMRSRepositoryConnector instance needs to maintain an up to date list of OMRS Connectors to all of the - * repositories in the connected open metadata repository cohort(s). It does by registering as an OMRSConnectorConsumer - * with the OMRSConnectorManager to be notified when connectors to new open metadata repositories are available. - * </p> - */ -public class EnterpriseOMRSRepositoryConnector extends OMRSRepositoryConnector implements OMRSConnectorConsumer -{ - private OMRSConnectorManager connectorManager = null; - private String connectorConsumerId = null; - - private FederatedConnector localCohortConnector = null; - private ArrayList<FederatedConnector> remoteCohortConnectors = new ArrayList<>(); - - private String accessServiceName = null; - - private static final Logger log = LoggerFactory.getLogger(EnterpriseOMRSRepositoryConnector.class); - private static final OMRSAuditLog auditLog = new OMRSAuditLog(OMRSAuditingComponent.ENTERPRISE_REPOSITORY_CONNECTOR); - - - /** - * Constructor used by the EnterpriseOMRSConnectorProvider. - * - * @param connectorManager - provides notifications as repositories register and unregister with the - * cohorts. - */ - public EnterpriseOMRSRepositoryConnector(OMRSConnectorManager connectorManager) - { - super(); - - String methodName = "constructor"; - - this.connectorManager = connectorManager; - - if (connectorManager != null) - { - this.connectorConsumerId = connectorManager.registerConnectorConsumer(this); - } - else - { - OMRSErrorCode errorCode = OMRSErrorCode.INVALID_COHORT_CONFIG; - String errorMessage = errorCode.getErrorMessageId() + errorCode.getFormattedErrorMessage(); - - throw new OMRSRuntimeException(errorCode.getHTTPErrorCode(), - this.getClass().getName(), - methodName, - errorMessage, - errorCode.getSystemAction(), - errorCode.getUserAction()); - } - } - - - /** - * Set up the unique Id for this metadata collection. - * - * @param metadataCollectionId - String unique Id - */ - public void setMetadataCollectionId(String metadataCollectionId) - { - super.metadataCollectionId = metadataCollectionId; - - if (metadataCollectionId != null) - { - super.metadataCollection = new EnterpriseOMRSMetadataCollection(this, - super.serverName, - repositoryHelper, - repositoryValidator, - metadataCollectionId); - - } - } - - - /** - * Return the name of the access service using this connector. - * - * @return access service name - */ - public String getAccessServiceName() - { - return accessServiceName; - } - - - /** - * Set up the name of the access service using this connector. - * - * @param accessServiceName - string name - */ - public void setAccessServiceName(String accessServiceName) - { - this.accessServiceName = accessServiceName; - } - - - /** - * Indicates that the connector is completely configured and can begin processing. - * - * @throws ConnectorCheckedException - there is a problem within the connector. - */ - public void start() throws ConnectorCheckedException - { - super.start(); - - final String actionDescription = "start"; - - OMRSAuditCode auditCode = OMRSAuditCode.STARTING_ENTERPRISE_CONNECTOR; - auditLog.logRecord(actionDescription, - auditCode.getLogMessageId(), - auditCode.getSeverity(), - auditCode.getFormattedLogMessage(accessServiceName), - null, - auditCode.getSystemAction(), - auditCode.getUserAction()); - } - - - /** - * Free up any resources held since the connector is no longer needed. - * - * @throws ConnectorCheckedException - there is a problem disconnecting the connector. - */ - public void disconnect() throws ConnectorCheckedException - { - super.disconnect(); - - final String actionDescription = "disconnect"; - - OMRSAuditCode auditCode = OMRSAuditCode.DISCONNECTING_ENTERPRISE_CONNECTOR; - auditLog.logRecord(actionDescription, - auditCode.getLogMessageId(), - auditCode.getSeverity(), - auditCode.getFormattedLogMessage(accessServiceName), - null, - auditCode.getSystemAction(), - auditCode.getUserAction()); - - if ((connectorManager != null) && (connectorConsumerId != null)) - { - connectorManager.unregisterConnectorConsumer(connectorConsumerId); - } - - localCohortConnector = null; - remoteCohortConnectors = new ArrayList<>(); - } - - - /** - * Returns the connector to the repository where the supplied instance can be updated - ie its home repository. - * - * @param instance - instance to test - * @param methodName - name of method making the request (used for logging) - * @return repository connector - * @throws RepositoryErrorException - home metadata collection is null - */ - protected OMRSRepositoryConnector getHomeConnector(InstanceHeader instance, - String methodName) throws RepositoryErrorException - { - this.validateRepositoryIsActive(methodName); - - repositoryValidator.validateHomeMetadataGUID(repositoryName, instance, methodName); - - String instanceMetadataCollectionId = instance.getMetadataCollectionId(); - - if (instanceMetadataCollectionId.equals(localCohortConnector.getMetadataCollectionId())) - { - return localCohortConnector.getConnector(); - } - - for (FederatedConnector remoteCohortConnector : remoteCohortConnectors) - { - if (remoteCohortConnector != null) - { - if (instanceMetadataCollectionId.equals(remoteCohortConnector.getMetadataCollectionId())) - { - return remoteCohortConnector.getConnector(); - } - } - } - - return null; - } - - - /** - * Returns the list of repository connectors that the EnterpriseOMRSRepositoryConnector is federating queries across. - * - * This method is used by this connector's metadata collection object on each request it processes. This - * means it always has the most up to date list of connectors to work with. - * - * @param methodName - name of method making the request (used for logging) - * @return OMRSRepositoryConnector List - * @throws RepositoryErrorException - the enterprise services are not available - */ - protected List<OMRSRepositoryConnector> getCohortConnectors(String methodName) throws RepositoryErrorException - { - this.validateRepositoryIsActive(methodName); - - List<OMRSRepositoryConnector> cohortConnectors = new ArrayList<>(); - - /* - * Make sure the local connector is first. - */ - if (localCohortConnector != null) - { - cohortConnectors.add(localCohortConnector.getConnector()); - } - - /* - * Now add the remote connectors. - */ - for (FederatedConnector federatedConnector : remoteCohortConnectors) - { - cohortConnectors.add(federatedConnector.getConnector()); - } - - if (! cohortConnectors.isEmpty()) - { - return cohortConnectors; - } - else - { - OMRSErrorCode errorCode = OMRSErrorCode.NO_REPOSITORIES; - String errorMessage = errorCode.getErrorMessageId() + errorCode.getFormattedErrorMessage(accessServiceName); - - throw new RepositoryErrorException(errorCode.getHTTPErrorCode(), - this.getClass().getName(), - methodName, - errorMessage, - errorCode.getSystemAction(), - errorCode.getUserAction()); - } - - } - - - /** - * Save the connector to the local repository. This is passed from the OMRSConnectorManager. - * - * @param metadataCollectionId - Unique identifier for the metadata collection. - * @param localConnector - OMRSRepositoryConnector object for the local repository. - */ - public void setLocalConnector(String metadataCollectionId, - OMRSRepositoryConnector localConnector) - { - if (localConnector != null) - { - localCohortConnector = new FederatedConnector(metadataCollectionId, localConnector); - } - else - { - localCohortConnector = null; - } - } - - - /** - * Pass the connector to one of the remote repositories in the metadata repository cohort. - * - * @param metadataCollectionId - Unique identifier for the metadata collection. - * @param remoteConnector - OMRSRepositoryConnector object providing access to the remote repository. - */ - public void addRemoteConnector(String metadataCollectionId, - OMRSRepositoryConnector remoteConnector) - { - if (remoteConnector != null) - { - remoteCohortConnectors.add(new FederatedConnector(metadataCollectionId, remoteConnector)); - } - } - - - /** - * Pass the metadata collection id for a repository that has just left the metadata repository cohort. - * - * @param metadataCollectionId - identifier of the metadata collection that is no longer available. - */ - public void removeRemoteConnector(String metadataCollectionId) - { - Iterator<FederatedConnector> iterator = remoteCohortConnectors.iterator(); - - while(iterator.hasNext()) - { - FederatedConnector registeredConnector = iterator.next(); - - if (registeredConnector.getMetadataCollectionId().equals(metadataCollectionId)) - { - this.disconnectConnector(registeredConnector); - iterator.remove(); - } - } - } - - - /** - * Call disconnect on all registered connectors and stop calling them. The OMRS is about to shutdown. - */ - public void disconnectAllConnectors() - { - try - { - super.disconnect(); - } - catch (Throwable error) - { - /* - * Nothing to do - */ - } - - if (localCohortConnector != null) - { - this.disconnectConnector(localCohortConnector); - } - - if (remoteCohortConnectors != null) - { - for (FederatedConnector remoteConnector : remoteCohortConnectors) - { - if (remoteConnector != null) - { - this.disconnectConnector(remoteConnector); - } - } - } - } - - - /** - * Issue a disconnect call on the supplied connector. - * - * @param federatedConnector - connector to disconnect. - */ - private void disconnectConnector(FederatedConnector federatedConnector) - { - Connector connector = null; - - if (federatedConnector != null) - { - connector = federatedConnector.getConnector(); - } - - if (connector != null) - { - try - { - connector.disconnect(); - } - catch (Throwable error) - { - log.error("Exception from disconnect of connector to metadata collection:" + federatedConnector.getMetadataCollectionId() + " Error message was: " + error.getMessage()); - } - } - } - - /** - * FederatedConnector is a private class for storing details of each of the connectors to the repositories - * in the open metadata repository cohort. - */ - private class FederatedConnector - { - private String metadataCollectionId = null; - private OMRSRepositoryConnector connector = null; - - - /** - * Constructor to set up the details of a federated connector. - * - * @param metadataCollectionId - unique identifier for the metadata collection accessed through the connector - * @param connector - connector for the repository - */ - public FederatedConnector(String metadataCollectionId, OMRSRepositoryConnector connector) - { - this.metadataCollectionId = metadataCollectionId; - this.connector = connector; - } - - - /** - * Return the identifier for the metadata collection accessed through the connector. - * - * @return String identifier - */ - public String getMetadataCollectionId() - { - return metadataCollectionId; - } - - - /** - * Return the connector for the repository. - * - * @return OMRSRepositoryConnector object - */ - public OMRSRepositoryConnector getConnector() - { - return connector; - } - - - /** - * Return the metadata collection associated with the connector. - * - * @return OMRSMetadataCollection object - */ - public OMRSMetadataCollection getMetadataCollection() - { - if (connector != null) - { - try - { - return connector.getMetadataCollection(); - } - catch (Throwable error) - { - return null; - } - } - - return null; - } - } -}
http://git-wip-us.apache.org/repos/asf/atlas/blob/b0ecc36a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/OMRSEventListener.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/OMRSEventListener.java b/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/OMRSEventListener.java deleted file mode 100644 index 2c8de30..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/OMRSEventListener.java +++ /dev/null @@ -1,826 +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.omrs.auditlog.OMRSAuditCode; -import org.apache.atlas.omrs.auditlog.OMRSAuditLog; -import org.apache.atlas.omrs.auditlog.OMRSAuditingComponent; -import org.apache.atlas.omrs.eventmanagement.events.*; -import org.apache.atlas.omrs.eventmanagement.events.v1.OMRSEventV1; -import org.apache.atlas.omrs.topicconnectors.OMRSTopicListener; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -/** - * <p> - * The OMRSEventListener manages inbound events from the metadata repository cohort. There are - * two main groups of events: registration events that are handled by the OMRSCohortRegistry and metadata - * events that describe changes to TypeDefs and metadata instances. The metadata events are handled by the - * local connector. - * </p> - * <p> - * The role of the OMRSEventListener is to decide which events to process. This is controlled by the - * synchronization rule passed on the constructor. - * </p> - */ -public class OMRSEventListener implements OMRSTopicListener -{ - private String cohortName = null; - private String localMetadataCollectionId = null; - - /* - * There is an event processor for each category of event. The OMRSEventListener passes appropriate events to these - * objects depending on the settings of its configuration. - */ - private OMRSRegistryEventProcessor registryEventProcessor = null; - private OMRSTypeDefEventProcessor typeDefEventProcessor = null; - private OMRSInstanceEventProcessor instanceEventProcessor = null; - - /* - * The audit log is used for recording events, decisions, errors and exceptions - */ - private OMRSAuditLog auditLog = new OMRSAuditLog(OMRSAuditingComponent.EVENT_LISTENER); - - - private static final Logger log = LoggerFactory.getLogger(OMRSEventListener.class); - - - /** - * Default Constructor - saves configuration parameters. - * - * @param cohortName - name of the cohort that this event listener belongs to - * @param localMetadataCollectionId - unique identifier for the local metadata collection - * @param registryEventProcessor - processor for registry events - * @param typeDefEventProcessor - processor for TypeDef synchronization events - * @param instanceEventProcessor - processor for metadata instance replication - */ - public OMRSEventListener(String cohortName, - String localMetadataCollectionId, - OMRSRegistryEventProcessor registryEventProcessor, - OMRSTypeDefEventProcessor typeDefEventProcessor, - OMRSInstanceEventProcessor instanceEventProcessor) - { - this.cohortName = cohortName; - this.localMetadataCollectionId = localMetadataCollectionId; - this.registryEventProcessor = registryEventProcessor; - this.typeDefEventProcessor = typeDefEventProcessor; - this.instanceEventProcessor = instanceEventProcessor; - } - - - /** - * Process an incoming event. This method is called by the OMRSTopicConnector. The processing is careful of nulls - * and ignores an event that is incorrectly formatted. The assumption is that the unformatted part of the message - * is an extension from a newer version of the protocol and can be ignored. - * - * @param event Version 1 of the OMRSEvent that defines the category and payload of the incoming event. - */ - public void processEvent(OMRSEventV1 event) - { - String actionDescription = "Process Incoming Event"; - - /* - * The event should not be null but worth checking. - */ - if (event != null) - { - /* - * If the event came from this server - then ignore it. - */ - if ((localMetadataCollectionId != null) && - (localMetadataCollectionId.equals(event.getOriginator().getMetadataCollectionId()))) - { - if (log.isDebugEnabled()) - { - log.debug("Ignoring event that this server originated"); - } - } - else - { - /* - * Determine the category of event to process. - */ - switch (event.getEventCategory()) - { - case REGISTRY: - this.processRegistryEvent(new OMRSRegistryEvent(event)); - break; - - case TYPEDEF: - this.processTypeDefEvent(new OMRSTypeDefEvent(event)); - break; - - case INSTANCE: - this.processInstanceEvent(new OMRSInstanceEvent(event)); - break; - - default: - /* - * Nothing to do since this server does not understand the message type. This situation - * will occur if the local server is back level from another server in the cohort - * and the more advanced server supports new types of messages, - */ - OMRSAuditCode auditCode = OMRSAuditCode.PROCESS_UNKNOWN_EVENT; - - auditLog.logRecord(actionDescription, - auditCode.getLogMessageId(), - auditCode.getSeverity(), - auditCode.getFormattedLogMessage(), - "event {" + event.toString() + "}", - auditCode.getSystemAction(), - auditCode.getUserAction()); - - if (log.isDebugEnabled()) - { - log.debug("Unknown event received :|"); - } - - } - } - } - else - { - /* - * A null event was passed - probably should not happen so log audit record. - */ - OMRSAuditCode auditCode = OMRSAuditCode.NULL_OMRS_EVENT_RECEIVED; - - auditLog.logRecord(actionDescription, - auditCode.getLogMessageId(), - auditCode.getSeverity(), - auditCode.getFormattedLogMessage(), - null, - auditCode.getSystemAction(), - auditCode.getUserAction()); - - if (log.isDebugEnabled()) - { - log.debug("Null OMRS Event received :("); - } - } - } - - - /** - * The event contains a registry event. It needs to be further unpacked and passed to the appropriate - * registry event processor (OMRSCohortRegistry). - * - * @param registryEvent event to unpack - */ - private void processRegistryEvent(OMRSRegistryEvent registryEvent) - { - if (log.isDebugEnabled()) - { - log.debug("Processing registry event", registryEvent); - } - - if (registryEvent == null) - { - if (log.isDebugEnabled()) - { - log.debug("Null registry event - ignoring event"); - } - } - else if (registryEventProcessor == null) - { - if (log.isDebugEnabled()) - { - log.debug("No registry event processor - ignoring event "); - } - } - else /* process registry event */ - { - OMRSRegistryEventType registryEventType = registryEvent.getRegistryEventType(); - OMRSEventOriginator registryEventOriginator = registryEvent.getEventOriginator(); - - if ((registryEventType != null) && (registryEventOriginator != null)) - { - switch (registryEventType) - { - case REGISTRATION_EVENT: - registryEventProcessor.processRegistrationEvent(cohortName, - registryEventOriginator.getMetadataCollectionId(), - registryEventOriginator.getServerName(), - registryEventOriginator.getServerType(), - registryEventOriginator.getOrganizationName(), - registryEvent.getRegistrationTimestamp(), - registryEvent.getRemoteConnection()); - break; - - case RE_REGISTRATION_EVENT: - registryEventProcessor.processReRegistrationEvent(cohortName, - registryEventOriginator.getMetadataCollectionId(), - registryEventOriginator.getServerName(), - registryEventOriginator.getServerType(), - registryEventOriginator.getOrganizationName(), - registryEvent.getRegistrationTimestamp(), - registryEvent.getRemoteConnection()); - break; - - case REFRESH_REGISTRATION_REQUEST: - registryEventProcessor.processRegistrationRefreshRequest(cohortName, - registryEventOriginator.getServerName(), - registryEventOriginator.getServerType(), - registryEventOriginator.getOrganizationName()); - break; - - case UN_REGISTRATION_EVENT: - registryEventProcessor.processUnRegistrationEvent(cohortName, - registryEventOriginator.getMetadataCollectionId(), - registryEventOriginator.getServerName(), - registryEventOriginator.getServerType(), - registryEventOriginator.getOrganizationName()); - break; - - case REGISTRATION_ERROR_EVENT: - OMRSRegistryEventErrorCode errorCode = registryEvent.getErrorCode(); - - if (errorCode != null) - { - switch(errorCode) - { - case BAD_REMOTE_CONNECTION: - registryEventProcessor.processBadConnectionEvent(cohortName, - registryEventOriginator.getMetadataCollectionId(), - registryEventOriginator.getServerName(), - registryEventOriginator.getServerType(), - registryEventOriginator.getOrganizationName(), - registryEvent.getTargetMetadataCollectionId(), - registryEvent.getTargetRemoteConnection(), - registryEvent.getErrorMessage()); - break; - - case CONFLICTING_COLLECTION_ID: - registryEventProcessor.processConflictingCollectionIdEvent(cohortName, - registryEventOriginator.getMetadataCollectionId(), - registryEventOriginator.getServerName(), - registryEventOriginator.getServerType(), - registryEventOriginator.getOrganizationName(), - registryEvent.getTargetMetadataCollectionId(), - registryEvent.getErrorMessage()); - break; - - default: - if (log.isDebugEnabled()) - { - log.debug("Unknown registry event error code - ignoring event"); - } - break; - } - } - else - { - if (log.isDebugEnabled()) - { - log.debug("Null registry event error code - ignoring event"); - } - } - break; - - default: - /* - * New type of registry event that this server does not understand - ignore it - */ - if (log.isDebugEnabled()) - { - log.debug("Unknown registry event: " + registryEvent.toString()); - } - break; - } - } - else - { - if (log.isDebugEnabled()) - { - log.debug("Ignored registry event: " + registryEvent.toString()); - } - } - } - } - - - /** - * Unpack and deliver a TypeDef event to the TypeDefEventProcessor - * - * @param typeDefEvent - event to unpack - */ - private void processTypeDefEvent(OMRSTypeDefEvent typeDefEvent) - { - if (typeDefEvent == null) - { - if (log.isDebugEnabled()) - { - log.debug("Null TypeDef event - ignoring event"); - } - } - else if (typeDefEventProcessor == null) - { - if (log.isDebugEnabled()) - { - log.debug("No TypeDef event processor - ignoring event"); - } - } - else - { - OMRSTypeDefEventType typeDefEventType = typeDefEvent.getTypeDefEventType(); - OMRSEventOriginator typeDefEventOriginator = typeDefEvent.getEventOriginator(); - - if ((typeDefEventType != null) && (typeDefEventOriginator != null)) - { - switch (typeDefEventType) - { - case NEW_TYPEDEF_EVENT: - typeDefEventProcessor.processNewTypeDefEvent(cohortName, - typeDefEventOriginator.getMetadataCollectionId(), - typeDefEventOriginator.getServerName(), - typeDefEventOriginator.getServerType(), - typeDefEventOriginator.getOrganizationName(), - typeDefEvent.getTypeDef()); - break; - - case NEW_ATTRIBUTE_TYPEDEF_EVENT: - typeDefEventProcessor.processNewAttributeTypeDefEvent(cohortName, - typeDefEventOriginator.getMetadataCollectionId(), - typeDefEventOriginator.getServerName(), - typeDefEventOriginator.getServerType(), - typeDefEventOriginator.getOrganizationName(), - typeDefEvent.getAttributeTypeDef()); - break; - - case UPDATED_TYPEDEF_EVENT: - typeDefEventProcessor.processUpdatedTypeDefEvent(cohortName, - typeDefEventOriginator.getMetadataCollectionId(), - typeDefEventOriginator.getServerName(), - typeDefEventOriginator.getServerType(), - typeDefEventOriginator.getOrganizationName(), - typeDefEvent.getTypeDefPatch()); - break; - - case DELETED_TYPEDEF_EVENT: - typeDefEventProcessor.processDeletedTypeDefEvent(cohortName, - typeDefEventOriginator.getMetadataCollectionId(), - typeDefEventOriginator.getServerName(), - typeDefEventOriginator.getServerType(), - typeDefEventOriginator.getOrganizationName(), - typeDefEvent.getTypeDefGUID(), - typeDefEvent.getTypeDefName()); - break; - - case DELETED_ATTRIBUTE_TYPEDEF_EVENT: - typeDefEventProcessor.processDeletedAttributeTypeDefEvent(cohortName, - typeDefEventOriginator.getMetadataCollectionId(), - typeDefEventOriginator.getServerName(), - typeDefEventOriginator.getServerType(), - typeDefEventOriginator.getOrganizationName(), - typeDefEvent.getTypeDefGUID(), - typeDefEvent.getTypeDefName()); - break; - - case RE_IDENTIFIED_TYPEDEF_EVENT: - typeDefEventProcessor.processReIdentifiedTypeDefEvent(cohortName, - typeDefEventOriginator.getMetadataCollectionId(), - typeDefEventOriginator.getServerName(), - typeDefEventOriginator.getServerType(), - typeDefEventOriginator.getOrganizationName(), - typeDefEvent.getOriginalTypeDefSummary(), - typeDefEvent.getTypeDef()); - break; - - case RE_IDENTIFIED_ATTRIBUTE_TYPEDEF_EVENT: - typeDefEventProcessor.processReIdentifiedAttributeTypeDefEvent(cohortName, - typeDefEventOriginator.getMetadataCollectionId(), - typeDefEventOriginator.getServerName(), - typeDefEventOriginator.getServerType(), - typeDefEventOriginator.getOrganizationName(), - typeDefEvent.getOriginalAttributeTypeDef(), - typeDefEvent.getAttributeTypeDef()); - - case TYPEDEF_ERROR_EVENT: - OMRSTypeDefEventErrorCode errorCode = typeDefEvent.getErrorCode(); - - if (errorCode != null) - { - switch(errorCode) - { - case CONFLICTING_TYPEDEFS: - typeDefEventProcessor.processTypeDefConflictEvent(cohortName, - typeDefEventOriginator.getMetadataCollectionId(), - typeDefEventOriginator.getServerName(), - typeDefEventOriginator.getServerType(), - typeDefEventOriginator.getOrganizationName(), - typeDefEvent.getOriginalTypeDefSummary(), - typeDefEvent.getOtherMetadataCollectionId(), - typeDefEvent.getOtherTypeDefSummary(), - typeDefEvent.getErrorMessage()); - break; - - case CONFLICTING_ATTRIBUTE_TYPEDEFS: - typeDefEventProcessor.processAttributeTypeDefConflictEvent(cohortName, - typeDefEventOriginator.getMetadataCollectionId(), - typeDefEventOriginator.getServerName(), - typeDefEventOriginator.getServerType(), - typeDefEventOriginator.getOrganizationName(), - typeDefEvent.getOriginalAttributeTypeDef(), - typeDefEvent.getOtherMetadataCollectionId(), - typeDefEvent.getOtherAttributeTypeDef(), - typeDefEvent.getErrorMessage()); - - case TYPEDEF_PATCH_MISMATCH: - typeDefEventProcessor.processTypeDefPatchMismatchEvent(cohortName, - typeDefEventOriginator.getMetadataCollectionId(), - typeDefEventOriginator.getServerName(), - typeDefEventOriginator.getServerType(), - typeDefEventOriginator.getOrganizationName(), - typeDefEvent.getTargetMetadataCollectionId(), - typeDefEvent.getTargetTypeDefSummary(), - typeDefEvent.getOtherTypeDef(), - typeDefEvent.getErrorMessage()); - break; - - default: - if (log.isDebugEnabled()) - { - log.debug("Unknown TypeDef event error code - ignoring event"); - } - break; - } - } - else - { - if (log.isDebugEnabled()) - { - log.debug("Ignored TypeDef event - null error code"); - } - } - break; - - default: - if (log.isDebugEnabled()) - { - log.debug("Ignored TypeDef event - unknown type"); - } - break; - } - } - } - } - - - /** - * Unpack and deliver an instance event to the InstanceEventProcessor - * - * @param instanceEvent - event to unpack - */ - private void processInstanceEvent(OMRSInstanceEvent instanceEvent) - { - if (log.isDebugEnabled()) - { - log.debug("Processing instance event", instanceEvent); - } - - if (instanceEvent == null) - { - if (log.isDebugEnabled()) - { - log.debug("Null instance event - ignoring event"); - } - } - else - { - OMRSInstanceEventType instanceEventType = instanceEvent.getInstanceEventType(); - OMRSEventOriginator instanceEventOriginator = instanceEvent.getEventOriginator(); - - if ((instanceEventType != null) && (instanceEventOriginator != null)) - { - switch (instanceEventType) - { - case NEW_ENTITY_EVENT: - instanceEventProcessor.processNewEntityEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getEntity()); - break; - - case UPDATED_ENTITY_EVENT: - instanceEventProcessor.processUpdatedEntityEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getEntity()); - break; - - case CLASSIFIED_ENTITY_EVENT: - instanceEventProcessor.processClassifiedEntityEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getEntity()); - break; - - case RECLASSIFIED_ENTITY_EVENT: - instanceEventProcessor.processReclassifiedEntityEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getEntity()); - break; - - case DECLASSIFIED_ENTITY_EVENT: - instanceEventProcessor.processDeclassifiedEntityEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getEntity()); - break; - - case DELETED_ENTITY_EVENT: - instanceEventProcessor.processDeletedEntityEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getEntity()); - break; - - case PURGED_ENTITY_EVENT: - instanceEventProcessor.processPurgedEntityEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getTypeDefGUID(), - instanceEvent.getTypeDefName(), - instanceEvent.getInstanceGUID()); - break; - - case UNDONE_ENTITY_EVENT: - instanceEventProcessor.processUndoneEntityEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getEntity()); - break; - - case RESTORED_ENTITY_EVENT: - instanceEventProcessor.processRestoredEntityEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getEntity()); - break; - - case REFRESH_ENTITY_REQUEST: - instanceEventProcessor.processRefreshEntityRequested(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getTypeDefGUID(), - instanceEvent.getTypeDefName(), - instanceEvent.getInstanceGUID(), - instanceEvent.getHomeMetadataCollectionId()); - break; - - case REFRESHED_ENTITY_EVENT: - instanceEventProcessor.processRefreshEntityEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getEntity()); - break; - - case RE_HOMED_ENTITY_EVENT: - instanceEventProcessor.processReHomedEntityEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getOriginalHomeMetadataCollectionId(), - instanceEvent.getEntity()); - break; - - case RETYPED_ENTITY_EVENT: - instanceEventProcessor.processReTypedEntityEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getOriginalTypeDefSummary(), - instanceEvent.getEntity()); - break; - - case RE_IDENTIFIED_ENTITY_EVENT: - instanceEventProcessor.processReIdentifiedEntityEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getOriginalInstanceGUID(), - instanceEvent.getEntity()); - break; - - case NEW_RELATIONSHIP_EVENT: - instanceEventProcessor.processNewRelationshipEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getRelationship()); - break; - - case UPDATED_RELATIONSHIP_EVENT: - instanceEventProcessor.processUpdatedRelationshipEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getRelationship()); - break; - - case UNDONE_RELATIONSHIP_EVENT: - instanceEventProcessor.processUndoneRelationshipEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getRelationship()); - break; - - case DELETED_RELATIONSHIP_EVENT: - instanceEventProcessor.processDeletedRelationshipEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getRelationship()); - break; - - case PURGED_RELATIONSHIP_EVENT: - instanceEventProcessor.processPurgedEntityEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getTypeDefGUID(), - instanceEvent.getTypeDefName(), - instanceEvent.getInstanceGUID()); - break; - - case RESTORED_RELATIONSHIP_EVENT: - instanceEventProcessor.processRestoredRelationshipEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getRelationship()); - break; - - case REFRESH_RELATIONSHIP_REQUEST: - instanceEventProcessor.processRefreshRelationshipRequest(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getTypeDefGUID(), - instanceEvent.getTypeDefName(), - instanceEvent.getInstanceGUID(), - instanceEvent.getHomeMetadataCollectionId()); - break; - - case REFRESHED_RELATIONSHIP_EVENT: - instanceEventProcessor.processRefreshRelationshipEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getRelationship()); - break; - - case RE_IDENTIFIED_RELATIONSHIP_EVENT: - instanceEventProcessor.processReIdentifiedRelationshipEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getOriginalInstanceGUID(), - instanceEvent.getRelationship()); - break; - - case RE_HOMED_RELATIONSHIP_EVENT: - instanceEventProcessor.processReHomedRelationshipEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getOriginalHomeMetadataCollectionId(), - instanceEvent.getRelationship()); - break; - - case RETYPED_RELATIONSHIP_EVENT: - instanceEventProcessor.processReTypedRelationshipEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getOriginalTypeDefSummary(), - instanceEvent.getRelationship()); - break; - - case INSTANCE_ERROR_EVENT: - OMRSInstanceEventErrorCode errorCode = instanceEvent.getErrorCode(); - - if (errorCode != null) - { - switch(errorCode) - { - case CONFLICTING_INSTANCES: - instanceEventProcessor.processConflictingInstancesEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getTargetMetadataCollectionId(), - instanceEvent.getTargetTypeDefSummary(), - instanceEvent.getTargetInstanceGUID(), - instanceEvent.getOtherMetadataCollectionId(), - instanceEvent.getOtherOrigin(), - instanceEvent.getOtherTypeDefSummary(), - instanceEvent.getOtherInstanceGUID(), - instanceEvent.getErrorMessage()); - break; - - case CONFLICTING_TYPE: - instanceEventProcessor.processConflictingTypeEvent(cohortName, - instanceEventOriginator.getMetadataCollectionId(), - instanceEventOriginator.getServerName(), - instanceEventOriginator.getServerType(), - instanceEventOriginator.getOrganizationName(), - instanceEvent.getTargetMetadataCollectionId(), - instanceEvent.getTargetTypeDefSummary(), - instanceEvent.getTargetInstanceGUID(), - instanceEvent.getOtherTypeDefSummary(), - instanceEvent.getErrorMessage()); - break; - - default: - if (log.isDebugEnabled()) - { - log.debug("Unknown instance event error code - ignoring event"); - } - break; - } - } - else - { - if (log.isDebugEnabled()) - { - log.debug("Ignored Instance event - null error code"); - } - } - break; - - default: - if (log.isDebugEnabled()) - { - log.debug("Ignored Instance event - unknown type"); - } - break; - } - } - else - { - if (log.isDebugEnabled()) - { - log.debug("Ignored instance event - null type"); - } - } - } - } -} - - -
