Class LocalOMRSConnectorProvider
java.lang.Object
org.odpi.openmetadata.frameworks.connectors.ConnectorProvider
org.odpi.openmetadata.repositoryservices.localrepository.repositoryconnector.LocalOMRSConnectorProvider
LocalOMRSConnectorProvider implements the connector provider for LocalOMRSRepositoryConnector. Since a server only
has one LocalOMRSRepositoryConnector, this connector provider returns the singleton connector for the local repository.
-
Field Summary
Fields inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorProvider
supportedConfigurationProperties, supportedTechnologyTypes, supportedTemplateTypes -
Constructor Summary
ConstructorsConstructorDescriptionConstructor used by the OCF ConnectorBroker.LocalOMRSConnectorProvider(String localMetadataCollectionId, LocalRepositoryMode localRepositoryMode, Connection localRepositoryRemoteConnection, OMRSRepositoryEventMapperConnector realEventMapper, OMRSRepositoryEventManager outboundRepositoryEventManager, OMRSRepositoryContentManager repositoryContentManager, OMRSRepositoryEventExchangeRule saveExchangeRule, AuditLog auditLog) Constructor used by OMRSOperationalServices during server start-up. -
Method Summary
Modifier and TypeMethodDescriptiongetConnector(Connection realLocalConnection) Creates a new instance of a connector based on the information in the supplied connection.Returns the properties about the type of connector that this Connector Provider supports.Methods inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorProvider
getSupportedConfigurationProperties, getSupportedTechnologyTypes, getSupportedTemplateTypes
-
Constructor Details
-
LocalOMRSConnectorProvider
public LocalOMRSConnectorProvider(String localMetadataCollectionId, LocalRepositoryMode localRepositoryMode, Connection localRepositoryRemoteConnection, OMRSRepositoryEventMapperConnector realEventMapper, OMRSRepositoryEventManager outboundRepositoryEventManager, OMRSRepositoryContentManager repositoryContentManager, OMRSRepositoryEventExchangeRule saveExchangeRule, AuditLog auditLog) Constructor used by OMRSOperationalServices during server start-up. It provides the configuration information about the local server that is used to set up the local repository connector.- Parameters:
localMetadataCollectionId- metadata collection id for the local repositorylocalRepositoryMode- style of operation to performlocalRepositoryRemoteConnection- connection object for creating a remote connector to this repository.realEventMapper- optional event mapper for local repositoryoutboundRepositoryEventManager- event manager to call for outbound events.repositoryContentManager- repositoryContentManager for supporting OMRS in managing TypeDefs.saveExchangeRule- rule to determine what events to save to the local repository.auditLog- logging destination
-
LocalOMRSConnectorProvider
public LocalOMRSConnectorProvider()Constructor used by the OCF ConnectorBroker. This approach will result in an exception when getConnector is called because there is no localMetadataCollectionId (amongst other things).
-
-
Method Details
-
getConnectorType
Returns the properties about the type of connector that this Connector Provider supports.- Specified by:
getConnectorTypein classConnectorProvider- Returns:
- properties including the name of the connector type, the connector provider class and any specific connection properties that are recognized by this connector.
-
getConnector
public Connector getConnector(Connection realLocalConnection) throws ConnectionCheckedException, ConnectorCheckedException, UserNotAuthorizedException Creates a new instance of a connector based on the information in the supplied connection.- Specified by:
getConnectorin classConnectorProvider- Parameters:
realLocalConnection- connection that should have all the properties needed by the Connector Provider to create a connector instance.- Returns:
- Connector instance of the LocalOMRSRepositoryConnector wrapping the real local connector.
- Throws:
ConnectionCheckedException- if there are missing or invalid properties in the connectionConnectorCheckedException- if there are issues instantiating or initializing the connectorUserNotAuthorizedException
-