Package org.odpi.openmetadata.accessservices.dataengine.server.handlers

Class DataEngineConnectionAndEndpointHandler

java.lang.Object

org.odpi.openmetadata.accessservices.dataengine.server.handlers.DataEngineConnectionAndEndpointHandler

public class DataEngineConnectionAndEndpointHandler
extends Object

DataEngineConnectionAndEndpointHandler manages Connection and Endpoint objects from the property server. It runs server-side in the DataEngine OMAS and creates Connection and Endpoint entities with wire relationships through the OMRSRepositoryConnector.

Constructor Summary

Constructors

Constructor	Description
DataEngineConnectionAndEndpointHandler(InvalidParameterHandler invalidParameterHandler, OMRSRepositoryHelper repositoryHelper, String serviceName, String serverName, DataEngineCommonHandler dataEngineCommonHandler, ConnectionHandler<Connection> connectionHandler, EndpointHandler<Endpoint> endpointHandler, ConnectorTypeHandler<ConnectorType> connectorTypeHandler)	Construct the handler information needed to interact with the repository services

Method Summary

Modifier and Type	Method	Description
void	removeConnection(String userId, String connectionGUID, DeleteSemantic deleteSemantic, String externalSourceName, String externalSourceGUID)	Remove the connection
void	removeEndpoint(String userId, String endpointGUID, DeleteSemantic deleteSemantic, String externalSourceName, String externalSourceGUID)	Remove the endpoint
void	upsertConnectionAndEndpoint(String assetQualifiedName, String assetGUID, String assetTypeName, String protocol, String networkAddress, String externalSourceGUID, String externalSourceName, String userID)	Constructs an Endpoint linked to a Connection, which in turn links it to provided asset

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DataEngineConnectionAndEndpointHandler

public DataEngineConnectionAndEndpointHandler(InvalidParameterHandler invalidParameterHandler,
 OMRSRepositoryHelper repositoryHelper,
 String serviceName,
 String serverName,
 DataEngineCommonHandler dataEngineCommonHandler,
 ConnectionHandler<Connection> connectionHandler,
 EndpointHandler<Endpoint> endpointHandler,
 ConnectorTypeHandler<ConnectorType> connectorTypeHandler)

Construct the handler information needed to interact with the repository services

Parameters:

invalidParameterHandler - handler for managing parameter errors

repositoryHelper - provides utilities for manipulating the repository services objects

serviceName - service name

serverName - server name

dataEngineCommonHandler - provides common Data Engine OMAS utilities

connectionHandler - provides utilities specific for manipulating Connection

endpointHandler - provides utilities specific for manipulating Endpoint

connectorTypeHandler - provides utilities specific for manipulating ConnectorType

Method Details

upsertConnectionAndEndpoint

public void upsertConnectionAndEndpoint(String assetQualifiedName,
 String assetGUID,
 String assetTypeName,
 String protocol,
 String networkAddress,
 String externalSourceGUID,
 String externalSourceName,
 String userID)
                                 throws InvalidParameterException,
PropertyServerException,
UserNotAuthorizedException

Constructs an Endpoint linked to a Connection, which in turn links it to provided asset

Parameters:

assetQualifiedName - asset qualified name

assetGUID - asset GUID

assetTypeName - asset type name

protocol - property of Endpoint

networkAddress - property of Endpoint

externalSourceGUID - external source guid

externalSourceName - external source name

userID - user id

Throws:

InvalidParameterException - if invalid parameters

PropertyServerException - if errors in repository

UserNotAuthorizedException - if user not authorized

removeConnection

public void removeConnection(String userId,
 String connectionGUID,
 DeleteSemantic deleteSemantic,
 String externalSourceName,
 String externalSourceGUID)
                      throws FunctionNotSupportedException,
InvalidParameterException,
PropertyServerException,
UserNotAuthorizedException

Remove the connection

Parameters:

userId - the name of the calling user

connectionGUID - unique identifier of the connection to be removed

deleteSemantic - the delete semantic

externalSourceName - the external data engine

externalSourceGUID - the external data engine GUID

Throws:

InvalidParameterException - the bean properties are invalid

UserNotAuthorizedException - user not authorized to issue this request

PropertyServerException - problem accessing the property server

FunctionNotSupportedException - the repository does not support this call.

removeEndpoint

public void removeEndpoint(String userId,
 String endpointGUID,
 DeleteSemantic deleteSemantic,
 String externalSourceName,
 String externalSourceGUID)
                    throws FunctionNotSupportedException,
InvalidParameterException,
PropertyServerException,
UserNotAuthorizedException

Remove the endpoint

Parameters:

userId - the name of the calling user

endpointGUID - unique identifier of the endpoint to be removed

deleteSemantic - the delete semantic

externalSourceName - the external data engine

externalSourceGUID - the external data engine GUID

Throws:

InvalidParameterException - the bean properties are invalid

UserNotAuthorizedException - user not authorized to issue this request

PropertyServerException - problem accessing the property server

FunctionNotSupportedException - the repository does not support this call.