Class IntegrationDaemonInstanceHandler
java.lang.Object
org.odpi.openmetadata.commonservices.multitenant.OMAGServerServiceInstanceHandler
org.odpi.openmetadata.commonservices.multitenant.AuditableServerServiceInstanceHandler
org.odpi.openmetadata.commonservices.multitenant.GovernanceServerServiceInstanceHandler
org.odpi.openmetadata.governanceservers.integrationdaemonservices.server.IntegrationDaemonInstanceHandler
IntegrationDaemonInstanceHandler retrieves information from the instance map for the
integration daemon instances. The instance map is thread-safe. Instances are added
and removed by the IntegrationDaemonOperationalServices class.
-
Field Summary
Fields inherited from class org.odpi.openmetadata.commonservices.multitenant.GovernanceServerServiceInstanceHandler
invalidParameterHandler
Fields inherited from class org.odpi.openmetadata.commonservices.multitenant.OMAGServerServiceInstanceHandler
platformInstanceMap, serviceName
-
Constructor Summary
ConstructorDescriptionDefault constructor registers the access service -
Method Summary
Modifier and TypeMethodDescriptiongetConfigurationProperties
(String userId, String serverName, String serviceOperationName, String connectorName) Retrieve the configuration properties of the named connector.getIntegrationServiceContextManagers
(String userId, String serverName, String serviceURLMarker, String serviceOperationName) Retrieve the specific context manager for the requested integration service.getIntegrationServiceHandler
(String userId, String serverName, String serviceURLMarker, String serviceOperationName) Retrieve the specific handler for the requested integration service.void
refreshConnector
(String userId, String serverName, String serviceOperationName, String connectorName) Refresh the named connector.void
restartConnector
(String userId, String serverName, String serviceOperationName, String connectorName) Restart the named connector.void
updateConfigurationProperties
(String userId, String serverName, String serviceOperationName, String connectorName, boolean isMergeUpdate, Map<String, Object> configurationProperties) Update the configuration properties of the named connector.void
updateConnectorConnection
(String userId, String serverName, String serviceOperationName, String connectorName, Connection connection) Update the connection for a specific integration connector.void
updateEndpointNetworkAddress
(String userId, String serverName, String serviceOperationName, String connectorName, String networkAddress) Update the endpoint network address for a specific integration connector.Methods inherited from class org.odpi.openmetadata.commonservices.multitenant.GovernanceServerServiceInstanceHandler
validateConnector
Methods inherited from class org.odpi.openmetadata.commonservices.multitenant.AuditableServerServiceInstanceHandler
getAuditLog
Methods inherited from class org.odpi.openmetadata.commonservices.multitenant.OMAGServerServiceInstanceHandler
getServerSecurityVerifier, getServerServiceInstance, getServiceName, isServerActive, removeServerServiceInstance
-
Constructor Details
-
IntegrationDaemonInstanceHandler
public IntegrationDaemonInstanceHandler()Default constructor registers the access service
-
-
Method Details
-
getIntegrationServiceHandler
public IntegrationServiceHandler getIntegrationServiceHandler(String userId, String serverName, String serviceURLMarker, String serviceOperationName) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Retrieve the specific handler for the requested integration service.- Parameters:
userId
- calling userserverName
- name of the server tied to the requestserviceURLMarker
- marker that identifies the called service in the URLserviceOperationName
- name of the REST API call (typically the top-level methodName)- Returns:
- handler for use by the requested instance
- Throws:
InvalidParameterException
- no available instance for the requested serverUserNotAuthorizedException
- user does not have access to the requested serverPropertyServerException
- the service name is not known - indicating a logic error
-
getIntegrationServiceContextManagers
public List<IntegrationContextManager> getIntegrationServiceContextManagers(String userId, String serverName, String serviceURLMarker, String serviceOperationName) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Retrieve the specific context manager for the requested integration service.- Parameters:
userId
- calling userserverName
- name of the server tied to the requestserviceURLMarker
- marker that identifies the called service in the URLserviceOperationName
- name of the REST API call (typically the top-level methodName)- Returns:
- handler for use by the requested instance
- Throws:
InvalidParameterException
- no available instance for the requested serverUserNotAuthorizedException
- user does not have access to the requested serverPropertyServerException
- the service name is not known - indicating a logic error
-
getConfigurationProperties
public Map<String,Object> getConfigurationProperties(String userId, String serverName, String serviceOperationName, String connectorName) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Retrieve the configuration properties of the named connector.- Parameters:
userId
- calling userserverName
- name of the server tied to the requestserviceOperationName
- name of the REST API call (typically the top-level methodName)connectorName
- name of a specific connector- Returns:
- property map
- Throws:
InvalidParameterException
- the connector name is not recognizedUserNotAuthorizedException
- user does not have access to the requested serverPropertyServerException
- the service name is not known - indicating a logic error
-
updateConfigurationProperties
public void updateConfigurationProperties(String userId, String serverName, String serviceOperationName, String connectorName, boolean isMergeUpdate, Map<String, Object> configurationProperties) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerExceptionUpdate the configuration properties of the named connector.- Parameters:
userId
- calling userserverName
- name of the server tied to the requestserviceOperationName
- name of the REST API call (typically the top-level methodName)connectorName
- name of a specific connectorisMergeUpdate
- should the properties be merged into the existing properties or replace themconfigurationProperties
- new configuration properties- Throws:
InvalidParameterException
- the connector name is not recognizedUserNotAuthorizedException
- user does not have access to the requested serverPropertyServerException
- the service name is not known - indicating a logic error
-
updateEndpointNetworkAddress
public void updateEndpointNetworkAddress(String userId, String serverName, String serviceOperationName, String connectorName, String networkAddress) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Update the endpoint network address for a specific integration connector.- Parameters:
serverName
- integration daemon server nameuserId
- calling userserviceOperationName
- calling methodconnectorName
- name of a specific connectornetworkAddress
- name of a specific connector or null for all connectors and the properties to change- Throws:
InvalidParameterException
- the connector name is not recognizedUserNotAuthorizedException
- user does not have access to the requested serverPropertyServerException
- the service name is not known - indicating a logic error
-
updateConnectorConnection
public void updateConnectorConnection(String userId, String serverName, String serviceOperationName, String connectorName, Connection connection) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Update the connection for a specific integration connector.- Parameters:
serverName
- integration daemon server nameuserId
- calling userserviceOperationName
- calling methodconnectorName
- name of a specific connectorconnection
- new connection object- Throws:
InvalidParameterException
- the connector name is not recognizedUserNotAuthorizedException
- user does not have access to the requested serverPropertyServerException
- the service name is not known - indicating a logic error
-
refreshConnector
public void refreshConnector(String userId, String serverName, String serviceOperationName, String connectorName) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Refresh the named connector.- Parameters:
userId
- calling userserverName
- name of the server tied to the requestserviceOperationName
- name of the REST API call (typically the top-level methodName)connectorName
- name of a specific connector- Throws:
InvalidParameterException
- the connector name is not recognizedUserNotAuthorizedException
- user does not have access to the requested serverPropertyServerException
- the service name is not known - indicating a logic error
-
restartConnector
public void restartConnector(String userId, String serverName, String serviceOperationName, String connectorName) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Restart the named connector.- Parameters:
userId
- calling userserverName
- name of the server tied to the requestserviceOperationName
- name of the REST API call (typically the top-level methodName)connectorName
- name of a specific connector- Throws:
InvalidParameterException
- the connector name is not recognizedUserNotAuthorizedException
- user does not have access to the requested serverPropertyServerException
- the service name is not known - indicating a logic error
-