Package org.odpi.openmetadata.governanceservers.integrationdaemonservices.handlers

Class IntegrationServiceHandler

java.lang.Object
org.odpi.openmetadata.governanceservers.integrationdaemonservices.handlers.IntegrationServiceHandler
public class IntegrationServiceHandler extends Object
IntegrationServiceHandler provides the support for a specific integration service running in the integration daemon. This handler is responsible for setting up its connectors and responding to REST API calls. The management of the threads where the connectors are running is handled by the IntegrationDaemonThread.

  • Constructor Details

    • IntegrationServiceHandler

      public IntegrationServiceHandler(String localServerName, String localServerUserId, IntegrationServiceConfig serviceConfig, IntegrationContextManager contextManager, AuditLog auditLog)
      Constructor passes the service config. It is just saved at this point. Interesting things start to happen on initialize().
      Parameters:
      localServerName - name of the local server
      localServerUserId - userId for server requests
      serviceConfig - configuration for this specific integration service
      contextManager - context manager instance for this integration service
      auditLog - logging destination

  • Method Details

    • getContextManager

      public IntegrationContextManager getContextManager()
      Return the context manager for this service. Each integration service has its own implementation.
      Returns:
      supplied context manager

    • getIntegrationServiceFullName

      public String getIntegrationServiceFullName()
      Return the full name of the service.
      Returns:
      string name

    • initialize

      public List<IntegrationConnectorHandler> initialize()
      Create connector handlers for each of the connections listed in the configuration and return them to the caller. When the connector handlers are returned, the integration connectors within them are fully initialized and have their context set. They are ready to be called for start() which is done by the integration daemon handler when they are on the correct thread.
      Returns:
      list of initialized connection handlers or empty list of no working connectors

    • getIntegrationServiceSummary

      public IntegrationServiceSummary getIntegrationServiceSummary()
      Retrieve the status of this integration service.
      Returns:
      Status summary for this integration service

    • refreshService

      public void refreshService(String connectorName) throws InvalidParameterException
      Refresh all the connectors, or a specific connector if a connector name is supplied in a service.
      Parameters:
      connectorName - name of a specific connector or null for all connectors
      Throws:
      InvalidParameterException - the connector name is not recognized

    • restartService

      public void restartService(String connectorName) throws InvalidParameterException
      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