http://git-wip-us.apache.org/repos/asf/atlas/blob/68b47923/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEvent.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEvent.java b/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEvent.java deleted file mode 100644 index c12752a..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEvent.java +++ /dev/null @@ -1,453 +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.events; - -import org.apache.atlas.omrs.eventmanagement.events.v1.OMRSEventV1; -import org.apache.atlas.omrs.eventmanagement.events.v1.OMRSEventV1TypeDefSection; -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.slf4j.Logger; -import org.slf4j.LoggerFactory; - - -public class OMRSTypeDefEvent extends OMRSEvent -{ - /* - * The type of the TypeDef event that defines how the rest of the values should be interpreted. - */ - private OMRSTypeDefEventType typeDefEventType = OMRSTypeDefEventType.UNKNOWN_TYPEDEF_EVENT; - - /* - * TypeDef specific properties. - */ - private AttributeTypeDef attributeTypeDef = null; - private TypeDef typeDef = null; - private String typeDefGUID = null; - private String typeDefName = null; - private TypeDefPatch typeDefPatch = null; - - /* - * TypeDef specific properties for events related to correcting conflicts in the open metadata repository - * cohort. - */ - private TypeDefSummary originalTypeDefSummary = null; - private AttributeTypeDef originalAttributeTypeDef = null; - - /* - * Specific variables only used in error reporting. It defines the subset of error codes from OMRSEvent - * that are specific to TypeDef events. - */ - private OMRSTypeDefEventErrorCode errorCode = OMRSTypeDefEventErrorCode.NOT_IN_USE; - - - private static final Logger log = LoggerFactory.getLogger(OMRSTypeDefEvent.class); - - /** - * Inbound event constructor that takes the object created by the Jackson JSON mapper and unpacks the - * properties into the instance event. - * - * @param inboundEvent - incoming Event. - */ - public OMRSTypeDefEvent(OMRSEventV1 inboundEvent) - { - super(inboundEvent); - - OMRSEventV1TypeDefSection typeDefSection = inboundEvent.getTypeDefEventSection(); - - if (typeDefSection != null) - { - this.typeDefEventType = typeDefSection.getTypeDefEventType(); - this.attributeTypeDef = typeDefSection.getAttributeTypeDef(); - this.typeDef = typeDefSection.getTypeDef(); - this.typeDefGUID = typeDefSection.getTypeDefGUID(); - this.typeDefName = typeDefSection.getTypeDefName(); - this.typeDefPatch = typeDefSection.getTypeDefPatch(); - this.originalTypeDefSummary = typeDefSection.getOriginalTypeDefSummary(); - this.originalAttributeTypeDef = typeDefSection.getOriginalAttributeTypeDef(); - } - - if (super.genericErrorCode != null) - { - switch(genericErrorCode) - { - case CONFLICTING_TYPEDEFS: - errorCode = OMRSTypeDefEventErrorCode.CONFLICTING_TYPEDEFS; - break; - - case CONFLICTING_ATTRIBUTE_TYPEDEFS: - errorCode = OMRSTypeDefEventErrorCode.CONFLICTING_ATTRIBUTE_TYPEDEFS; - - case TYPEDEF_PATCH_MISMATCH: - errorCode = OMRSTypeDefEventErrorCode.TYPEDEF_PATCH_MISMATCH; - break; - - default: - errorCode = OMRSTypeDefEventErrorCode.UNKNOWN_ERROR_CODE; - break; - } - } - } - - /** - * Outbound event constructor for events such as newTypeDef. - * - * @param typeDefEventType - type of event - * @param typeDef - Complete details of the TypeDef that is the subject of the event. - */ - public OMRSTypeDefEvent(OMRSTypeDefEventType typeDefEventType, - TypeDef typeDef) - { - super(OMRSEventCategory.TYPEDEF); - - this.typeDefEventType = typeDefEventType; - this.typeDef = typeDef; - } - - - /** - * Outbound event constructor for events such as newAttributeTypeDef. - * - * @param typeDefEventType - type of event - * @param attributeTypeDef - Complete details of the AttributeTypeDef that is the subject of the event. - */ - public OMRSTypeDefEvent(OMRSTypeDefEventType typeDefEventType, - AttributeTypeDef attributeTypeDef) - { - super(OMRSEventCategory.TYPEDEF); - - this.typeDefEventType = typeDefEventType; - this.attributeTypeDef = attributeTypeDef; - } - - - /** - * Outbound event constructor for events such as updates. - * - * @param typeDefEventType - type of event - * @param typeDefPatch - Complete details of the TypeDef that is the subject of the event. - */ - public OMRSTypeDefEvent(OMRSTypeDefEventType typeDefEventType, - TypeDefPatch typeDefPatch) - { - super(OMRSEventCategory.TYPEDEF); - - this.typeDefEventType = typeDefEventType; - this.typeDefPatch = typeDefPatch; - } - - - /** - * Outbound event constructor for events such as deletes. - * - * @param typeDefEventType - type of event - * @param typeDefGUID - Unique identifier of the TypeDef that is the subject of the event. - * @param typeDefName - Unique name of the TypeDef that is the subject of the event. - */ - public OMRSTypeDefEvent(OMRSTypeDefEventType typeDefEventType, - String typeDefGUID, - String typeDefName) - { - super(OMRSEventCategory.TYPEDEF); - - this.typeDefEventType = typeDefEventType; - this.typeDefGUID = typeDefGUID; - this.typeDefName = typeDefName; - } - - - /** - * Outbound event constructor for changing the identifiers associated with TypeDefs. - * - * @param typeDefEventType - type of event - * @param originalTypeDefSummary - description of the original TypeDef that is the subject of the event. - * @param typeDef - updated TypeDef with new identifiers - */ - public OMRSTypeDefEvent(OMRSTypeDefEventType typeDefEventType, - TypeDefSummary originalTypeDefSummary, - TypeDef typeDef) - { - super(OMRSEventCategory.TYPEDEF); - - this.typeDefEventType = typeDefEventType; - this.originalTypeDefSummary = originalTypeDefSummary; - this.typeDef = typeDef; - } - - - /** - * Outbound event constructor for changing the identifiers associated with AttributeTypeDefs. - * - * @param typeDefEventType - type of event - * @param originalAttributeTypeDef - description of the original AttributeTypeDef that is the subject of the event. - * @param attributeTypeDef - updated AttributeTypeDef with new identifiers - */ - public OMRSTypeDefEvent(OMRSTypeDefEventType typeDefEventType, - AttributeTypeDef originalAttributeTypeDef, - AttributeTypeDef attributeTypeDef) - { - super(OMRSEventCategory.TYPEDEF); - - this.typeDefEventType = typeDefEventType; - this.originalAttributeTypeDef = originalAttributeTypeDef; - this.attributeTypeDef = attributeTypeDef; - } - - - /** - * Outbound event constructor for conflicting typedef errors. - * - * @param errorCode - code enum indicating the cause of the error. - * @param errorMessage - descriptive message about the error. - * @param targetMetadataCollectionId - identifier of the cohort member that issued the event in error. - * @param targetTypeDefSummary - details of the TypeDef in the remote repository. - * @param otherTypeDefSummary - details of the TypeDef in the local repository. - */ - public OMRSTypeDefEvent(OMRSTypeDefEventErrorCode errorCode, - String errorMessage, - String targetMetadataCollectionId, - TypeDefSummary targetTypeDefSummary, - TypeDefSummary otherTypeDefSummary) - { - super(OMRSEventCategory.TYPEDEF, - errorCode.getErrorCodeEncoding(), - errorMessage, - targetMetadataCollectionId, - targetTypeDefSummary, - otherTypeDefSummary); - - this.typeDefEventType = OMRSTypeDefEventType.TYPEDEF_ERROR_EVENT; - } - - - /** - * Outbound event constructor for conflicting attribute typedef errors. - * - * @param errorCode - code enum indicating the cause of the error. - * @param errorMessage - descriptive message about the error. - * @param targetMetadataCollectionId - identifier of the cohort member that issued the event in error. - * @param targetAttributeTypeDef - details of the TypeDef in the remote repository. - * @param otherAttributeTypeDef - details of the TypeDef in the local repository. - */ - public OMRSTypeDefEvent(OMRSTypeDefEventErrorCode errorCode, - String errorMessage, - String targetMetadataCollectionId, - AttributeTypeDef targetAttributeTypeDef, - AttributeTypeDef otherAttributeTypeDef) - { - super(OMRSEventCategory.TYPEDEF, - errorCode.getErrorCodeEncoding(), - errorMessage, - targetMetadataCollectionId, - targetAttributeTypeDef, - targetAttributeTypeDef); - - this.typeDefEventType = OMRSTypeDefEventType.TYPEDEF_ERROR_EVENT; - } - - - - /** - * Outbound event constructor for typedef mismatch errors. - * - * @param errorCode - code enum indicating the cause of the error. - * @param errorMessage - descriptive message about the error. - * @param targetMetadataCollectionId - identifier of the cohort member that issued the event in error. - * @param targetTypeDefSummary - details of the TypeDef in the remote repository. - * @param otherTypeDef - details of the TypeDef in the local repository. - */ - public OMRSTypeDefEvent(OMRSTypeDefEventErrorCode errorCode, - String errorMessage, - String targetMetadataCollectionId, - TypeDefSummary targetTypeDefSummary, - TypeDef otherTypeDef) - { - super(OMRSEventCategory.TYPEDEF, - errorCode.getErrorCodeEncoding(), - errorMessage, - targetMetadataCollectionId, - targetTypeDefSummary, - otherTypeDef); - - this.typeDefEventType = OMRSTypeDefEventType.TYPEDEF_ERROR_EVENT; - } - - - /** - * Return the code for this event's type. - * - * @return OMRSTypeDefEventType enum - */ - public OMRSTypeDefEventType getTypeDefEventType() - { - return typeDefEventType; - } - - - /** - * Return the complete TypeDef object. - * - * @return TypeDef object - */ - public TypeDef getTypeDef() - { - return typeDef; - } - - - /** - * Return the complete AttributeTypeDef object. - * - * @return AttributeTypeDef object - */ - public AttributeTypeDef getAttributeTypeDef() - { - return attributeTypeDef; - } - - /** - * Return the unique id of the TypeDef. - * - * @return String guid - */ - public String getTypeDefGUID() - { - return typeDefGUID; - } - - - /** - * Return the unique name of the TypeDef. - * - * @return String name - */ - public String getTypeDefName() - { - return typeDefName; - } - - - /** - * Return a patch for the TypeDef. - * - * @return TypeDefPatch object - */ - public TypeDefPatch getTypeDefPatch() - { - return typeDefPatch; - } - - - /** - * Return the details of the TypeDef before it was changed. - * - * @return TypeDefSummary containing identifiers, category and version - */ - public TypeDefSummary getOriginalTypeDefSummary() - { - return originalTypeDefSummary; - } - - - /** - * Return the details of the AttributeTypeDef before it was changed. - * - * @return AttributeTypeDef object - */ - public AttributeTypeDef getOriginalAttributeTypeDef() - { - return originalAttributeTypeDef; - } - - /** - * Return the TypeDef error code for error events. - * - * @return OMRSTypeDefEventErrorCode enum - */ - public OMRSTypeDefEventErrorCode getErrorCode() - { - return errorCode; - } - - - /** - * Returns an OMRSEvent populated with details from this TypeDefEvent - * - * @return OMRSEvent (Version 1) object - */ - public OMRSEventV1 getOMRSEventV1() - { - OMRSEventV1 omrsEvent = super.getOMRSEventV1(); - - OMRSEventV1TypeDefSection typeDefSection = new OMRSEventV1TypeDefSection(); - - typeDefSection.setTypeDefEventType(this.typeDefEventType); - typeDefSection.setTypeDef(this.typeDef); - typeDefSection.setAttributeTypeDef(this.attributeTypeDef); - typeDefSection.setTypeDefPatch(this.typeDefPatch); - typeDefSection.setTypeDefGUID(this.typeDefGUID); - typeDefSection.setTypeDefName(this.typeDefName); - typeDefSection.setOriginalTypeDefSummary(this.originalTypeDefSummary); - typeDefSection.setOriginalAttributeTypeDef(this.originalAttributeTypeDef); - - omrsEvent.setTypeDefEventSection(typeDefSection); - - return omrsEvent; - } - - - /** - * Standard toString method. - * - * @return JSON style description of variables. - */ - @Override - public String toString() - { - return "OMRSTypeDefEvent{" + - "typeDefEventType=" + typeDefEventType + - ", attributeTypeDef=" + attributeTypeDef + - ", typeDef=" + typeDef + - ", typeDefGUID='" + typeDefGUID + '\'' + - ", typeDefName='" + typeDefName + '\'' + - ", typeDefPatch=" + typeDefPatch + - ", originalTypeDefSummary=" + originalTypeDefSummary + - ", originalAttributeTypeDef=" + originalAttributeTypeDef + - ", errorCode=" + errorCode + - ", eventTimestamp=" + eventTimestamp + - ", eventDirection=" + eventDirection + - ", eventCategory=" + eventCategory + - ", eventOriginator=" + eventOriginator + - ", genericErrorCode=" + genericErrorCode + - ", errorMessage='" + errorMessage + '\'' + - ", targetMetadataCollectionId='" + targetMetadataCollectionId + '\'' + - ", targetRemoteConnection=" + targetRemoteConnection + - ", targetTypeDefSummary=" + targetTypeDefSummary + - ", targetAttributeTypeDef=" + targetAttributeTypeDef + - ", targetInstanceGUID='" + targetInstanceGUID + '\'' + - ", otherOrigin=" + otherOrigin + - ", otherMetadataCollectionId='" + otherMetadataCollectionId + '\'' + - ", otherTypeDefSummary=" + otherTypeDefSummary + - ", otherTypeDef=" + otherTypeDef + - ", otherAttributeTypeDef=" + otherAttributeTypeDef + - ", otherInstanceGUID='" + otherInstanceGUID + '\'' + - '}'; - } -}
http://git-wip-us.apache.org/repos/asf/atlas/blob/68b47923/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEventErrorCode.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEventErrorCode.java b/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEventErrorCode.java deleted file mode 100644 index fd36108..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEventErrorCode.java +++ /dev/null @@ -1,122 +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.events; - -import org.apache.atlas.omrs.eventmanagement.events.OMRSEventErrorCode; - -/** - * OMRSTypeDefEventErrorCode defines the list of error codes that are used to record errors in the TypeDef - * synchronization process that is used by the repository connectors within the open metadata repository cluster. - * <ul> - * <li> - * NOT_IN_USE - There has been no error detected and so the error code is not in use. - * </li> - * </ul> - */ -public enum OMRSTypeDefEventErrorCode -{ - NOT_IN_USE (0, "No Error", - "There has been no error detected and so the error code is not in use.", - null), - CONFLICTING_TYPEDEFS (1, "ConflictingTypeDefs", - "There are conflicting type definitions (TypeDefs) detected between two " + - "repositories in the open metadata repository cohort.", - OMRSEventErrorCode.CONFLICTING_TYPEDEFS), - CONFLICTING_ATTRIBUTE_TYPEDEFS (2, "ConflictingAttributeTypeDefs", - "There are conflicting attribute type definitions (AttributeTypeDefs) detected between two " + - "repositories in the open metadata repository cohort.", - OMRSEventErrorCode.CONFLICTING_ATTRIBUTE_TYPEDEFS), - TYPEDEF_PATCH_MISMATCH (3, "TypeDefPatchMismatch", - "There are different versions of a TypeDef in use in the cohort", - OMRSEventErrorCode.TYPEDEF_PATCH_MISMATCH), - UNKNOWN_ERROR_CODE (99, "Unknown Error Code", - "Unrecognized error code from incoming event.", - null); - - - private int errorCodeId; - private String errorCodeName; - private String errorCodeDescription; - private OMRSEventErrorCode errorCodeEncoding; - - - /** - * Default constructor sets up the values for this enum instance. - * - * @param errorCodeId - int identifier for the enum, used for indexing arrays etc with the enum. - * @param errorCodeName - String name for the enum, used for message content. - * @param errorCodeDescription - String default description for the enum, used when there is not natural - * language resource bundle available. - * @param errorCodeEncoding - code value to use in OMRSEvents - */ - OMRSTypeDefEventErrorCode(int errorCodeId, - String errorCodeName, - String errorCodeDescription, - OMRSEventErrorCode errorCodeEncoding) - { - this.errorCodeId = errorCodeId; - this.errorCodeName = errorCodeName; - this.errorCodeDescription = errorCodeDescription; - this.errorCodeEncoding = errorCodeEncoding; - } - - - /** - * Return the identifier for the enum, used for indexing arrays etc with the enum. - * - * @return int identifier - */ - public int getErrorCodeId() - { - return errorCodeId; - } - - - /** - * Return the name for the enum, used for message content. - * - * @return String name - */ - public String getErrorCodeName() - { - return errorCodeName; - } - - - /** - * Return the default description for the enum, used when there is not natural - * language resource bundle available. - * - * @return String default description - */ - public String getErrorCodeDescription() - { - return errorCodeDescription; - } - - - /** - * Return the encoding to use in OMRSEvents. - * - * @return String OMRSEvent encoding for this errorCode - */ - public OMRSEventErrorCode getErrorCodeEncoding() - { - return errorCodeEncoding; - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/atlas/blob/68b47923/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEventProcessor.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEventProcessor.java b/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEventProcessor.java deleted file mode 100644 index 7cb2338..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEventProcessor.java +++ /dev/null @@ -1,262 +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.events; - -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; - -/** - * OMRSTypeDefEventProcessor is an interface implemented by a component that is able to process incoming - * TypeDef events for an Open Metadata Repository. TypeDef events are used to synchronize TypeDefs across - * an Open Metadata Repository Cohort. - */ -public interface OMRSTypeDefEventProcessor -{ - /** - * A new TypeDef 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 typeDef - details of the new TypeDef. - */ - void processNewTypeDefEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - TypeDef typeDef); - - - /** - * 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. - */ - void processNewAttributeTypeDefEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - AttributeTypeDef attributeTypeDef); - - - /** - * An existing TypeDef has been updated 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 typeDefPatch - details of the new version of the TypeDef - */ - void processUpdatedTypeDefEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - TypeDefPatch typeDefPatch); - - - /** - * An existing TypeDef has been deleted in an open metadata repository. Both the name and the - * GUID are provided to ensure the right TypeDef 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 typeDefGUID - unique identifier of the TypeDef - * @param typeDefName - unique name of the TypeDef - */ - void processDeletedTypeDefEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - String typeDefGUID, - String typeDefName); - - - /** - * 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 - */ - void processDeletedAttributeTypeDefEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - String attributeTypeDefGUID, - String attributeTypeDefName); - - - /** - * Process an event that changes either the name or guid of a TypeDef. It is resolving a Conflicting TypeDef 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 originalTypeDef - description of original TypeDef - * @param typeDef - updated TypeDef with new identifiers inside. - */ - void processReIdentifiedTypeDefEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - TypeDefSummary originalTypeDef, - TypeDef typeDef); - - - /** - * 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. - */ - void processReIdentifiedAttributeTypeDefEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - AttributeTypeDef originalAttributeTypeDef, - AttributeTypeDef attributeTypeDef); - - - /** - * Process a detected conflict in the 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 originatorTypeDef- description of the TypeDef in the event originator. - * @param otherMetadataCollectionId - the metadataCollection using the conflicting TypeDef. - * @param conflictingTypeDef - description of the TypeDef in the other metadata collection. - * @param errorMessage - details of the error that occurs when the connection is used. - */ - void processTypeDefConflictEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - TypeDefSummary originatorTypeDef, - String otherMetadataCollectionId, - TypeDefSummary conflictingTypeDef, - String errorMessage); - - - /** - * 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. - */ - void processAttributeTypeDefConflictEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - AttributeTypeDef originatorAttributeTypeDef, - String otherMetadataCollectionId, - AttributeTypeDef conflictingAttributeTypeDef, - String errorMessage); - - - /** - * 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 reporting repository. - * @param targetTypeDef - details of the TypeDef in the target repository. - * @param otherTypeDef - details of the TypeDef in the other repository. - * @param errorMessage - details of the error that occurs when the connection is used. - */ - void processTypeDefPatchMismatchEvent(String sourceName, - String originatorMetadataCollectionId, - String originatorServerName, - String originatorServerType, - String originatorOrganizationName, - String targetMetadataCollectionId, - TypeDefSummary targetTypeDef, - TypeDef otherTypeDef, - String errorMessage); -} http://git-wip-us.apache.org/repos/asf/atlas/blob/68b47923/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEventType.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEventType.java b/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEventType.java deleted file mode 100644 index e04fbe4..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/OMRSTypeDefEventType.java +++ /dev/null @@ -1,111 +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.events; - -/** - * OMRSTypeDefEventType defines the different types of TypeDef events in the open metadata repository services - * protocol: - * <ul> - * <li> - * UNKNOWN_TYPEDEF_EVENT - the event is not recognized by this local server, probably because it is back-level - * from other servers in the cluster. It is logged in the audit log and then ignored. The metadata exchange - * protocol should evolve so that new message types can be ignored by back-level servers without damage - * to the cluster's integrity. - * </li> - * <li> - * NEW_TYPEDEF - A new TypeDef has been defined. - * </li> - * <li> - * UPDATED_TYPEDEF - An existing TypeDef has been updated. - * </li> - * <li> - * DELETED_TYPEDEF_EVENT - An existing TypeDef has been deleted. - * </li> - * <li> - * RE_IDENTIFIED_TYPEDEF_EVENT - the guid has been changed for a TypeDef. - * </li> - * </ul> - */ -public enum OMRSTypeDefEventType -{ - UNKNOWN_TYPEDEF_EVENT (0, "UnknownTypeDefEvent", "A TypeDef event that is not recognized by the local server."), - NEW_TYPEDEF_EVENT (1, "NewTypeDef", "A new TypeDef has been defined."), - NEW_ATTRIBUTE_TYPEDEF_EVENT (2, "NewAttributeTypeDef", "A new AttributeTypeDef has been defined."), - UPDATED_TYPEDEF_EVENT (3, "UpdatedTypeDef", "An existing TypeDef has been updated."), - DELETED_TYPEDEF_EVENT (4, "DeletedTypeDef", "An existing TypeDef has been deleted."), - DELETED_ATTRIBUTE_TYPEDEF_EVENT (5, "DeletedAttributeTypeDef", "An existing AttributeTypeDef has been deleted."), - RE_IDENTIFIED_TYPEDEF_EVENT (6, "ReIdentifiedTypeDef", "An existing TypeDef has changed either it guid or its name."), - RE_IDENTIFIED_ATTRIBUTE_TYPEDEF_EVENT (7, "ReIdentifiedAttributeTypeDef", "An existing AttributeTypeDef has changed either it guid or its name."), - TYPEDEF_ERROR_EVENT (99, "InstanceErrorEvent", - "An error has been detected in the exchange of TypeDefs between members of the cohort."); - - - private int eventTypeCode; - private String eventTypeName; - private String eventTypeDescription; - - - /** - * Default Constructor - sets up the specific values for this instance of the enum. - * - * @param eventTypeCode - int identifier used for indexing based on the enum. - * @param eventTypeName - string name used for messages that include the enum. - * @param eventTypeDescription - default description for the enum value - used when natural resource - * bundle is not available. - */ - OMRSTypeDefEventType(int eventTypeCode, String eventTypeName, String eventTypeDescription) - { - this.eventTypeCode = eventTypeCode; - this.eventTypeName = eventTypeName; - this.eventTypeDescription = eventTypeDescription; - } - - - /** - * Return the int identifier used for indexing based on the enum. - * - * @return int identifier code - */ - public int getTypeDefEventTypeCode() - { - return eventTypeCode; - } - - - /** - * Return the string name used for messages that include the enum. - * - * @return String name - */ - public String getTypeDefEventTypeName() - { - return eventTypeName; - } - - - /** - * Return the default description for the enum value - used when natural resource - * bundle is not available. - * - * @return String default description - */ - public String getTypeDefEventTypeDescription() - { - return eventTypeDescription; - } -} http://git-wip-us.apache.org/repos/asf/atlas/blob/68b47923/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1.java b/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1.java deleted file mode 100644 index 26345a6..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1.java +++ /dev/null @@ -1,132 +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.events.v1; - -import com.fasterxml.jackson.annotation.JsonAutoDetect; -import com.fasterxml.jackson.annotation.JsonIgnoreProperties; -import com.fasterxml.jackson.annotation.JsonInclude; - -import org.apache.atlas.omrs.eventmanagement.events.OMRSEventCategory; -import org.apache.atlas.omrs.eventmanagement.events.OMRSEventOriginator; - - -import java.io.Serializable; -import java.util.Date; - -import static com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility.PUBLIC_ONLY; -import static com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility.NONE; - - -/** - * OMRSEventV1 is the OMRSEvent payload for version 1 of the open metadata and governance message exchange. - */ -@JsonAutoDetect(getterVisibility=PUBLIC_ONLY, setterVisibility=PUBLIC_ONLY, fieldVisibility=NONE) -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonIgnoreProperties(ignoreUnknown=true) -public class OMRSEventV1 implements Serializable -{ - private static final long serialVersionUID = 1L; - - private final String protocolVersionId = "OMRS V1.0"; - private Date timestamp = null; - private OMRSEventOriginator originator = null; - private OMRSEventCategory eventCategory = null; - private OMRSEventV1RegistrySection registryEventSection = null; - private OMRSEventV1TypeDefSection typeDefEventSection = null; - private OMRSEventV1InstanceSection instanceEventSection = null; - private OMRSEventV1ErrorSection errorSection = null; - - public OMRSEventV1() - { - } - - public String getProtocolVersionId() - { - return protocolVersionId; - } - - public Date getTimestamp() - { - return timestamp; - } - - public void setTimestamp(Date timestamp) - { - this.timestamp = timestamp; - } - - public OMRSEventOriginator getOriginator() - { - return originator; - } - - public void setOriginator(OMRSEventOriginator originator) - { - this.originator = originator; - } - - public OMRSEventCategory getEventCategory() - { - return eventCategory; - } - - public void setEventCategory(OMRSEventCategory eventCategory) - { - this.eventCategory = eventCategory; - } - - public OMRSEventV1RegistrySection getRegistryEventSection() - { - return registryEventSection; - } - - public void setRegistryEventSection(OMRSEventV1RegistrySection registryEventSection) - { - this.registryEventSection = registryEventSection; - } - - public OMRSEventV1TypeDefSection getTypeDefEventSection() - { - return typeDefEventSection; - } - - public void setTypeDefEventSection(OMRSEventV1TypeDefSection typeDefEventSection) - { - this.typeDefEventSection = typeDefEventSection; - } - - public OMRSEventV1InstanceSection getInstanceEventSection() - { - return instanceEventSection; - } - - public void setInstanceEventSection(OMRSEventV1InstanceSection instanceEventSection) - { - this.instanceEventSection = instanceEventSection; - } - - public OMRSEventV1ErrorSection getErrorSection() - { - return errorSection; - } - - public void setErrorSection(OMRSEventV1ErrorSection errorSection) - { - this.errorSection = errorSection; - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/atlas/blob/68b47923/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1ErrorSection.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1ErrorSection.java b/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1ErrorSection.java deleted file mode 100644 index 2e74bb7..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1ErrorSection.java +++ /dev/null @@ -1,190 +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.events.v1; - -import com.fasterxml.jackson.annotation.JsonAutoDetect; -import com.fasterxml.jackson.annotation.JsonIgnoreProperties; -import com.fasterxml.jackson.annotation.JsonInclude; -import org.apache.atlas.ocf.properties.beans.Connection; -import org.apache.atlas.omrs.eventmanagement.events.OMRSEventErrorCode; -import org.apache.atlas.omrs.metadatacollection.properties.instances.InstanceProvenanceType; -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.TypeDefSummary; - -import java.io.Serializable; - -import static com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility.NONE; -import static com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility.PUBLIC_ONLY; - -/** - * OMRSEventV1ErrorSection describes the properties used to record errors detected by one of the members of the - * open metadata repository cohort. - */ -@JsonAutoDetect(getterVisibility=PUBLIC_ONLY, setterVisibility=PUBLIC_ONLY, fieldVisibility=NONE) -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonIgnoreProperties(ignoreUnknown=true) -public class OMRSEventV1ErrorSection implements Serializable -{ - private static final long serialVersionUID = 1L; - - private OMRSEventErrorCode errorCode = null; - private String errorMessage = null; - private String targetMetadataCollectionId = null; - private Connection targetRemoteConnection = null; - private TypeDefSummary targetTypeDefSummary = null; - private AttributeTypeDef targetAttributeTypeDef = null; - private String targetInstanceGUID = null; - private InstanceProvenanceType otherOrigin = null; - private String otherMetadataCollectionId = null; - private TypeDefSummary otherTypeDefSummary = null; - private TypeDef otherTypeDef = null; - private AttributeTypeDef otherAttributeTypeDef = null; - private String otherInstanceGUID = null; - - public OMRSEventV1ErrorSection() - { - } - - public OMRSEventErrorCode getErrorCode() - { - return errorCode; - } - - public void setErrorCode(OMRSEventErrorCode errorCode) - { - this.errorCode = errorCode; - } - - public String getErrorMessage() - { - return errorMessage; - } - - public void setErrorMessage(String errorMessage) - { - this.errorMessage = errorMessage; - } - - public String getTargetMetadataCollectionId() - { - return targetMetadataCollectionId; - } - - public void setTargetMetadataCollectionId(String targetMetadataCollectionId) - { - this.targetMetadataCollectionId = targetMetadataCollectionId; - } - - public Connection getTargetRemoteConnection() - { - return targetRemoteConnection; - } - - public void setTargetRemoteConnection(Connection targetRemoteConnection) - { - this.targetRemoteConnection = targetRemoteConnection; - } - - public TypeDefSummary getTargetTypeDefSummary() - { - return targetTypeDefSummary; - } - - public void setTargetTypeDefSummary(TypeDefSummary targetTypeDefSummary) - { - this.targetTypeDefSummary = targetTypeDefSummary; - } - - public AttributeTypeDef getTargetAttributeTypeDef() - { - return targetAttributeTypeDef; - } - - public void setTargetAttributeTypeDef(AttributeTypeDef targetAttributeTypeDef) - { - this.targetAttributeTypeDef = targetAttributeTypeDef; - } - - public String getTargetInstanceGUID() - { - return targetInstanceGUID; - } - - public void setTargetInstanceGUID(String targetInstanceGUID) - { - this.targetInstanceGUID = targetInstanceGUID; - } - - public InstanceProvenanceType getOtherOrigin() - { - return otherOrigin; - } - - public void setOtherOrigin(InstanceProvenanceType otherOrigin) - { - this.otherOrigin = otherOrigin; - } - - public String getOtherMetadataCollectionId() - { - return otherMetadataCollectionId; - } - - public void setOtherMetadataCollectionId(String otherMetadataCollectionId) - { - this.otherMetadataCollectionId = otherMetadataCollectionId; - } - - public TypeDefSummary getOtherTypeDefSummary() { return otherTypeDefSummary; } - - public void setOtherTypeDefSummary(TypeDefSummary otherTypeDefSummary) - { - this.otherTypeDefSummary = otherTypeDefSummary; - } - - public TypeDef getOtherTypeDef() - { - return otherTypeDef; - } - - public void setOtherTypeDef(TypeDef otherTypeDef) - { - this.otherTypeDef = otherTypeDef; - } - - public AttributeTypeDef getOtherAttributeTypeDef() - { - return otherAttributeTypeDef; - } - - public void setOtherAttributeTypeDef(AttributeTypeDef otherAttributeTypeDef) - { - this.otherAttributeTypeDef = otherAttributeTypeDef; - } - - public String getOtherInstanceGUID() - { - return otherInstanceGUID; - } - - public void setOtherInstanceGUID(String otherInstanceGUID) - { - this.otherInstanceGUID = otherInstanceGUID; - } -} http://git-wip-us.apache.org/repos/asf/atlas/blob/68b47923/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1InstanceSection.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1InstanceSection.java b/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1InstanceSection.java deleted file mode 100644 index f31c302..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1InstanceSection.java +++ /dev/null @@ -1,158 +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.events.v1; - -import com.fasterxml.jackson.annotation.JsonAutoDetect; -import com.fasterxml.jackson.annotation.JsonIgnoreProperties; -import com.fasterxml.jackson.annotation.JsonInclude; -import org.apache.atlas.omrs.eventmanagement.events.OMRSInstanceEventType; -import org.apache.atlas.omrs.metadatacollection.properties.instances.EntityDetail; -import org.apache.atlas.omrs.metadatacollection.properties.instances.Relationship; -import org.apache.atlas.omrs.metadatacollection.properties.typedefs.TypeDefSummary; - -import java.io.Serializable; - -import static com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility.NONE; -import static com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility.PUBLIC_ONLY; - -/** - * OMRSEventV1InstanceSection describes the properties specific to instance events - */ -@JsonAutoDetect(getterVisibility=PUBLIC_ONLY, setterVisibility=PUBLIC_ONLY, fieldVisibility=NONE) -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonIgnoreProperties(ignoreUnknown=true) -public class OMRSEventV1InstanceSection implements Serializable -{ - private static final long serialVersionUID = 1L; - - private OMRSInstanceEventType eventType = null; - - private String typeDefGUID = null; - private String typeDefName = null; - private String instanceGUID = null; - private EntityDetail entity = null; - private Relationship relationship = null; - private String homeMetadataCollectionId = null; - private String originalHomeMetadataCollectionId = null; - private TypeDefSummary originalTypeDefSummary = null; - private String originalInstanceGUID = null; - - public OMRSEventV1InstanceSection() - { - } - - public OMRSInstanceEventType getEventType() - { - return eventType; - } - - public void setEventType(OMRSInstanceEventType eventType) - { - this.eventType = eventType; - } - - public String getTypeDefGUID() - { - return typeDefGUID; - } - - public void setTypeDefGUID(String typeDefGUID) - { - this.typeDefGUID = typeDefGUID; - } - - public String getTypeDefName() - { - return typeDefName; - } - - public void setTypeDefName(String typeDefName) - { - this.typeDefName = typeDefName; - } - - public String getInstanceGUID() - { - return instanceGUID; - } - - public void setInstanceGUID(String instanceGUID) - { - this.instanceGUID = instanceGUID; - } - - public EntityDetail getEntity() - { - return entity; - } - - public void setEntity(EntityDetail entity) - { - this.entity = entity; - } - - public Relationship getRelationship() - { - return relationship; - } - - public void setRelationship(Relationship relationship) - { - this.relationship = relationship; - } - - public String getHomeMetadataCollectionId() - { - return homeMetadataCollectionId; - } - - public void setHomeMetadataCollectionId(String homeMetadataCollectionId) - { - this.homeMetadataCollectionId = homeMetadataCollectionId; - } - - public String getOriginalHomeMetadataCollectionId() - { - return originalHomeMetadataCollectionId; - } - - public void setOriginalHomeMetadataCollectionId(String originalHomeMetadataCollectionId) - { - this.originalHomeMetadataCollectionId = originalHomeMetadataCollectionId; - } - - public TypeDefSummary getOriginalTypeDefSummary() - { - return originalTypeDefSummary; - } - - public void setOriginalTypeDefSummary(TypeDefSummary originalTypeDefSummary) - { - this.originalTypeDefSummary = originalTypeDefSummary; - } - - public String getOriginalInstanceGUID() - { - return originalInstanceGUID; - } - - public void setOriginalInstanceGUID(String originalInstanceGUID) - { - this.originalInstanceGUID = originalInstanceGUID; - } -} http://git-wip-us.apache.org/repos/asf/atlas/blob/68b47923/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1RegistrySection.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1RegistrySection.java b/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1RegistrySection.java deleted file mode 100644 index 2878404..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1RegistrySection.java +++ /dev/null @@ -1,83 +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.events.v1; - -import com.fasterxml.jackson.annotation.JsonAutoDetect; -import com.fasterxml.jackson.annotation.JsonIgnoreProperties; -import com.fasterxml.jackson.annotation.JsonInclude; -import org.apache.atlas.ocf.properties.beans.Connection; -import org.apache.atlas.omrs.eventmanagement.events.OMRSRegistryEventType; -import org.apache.atlas.omrs.metadatacollection.properties.typedefs.TypeDefSummary; - -import java.io.Serializable; -import java.util.ArrayList; -import java.util.Date; -import java.util.List; - -import static com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility.NONE; -import static com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility.PUBLIC_ONLY; - -/** - * OMRSEventV1RegistrySection describes properties that are used exclusively for registry events. - */ -@JsonAutoDetect(getterVisibility=PUBLIC_ONLY, setterVisibility=PUBLIC_ONLY, fieldVisibility=NONE) -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonIgnoreProperties(ignoreUnknown=true) -public class OMRSEventV1RegistrySection implements Serializable -{ - private static final long serialVersionUID = 1L; - - private OMRSRegistryEventType registryEventType = null; - private Date registrationTimestamp = null; - private Connection remoteConnection = null; - - - public OMRSEventV1RegistrySection() - { - } - - public OMRSRegistryEventType getRegistryEventType() - { - return registryEventType; - } - - public void setRegistryEventType(OMRSRegistryEventType registryEventType) - { - this.registryEventType = registryEventType; - } - - public Date getRegistrationTimestamp() - { - return registrationTimestamp; - } - - public void setRegistrationTimestamp(Date registrationTimestamp) - { - this.registrationTimestamp = registrationTimestamp; - } - - public Connection getRemoteConnection() - { - return remoteConnection; - } - - public void setRemoteConnection(Connection remoteConnection) - { - this.remoteConnection = remoteConnection; - } -} http://git-wip-us.apache.org/repos/asf/atlas/blob/68b47923/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1TypeDefSection.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1TypeDefSection.java b/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1TypeDefSection.java deleted file mode 100644 index d035f75..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/events/v1/OMRSEventV1TypeDefSection.java +++ /dev/null @@ -1,136 +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.events.v1; - -import com.fasterxml.jackson.annotation.JsonAutoDetect; -import com.fasterxml.jackson.annotation.JsonIgnoreProperties; -import com.fasterxml.jackson.annotation.JsonInclude; -import org.apache.atlas.omrs.eventmanagement.events.OMRSTypeDefEventType; -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 java.io.Serializable; - -import static com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility.NONE; -import static com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility.PUBLIC_ONLY; - -/** - * OMRSEventV1TypeDefSection describes the properties specific to TypeDef related events - */ -@JsonAutoDetect(getterVisibility=PUBLIC_ONLY, setterVisibility=PUBLIC_ONLY, fieldVisibility=NONE) -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonIgnoreProperties(ignoreUnknown=true) -public class OMRSEventV1TypeDefSection implements Serializable -{ - private static final long serialVersionUID = 1L; - - private OMRSTypeDefEventType typeDefEventType = null; - private String typeDefGUID = null; - private String typeDefName = null; - private AttributeTypeDef attributeTypeDef = null; - private TypeDef typeDef = null; - private TypeDefPatch typeDefPatch = null; - private TypeDefSummary originalTypeDefSummary = null; - private AttributeTypeDef originalAttributeTypeDef = null; - - public OMRSEventV1TypeDefSection() - { - } - - public OMRSTypeDefEventType getTypeDefEventType() - { - return typeDefEventType; - } - - public void setTypeDefEventType(OMRSTypeDefEventType typeDefEventType) - { - this.typeDefEventType = typeDefEventType; - } - - public String getTypeDefGUID() - { - return typeDefGUID; - } - - public void setTypeDefGUID(String typeDefGUID) - { - this.typeDefGUID = typeDefGUID; - } - - public String getTypeDefName() - { - return typeDefName; - } - - public void setTypeDefName(String typeDefName) - { - this.typeDefName = typeDefName; - } - - public AttributeTypeDef getAttributeTypeDef() - { - return attributeTypeDef; - } - - public void setAttributeTypeDef(AttributeTypeDef attributeTypeDef) - { - this.attributeTypeDef = attributeTypeDef; - } - - public TypeDef getTypeDef() - { - return typeDef; - } - - public void setTypeDef(TypeDef typeDef) - { - this.typeDef = typeDef; - } - - public TypeDefPatch getTypeDefPatch() - { - return typeDefPatch; - } - - public void setTypeDefPatch(TypeDefPatch typeDefPatch) - { - this.typeDefPatch = typeDefPatch; - } - - public TypeDefSummary getOriginalTypeDefSummary() - { - return originalTypeDefSummary; - } - - public void setOriginalTypeDefSummary(TypeDefSummary originalTypeDefSummary) - { - this.originalTypeDefSummary = originalTypeDefSummary; - } - - public AttributeTypeDef getOriginalAttributeTypeDef() - { - return originalAttributeTypeDef; - } - - public void setOriginalAttributeTypeDef(AttributeTypeDef originalAttributeTypeDef) - { - this.originalAttributeTypeDef = originalAttributeTypeDef; - } -} http://git-wip-us.apache.org/repos/asf/atlas/blob/68b47923/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapper.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapper.java b/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapper.java deleted file mode 100644 index 3d3ae70..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapper.java +++ /dev/null @@ -1,107 +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.repositoryeventmapper; - -import org.apache.atlas.omrs.eventmanagement.OMRSRepositoryEventProcessor; -import org.apache.atlas.omrs.localrepository.repositorycontentmanager.OMRSRepositoryHelper; -import org.apache.atlas.omrs.localrepository.repositorycontentmanager.OMRSRepositoryValidator; -import org.apache.atlas.omrs.metadatacollection.repositoryconnector.OMRSRepositoryConnector; - -/** - * OMRSRepositoryEventMapper is the interface to a connector that is converting events received from - * a non-native local metadata repository into OMRS compliant repository events. It is used when the Open Metadata - * and Governance Server is being used as a RepositoryProxy, or if the local metadata repository has - * additional APIs that mean metadata can be changed without going through the OMRS Repository Connectors. - */ -public interface OMRSRepositoryEventMapper -{ - /** - * Pass additional information to the connector needed to process events. - * - * @param repositoryEventMapperName - repository event mapper name used for the source of the OMRS events. - * @param repositoryConnector - this is the connector to the local repository that the event mapper is processing - * events from. The repository connector is used to retrieve additional information - * necessary to fill out the OMRS Events. - */ - void initialize(String repositoryEventMapperName, - OMRSRepositoryConnector repositoryConnector); - - - /** - * Set up a repository helper object for the repository connector to use. - * - * @param repositoryHelper - helper object for building TypeDefs and metadata instances. - */ - void setRepositoryHelper(OMRSRepositoryHelper repositoryHelper); - - - /** - * Set up a repository validator for the repository connector to use. - * - * @param repositoryValidator - validator object to check the validity of TypeDefs and metadata instances. - */ - void setRepositoryValidator(OMRSRepositoryValidator repositoryValidator); - - - /** - * Set up the name of the server where the metadata collection resides. - * - * @param serverName - String name - */ - void setServerName(String serverName); - - - /** - * Set up the descriptive string describing the type of the server. This might be the - * name of the product, or similar identifier. - * - * @param serverType - String server type - */ - void setServerType(String serverType); - - - /** - * Set up the name of the organization that runs/owns the server. - * - * @param organizationName - String organization name - */ - void setOrganizationName(String organizationName); - - - /** - * Set up the unique Id for this metadata collection. - * - * @param metadataCollectionId - String unique Id - */ - void setMetadataCollectionId(String metadataCollectionId); - - - /** - * Set up the repository event processor for this connector to use. The connector should pass - * each typeDef or instance metadata change reported by its metadata repository's metadata on to the - * repository event processor. - * - * @param repositoryEventProcessor - listener responsible for distributing notifications of local - * changes to metadata types and instances to the rest of the - * open metadata repository cohort. - */ - void setRepositoryEventProcessor(OMRSRepositoryEventProcessor repositoryEventProcessor); - - - -} http://git-wip-us.apache.org/repos/asf/atlas/blob/68b47923/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapperBase.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapperBase.java b/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapperBase.java deleted file mode 100644 index e84735c..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapperBase.java +++ /dev/null @@ -1,33 +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.repositoryeventmapper; - - -/** - * OMRSRepositoryEventMapperBase provides a base class for implementors of OMRSRepositoryEventMapper. - */ -public abstract class OMRSRepositoryEventMapperBase extends OMRSRepositoryEventMapperConnector -{ - /** - * Default constructor for OCF ConnectorBase. - */ - public OMRSRepositoryEventMapperBase() - { - super(); - } -} http://git-wip-us.apache.org/repos/asf/atlas/blob/68b47923/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapperConnector.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapperConnector.java b/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapperConnector.java deleted file mode 100644 index 0db06e4..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapperConnector.java +++ /dev/null @@ -1,169 +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.repositoryeventmapper; - -import org.apache.atlas.ocf.ConnectorBase; -import org.apache.atlas.ocf.ffdc.ConnectorCheckedException; -import org.apache.atlas.omrs.eventmanagement.OMRSRepositoryEventProcessor; -import org.apache.atlas.omrs.localrepository.repositorycontentmanager.OMRSRepositoryHelper; -import org.apache.atlas.omrs.localrepository.repositorycontentmanager.OMRSRepositoryValidator; -import org.apache.atlas.omrs.metadatacollection.repositoryconnector.OMRSRepositoryConnector; - -/** - * OMRSRepositoryEventMapperBase provides a base class for implementors of OMRSRepositoryEventMapper. - */ -public abstract class OMRSRepositoryEventMapperConnector extends ConnectorBase implements OMRSRepositoryEventMapper -{ - protected OMRSRepositoryEventProcessor repositoryEventProcessor = null; - protected String repositoryEventMapperName = null; - protected OMRSRepositoryConnector repositoryConnector = null; - protected OMRSRepositoryHelper repositoryHelper = null; - protected OMRSRepositoryValidator repositoryValidator = null; - protected String localMetadataCollectionId = null; - protected String localServerName = null; - protected String localServerType = null; - protected String localOrganizationName = null; - - /** - * Default constructor for OCF ConnectorBase. - */ - public OMRSRepositoryEventMapperConnector() - { - super(); - } - - - /** - * Pass additional information to the connector needed to process events. - * - * @param repositoryEventMapperName - repository event mapper name used for the source of the OMRS events. - * @param repositoryConnector - ths is the connector to the local repository that the event mapper is processing - * events from. The repository connector is used to retrieve additional information - * necessary to fill out the OMRS Events. - */ - public void initialize(String repositoryEventMapperName, - OMRSRepositoryConnector repositoryConnector) - { - this.repositoryEventMapperName = repositoryEventMapperName; - this.repositoryConnector = repositoryConnector; - } - - - /** - * Set up a repository helper object for the repository connector to use. - * - * @param repositoryHelper - helper object for building TypeDefs and metadata instances. - */ - public void setRepositoryHelper(OMRSRepositoryHelper repositoryHelper) - { - this.repositoryHelper = repositoryHelper; - } - - - /** - * Set up a repository validator for the repository connector to use. - * - * @param repositoryValidator - validator object to check the validity of TypeDefs and metadata instances. - */ - public void setRepositoryValidator(OMRSRepositoryValidator repositoryValidator) - { - this.repositoryValidator = repositoryValidator; - } - - - /** - * Set up the name of the server where the metadata collection resides. - * - * @param serverName - String name - */ - public void setServerName(String serverName) - { - this.localServerName = serverName; - } - - - /** - * Set up the descriptive string describing the type of the server. This might be the - * name of the product, or similar identifier. - * - * @param serverType - String server type - */ - public void setServerType(String serverType) - { - this.localServerType = serverType; - } - - - /** - * Set up the name of the organization that runs/owns the server. - * - * @param organizationName - String organization name - */ - public void setOrganizationName(String organizationName) - { - this.localOrganizationName = organizationName; - } - - - /** - * Set up the unique Id for this metadata collection. - * - * @param metadataCollectionId - String unique Id - */ - public void setMetadataCollectionId(String metadataCollectionId) - { - this.localMetadataCollectionId = metadataCollectionId; - } - - - /** - * Set up the repository event listener for this connector to use. The connector should pass - * each type or instance metadata change reported by its metadata repository's metadata on to the - * repository event listener. - * - * @param repositoryEventProcessor - listener responsible for distributing notifications of local - * changes to metadata types and instances to the rest of the - * open metadata repository cluster. - */ - public void setRepositoryEventProcessor(OMRSRepositoryEventProcessor repositoryEventProcessor) - { - this.repositoryEventProcessor = repositoryEventProcessor; - } - - - /** - * 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(); - } - - - /** - * Free up any resources held since the connector is no longer needed. - * - * @throws ConnectorCheckedException - there is a problem within the connector. - */ - public void disconnect() throws ConnectorCheckedException - { - super.disconnect(); - } -} http://git-wip-us.apache.org/repos/asf/atlas/blob/68b47923/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapperProviderBase.java ---------------------------------------------------------------------- diff --git a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapperProviderBase.java b/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapperProviderBase.java deleted file mode 100644 index b4895b1..0000000 --- a/omrs/src/main/java/org/apache/atlas/omrs/eventmanagement/repositoryeventmapper/OMRSRepositoryEventMapperProviderBase.java +++ /dev/null @@ -1,41 +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.repositoryeventmapper; - -import org.apache.atlas.ocf.ConnectorProviderBase; - -/** - * OMRSRepositoryEventMapperProviderBase provides a base class for the connector provider supporting - * OMRSRepositoryEventMapper connectors. It extends ConnectorProviderBase which does the creation of connector instances. - * - * The subclasses of OMRSRepositoryEventMapperProviderBase must initialize ConnectorProviderBase with the Java class - * name of the OMRS Connector implementation (by calling super.setConnectorClassName(className)). - * Then the connector provider will work. - */ -public abstract class OMRSRepositoryEventMapperProviderBase extends ConnectorProviderBase -{ - /** - * Default Constructor - */ - public OMRSRepositoryEventMapperProviderBase() - { - /* - * Nothing to do - */ - } -}
