Class IntegrationDaemonInstance
java.lang.Object
org.odpi.openmetadata.commonservices.multitenant.OMAGServerServiceInstance
org.odpi.openmetadata.commonservices.multitenant.AuditableServerServiceInstance
org.odpi.openmetadata.commonservices.multitenant.GovernanceServerServiceInstance
org.odpi.openmetadata.governanceservers.integrationdaemonservices.server.IntegrationDaemonInstance
IntegrationDaemonInstance maintains the instance information needed to execute requests on behalf of
an integration daemon. The integration daemon is running
-
Field Summary
Fields inherited from class org.odpi.openmetadata.commonservices.multitenant.GovernanceServerServiceInstance
accessServiceInTopicName, accessServiceOutTopicName, accessServiceRootURL, accessServiceServerName, invalidParameterHandler
Fields inherited from class org.odpi.openmetadata.commonservices.multitenant.AuditableServerServiceInstance
auditLog, localServerUserId
Fields inherited from class org.odpi.openmetadata.commonservices.multitenant.OMAGServerServiceInstance
maxPageSize, securityVerifier, serverName, serviceName
-
Method Summary
Modifier and TypeMethodDescriptiongetConfigurationProperties
(String connectorName) Retrieve the configuration properties of the named connector.Retrieve all the connectors.void
refreshConnector
(String connectorName) Refresh all the connectors, or a specific connector if a connector name is supplied.void
restartConnector
(String connectorName) Restart all the connectors, or a specific connector if a connector name is supplied.void
shutdown()
Shutdown the integration daemonvoid
updateConfigurationProperties
(String userId, String connectorName, boolean isMergeUpdate, Map<String, Object> configurationProperties) Update the configuration properties of a specific named connector.void
updateConnectorConnection
(String userId, String connectorName, Connection connection) Update the connection for a specific integration connector.void
updateEndpointNetworkAddress
(String userId, String connectorName, String networkAddress) Update the endpoint network address for a specific integration connector.Methods inherited from class org.odpi.openmetadata.commonservices.multitenant.AuditableServerServiceInstance
getAuditLog
Methods inherited from class org.odpi.openmetadata.commonservices.multitenant.OMAGServerServiceInstance
getInvalidParameterHandler, getServerName, getServiceInstanceStatus, getServiceName, setMaxPageSize, setSecurityVerifier, setServerName, setServiceInstanceStatus
-
Method Details
-
getConfigurationProperties
public Map<String,Object> getConfigurationProperties(String connectorName) throws InvalidParameterException Retrieve the configuration properties of the named connector.- Parameters:
connectorName
- name of a specific connector- Returns:
- property map
- Throws:
InvalidParameterException
- the connector name is not recognized
-
updateConfigurationProperties
public void updateConfigurationProperties(String userId, String connectorName, boolean isMergeUpdate, Map<String, Object> configurationProperties) throws InvalidParameterExceptionUpdate the configuration properties of a specific named connector.- Parameters:
userId
- calling userconnectorName
- 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 recognized
-
updateEndpointNetworkAddress
public void updateEndpointNetworkAddress(String userId, String connectorName, String networkAddress) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Update the endpoint network address for a specific integration connector.- Parameters:
userId
- calling userconnectorName
- 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 connectorName, Connection connection) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Update the connection for a specific integration connector.- Parameters:
userId
- calling userconnectorName
- 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
-
getConnectorReports
Retrieve all the connectors. -
refreshConnector
Refresh all the connectors, or a specific connector if a connector name is supplied.- Parameters:
connectorName
- name of a specific connector or null for all connectors- Throws:
InvalidParameterException
- the connector name is not recognized
-
restartConnector
Restart all the connectors, or a specific connector if a connector name is supplied.- Parameters:
connectorName
- name of a specific connector or null for all connectors- Throws:
InvalidParameterException
- the connector name is not recognized
-
shutdown
public void shutdown()Shutdown the integration daemon- Overrides:
shutdown
in classOMAGServerServiceInstance
-