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, invalidParameterHandlerFields inherited from class org.odpi.openmetadata.commonservices.multitenant.AuditableServerServiceInstance
auditLog, localServerUserIdFields 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.voidrefreshConnector(String connectorName) Refresh all the connectors, or a specific connector if a connector name is supplied.voidrestartConnector(String connectorName) Restart all the connectors, or a specific connector if a connector name is supplied.voidshutdown()Shutdown the integration daemonvoidupdateConfigurationProperties(String userId, String connectorName, boolean isMergeUpdate, Map<String, Object> configurationProperties) Update the configuration properties of a specific named connector.voidupdateConnectorConnection(String userId, String connectorName, Connection connection) Update the connection for a specific integration connector.voidupdateEndpointNetworkAddress(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
getAuditLogMethods 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:
shutdownin classOMAGServerServiceInstance
-