Class OMRSRegistryEventProcessor

  • All Implemented Interfaces:
    OMRSRegistryEventProcessorInterface

    public abstract class OMRSRegistryEventProcessor
    extends java.lang.Object
    implements OMRSRegistryEventProcessorInterface
    OMRSRegistryEventProcessor is an interface implemented by a component that is able to process registry events for an Open Metadata Repository's membership of an Open Metadata Repository Cohort.
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      abstract void processBadConnectionEvent​(java.lang.String sourceName, java.lang.String originatorMetadataCollectionId, java.lang.String originatorMetadataCollectionName, java.lang.String originatorServerName, java.lang.String originatorServerType, java.lang.String originatorOrganizationName, java.lang.String targetMetadataCollectionId, Connection remoteConnection, java.lang.String errorMessage)
      A connection to one of the members of the open metadata repository cohort is not usable by one of the members.
      abstract void processConflictingCollectionIdEvent​(java.lang.String sourceName, java.lang.String originatorMetadataCollectionId, java.lang.String originatorMetadataCollectionName, java.lang.String originatorServerName, java.lang.String originatorServerType, java.lang.String originatorOrganizationName, java.lang.String conflictingMetadataCollectionId, java.lang.String errorMessage)
      There is more than one member of the open metadata repository cohort that is using the same metadata collection Id.
      abstract boolean processRegistrationEvent​(java.lang.String sourceName, java.lang.String originatorMetadataCollectionId, java.lang.String originatorMetadataCollectionName, java.lang.String originatorServerName, java.lang.String originatorServerType, java.lang.String originatorOrganizationName, java.util.Date registrationTimestamp, Connection remoteConnection)
      Introduces a new server/repository to the metadata repository cohort.
      abstract boolean processRegistrationRefreshRequest​(java.lang.String sourceName, java.lang.String originatorServerName, java.lang.String originatorServerType, java.lang.String originatorOrganizationName)
      Requests that the other servers in the cohort send re-registration events.
      abstract boolean processReRegistrationEvent​(java.lang.String sourceName, java.lang.String originatorMetadataCollectionId, java.lang.String originatorMetadataCollectionName, java.lang.String originatorServerName, java.lang.String originatorServerType, java.lang.String originatorOrganizationName, java.util.Date registrationTimestamp, Connection remoteConnection)
      Refreshes the other servers in the cohort with the originating server's registration.
      abstract boolean processUnRegistrationEvent​(java.lang.String sourceName, java.lang.String originatorMetadataCollectionId, java.lang.String originatorMetadataCollectionName, java.lang.String originatorServerName, java.lang.String originatorServerType, java.lang.String originatorOrganizationName)
      A server/repository is being removed from the metadata repository cohort.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • OMRSRegistryEventProcessor

        public OMRSRegistryEventProcessor()
    • Method Detail

      • processRegistrationEvent

        public abstract boolean processRegistrationEvent​(java.lang.String sourceName,
                                                         java.lang.String originatorMetadataCollectionId,
                                                         java.lang.String originatorMetadataCollectionName,
                                                         java.lang.String originatorServerName,
                                                         java.lang.String originatorServerType,
                                                         java.lang.String originatorOrganizationName,
                                                         java.util.Date registrationTimestamp,
                                                         Connection remoteConnection)
        Introduces a new server/repository to the metadata repository cohort.
        Specified by:
        processRegistrationEvent in interface OMRSRegistryEventProcessorInterface
        Parameters:
        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.
        originatorMetadataCollectionId - unique identifier of metadata collection of originator.
        originatorMetadataCollectionName - display name of metadata collection of originator.
        originatorServerName - name of the server that the event came from.
        originatorServerType - type of server that the event came from.
        originatorOrganizationName - name of the organization that owns the server that sent the event.
        registrationTimestamp - the time that the server/repository issued the registration request.
        remoteConnection - the Connection properties for the connector used to call the registering server.
        Returns:
        flag indicating if the event was sent or not.
      • processRegistrationRefreshRequest

        public abstract boolean processRegistrationRefreshRequest​(java.lang.String sourceName,
                                                                  java.lang.String originatorServerName,
                                                                  java.lang.String originatorServerType,
                                                                  java.lang.String originatorOrganizationName)
        Requests that the other servers in the cohort send re-registration events.
        Specified by:
        processRegistrationRefreshRequest in interface OMRSRegistryEventProcessorInterface
        Parameters:
        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.
        originatorServerName - name of the server that the event came from.
        originatorServerType - type of server that the event came from.
        originatorOrganizationName - name of the organization that owns the server that sent the event.
        Returns:
        flag indicating if the event was sent or not.
      • processReRegistrationEvent

        public abstract boolean processReRegistrationEvent​(java.lang.String sourceName,
                                                           java.lang.String originatorMetadataCollectionId,
                                                           java.lang.String originatorMetadataCollectionName,
                                                           java.lang.String originatorServerName,
                                                           java.lang.String originatorServerType,
                                                           java.lang.String originatorOrganizationName,
                                                           java.util.Date registrationTimestamp,
                                                           Connection remoteConnection)
        Refreshes the other servers in the cohort with the originating server's registration.
        Specified by:
        processReRegistrationEvent in interface OMRSRegistryEventProcessorInterface
        Parameters:
        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.
        originatorMetadataCollectionId - unique identifier of metadata collection of originator.
        originatorMetadataCollectionName - display name of metadata collection of originator.
        originatorServerName - name of the server that the event came from.
        originatorServerType - type of server that the event came from.
        originatorOrganizationName - name of the organization that owns the server that sent the event.
        registrationTimestamp - the time that the server/repository first registered with the cohort.
        remoteConnection - the Connection properties for the connector used to call the registering server.
        Returns:
        flag indicating if the event was sent or not.
      • processUnRegistrationEvent

        public abstract boolean processUnRegistrationEvent​(java.lang.String sourceName,
                                                           java.lang.String originatorMetadataCollectionId,
                                                           java.lang.String originatorMetadataCollectionName,
                                                           java.lang.String originatorServerName,
                                                           java.lang.String originatorServerType,
                                                           java.lang.String originatorOrganizationName)
        A server/repository is being removed from the metadata repository cohort.
        Specified by:
        processUnRegistrationEvent in interface OMRSRegistryEventProcessorInterface
        Parameters:
        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.
        originatorMetadataCollectionId - unique identifier of metadata collection of originator.
        originatorMetadataCollectionName - display name of metadata collection of originator.
        originatorServerName - name of the server that the event came from.
        originatorServerType - type of server that the event came from.
        originatorOrganizationName - name of the organization that owns the server that sent the event.
        Returns:
        flag indicating if the event was sent or not.
      • processConflictingCollectionIdEvent

        public abstract void processConflictingCollectionIdEvent​(java.lang.String sourceName,
                                                                 java.lang.String originatorMetadataCollectionId,
                                                                 java.lang.String originatorMetadataCollectionName,
                                                                 java.lang.String originatorServerName,
                                                                 java.lang.String originatorServerType,
                                                                 java.lang.String originatorOrganizationName,
                                                                 java.lang.String conflictingMetadataCollectionId,
                                                                 java.lang.String errorMessage)
        There is more than one member of the open metadata repository cohort that is using the same metadata collection Id. This means that their metadata instances can be updated in more than one server and their is a potential for data integrity issues.
        Specified by:
        processConflictingCollectionIdEvent in interface OMRSRegistryEventProcessorInterface
        Parameters:
        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.
        originatorMetadataCollectionId - unique identifier of metadata collection of originator.
        originatorMetadataCollectionName - display name of metadata collection of originator.
        originatorServerName - name of the server that the event came from.
        originatorServerType - type of server that the event came from.
        originatorOrganizationName - name of the organization that owns the server that sent the event.
        conflictingMetadataCollectionId - unique identifier for the metadata collection that is registering with the cohort.
        errorMessage - details of the conflict
      • processBadConnectionEvent

        public abstract void processBadConnectionEvent​(java.lang.String sourceName,
                                                       java.lang.String originatorMetadataCollectionId,
                                                       java.lang.String originatorMetadataCollectionName,
                                                       java.lang.String originatorServerName,
                                                       java.lang.String originatorServerType,
                                                       java.lang.String originatorOrganizationName,
                                                       java.lang.String targetMetadataCollectionId,
                                                       Connection remoteConnection,
                                                       java.lang.String errorMessage)
        A connection to one of the members of the open metadata repository cohort is not usable by one of the members.
        Specified by:
        processBadConnectionEvent in interface OMRSRegistryEventProcessorInterface
        Parameters:
        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.
        originatorMetadataCollectionId - unique identifier of metadata collection of originator.
        originatorMetadataCollectionName - display name of metadata collection of originator.
        originatorServerName - name of the server that the event came from.
        originatorServerType - type of server that the event came from.
        originatorOrganizationName - name of the organization that owns the server that sent the event.
        targetMetadataCollectionId - Id for the repository with the bad remote connection.
        remoteConnection - the Connection properties for the connector used to call the registering server.
        errorMessage - details of the error that occurs when the connection is used.