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

Class IntegrationConnectorCacheMap

java.lang.Object

org.odpi.openmetadata.governanceservers.integrationdaemonservices.handlers.IntegrationConnectorCacheMap

public class IntegrationConnectorCacheMap
extends Object

IntegrationConnectorCacheMap maintains the map of connectorIds to integration connector handlers. It is synchronized because the map is being rebuilt periodically.

Constructor Summary

Constructors

Constructor	Description
IntegrationConnectorCacheMap()

Method Summary

Modifier and Type	Method	Description
List<String>	getConnectorIds()	Return the list of connectorIds registered with an integration daemon.
IntegrationConnectorHandler	getHandlerByConnectorId(String connectorId)	Retrieve the integration connector for the connectorId.
IntegrationConnectorHandler	getHandlerByConnectorName(String connectorName)	Retrieve the integration connector by its connector name.
List<IntegrationConnectorHandler>	getIntegrationConnectorProcessingList()	Return the list of connectors that should be processed by the integration daemon thread.
void	putHandlerByConnectorId(String connectorId, IntegrationConnectorHandler integrationConnectorHandler, boolean permanent)	Add a new integration connector to the map/list.

Methods inherited from class java.lang.Object

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

Constructor Details

IntegrationConnectorCacheMap

public IntegrationConnectorCacheMap()

Method Details

putHandlerByConnectorId

public void putHandlerByConnectorId(String connectorId,
 IntegrationConnectorHandler integrationConnectorHandler,
 boolean permanent)

Add a new integration connector to the map/list. New connectors are added to the front of the list, so they get processed first in the next iteration.

Parameters:

connectorId - unique identifier of the connector

integrationConnectorHandler - mapped integration connector

permanent - is this connector part of the static configuration?

getHandlerByConnectorId

public IntegrationConnectorHandler getHandlerByConnectorId(String connectorId)

Retrieve the integration connector for the connectorId.

Parameters:

connectorId - identifier of the connector.

Returns:

connector handler

getHandlerByConnectorName

public IntegrationConnectorHandler getHandlerByConnectorName(String connectorName)

Retrieve the integration connector by its connector name.

Parameters:

connectorName - identifier of the connector.

Returns:

connector handler

getConnectorIds

public List<String> getConnectorIds()

Return the list of connectorIds registered with an integration daemon.

Returns:

list of connector ids.

getIntegrationConnectorProcessingList

public List<IntegrationConnectorHandler> getIntegrationConnectorProcessingList()

Return the list of connectors that should be processed by the integration daemon thread.

Returns:

list of non-blocking connectors