Class InfrastructureIntegratorContextManager
java.lang.Object
org.odpi.openmetadata.frameworks.integration.contextmanager.IntegrationContextManager
org.odpi.openmetadata.integrationservices.infrastructure.contextmanager.InfrastructureIntegratorContextManager
InfrastructureIntegratorContextManager provides the bridge between the integration daemon services and
the specific implementation of an integration service
-
Field Summary
Fields inherited from class org.odpi.openmetadata.frameworks.integration.contextmanager.IntegrationContextManager
actionControlInterface, auditLog, connectedAssetContext, governanceConfiguration, localServerPassword, localServerUserId, maxPageSize, openIntegrationClient, openMetadataStoreClient, partnerOMASPlatformRootURL, partnerOMASServerName, serviceOptions
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
createClients
(int maxPageSize) Suggestion for subclass to create client(s) to partner OMAS.void
initializeContextManager
(String partnerOMASServerName, String partnerOMASPlatformRootURL, String userId, String password, Map<String, Object> serviceOptions, int maxPageSize, AuditLog auditLog) Initialize server properties for the context manager.setContext
(String connectorId, String connectorName, String connectorUserId, IntegrationConnector integrationConnector, String integrationConnectorGUID, PermittedSynchronization permittedSynchronization, boolean generateIntegrationReport, String metadataSourceQualifiedName) Set up the context in the supplied connector.Methods inherited from class org.odpi.openmetadata.frameworks.integration.contextmanager.IntegrationContextManager
setUpMetadataSource
-
Constructor Details
-
InfrastructureIntegratorContextManager
public InfrastructureIntegratorContextManager()Default constructor
-
-
Method Details
-
initializeContextManager
public void initializeContextManager(String partnerOMASServerName, String partnerOMASPlatformRootURL, String userId, String password, Map<String, Object> serviceOptions, int maxPageSize, AuditLog auditLog) Initialize server properties for the context manager.- Overrides:
initializeContextManager
in classIntegrationContextManager
- Parameters:
partnerOMASServerName
- name of the server to connect topartnerOMASPlatformRootURL
- the network address of the server running the OMAS REST servicesuserId
- caller's userId embedded in all HTTP requestspassword
- caller's userId embedded in all HTTP requestsserviceOptions
- options from the integration service's configurationmaxPageSize
- maximum number of results that can be returned on a single REST callauditLog
- logging destination
-
createClients
Suggestion for subclass to create client(s) to partner OMAS.- Overrides:
createClients
in classIntegrationContextManager
- Parameters:
maxPageSize
- maximum value allowed for page size- Throws:
InvalidParameterException
- the subclass is not able to create one of its clients
-
setContext
public IntegrationContext setContext(String connectorId, String connectorName, String connectorUserId, IntegrationConnector integrationConnector, String integrationConnectorGUID, PermittedSynchronization permittedSynchronization, boolean generateIntegrationReport, String metadataSourceQualifiedName) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Set up the context in the supplied connector. This is called between initialize() and start() on the connector.- Overrides:
setContext
in classIntegrationContextManager
- Parameters:
connectorId
- unique identifier of the connector (used to configure the event listener)connectorName
- name of connector from configconnectorUserId
- userId for the connectorintegrationConnector
- connector created from connection integration service configurationintegrationConnectorGUID
- unique identifier of the integration connector entity (only set if working with integration groups)permittedSynchronization
- controls the direction(s) that metadata is allowed to flowgenerateIntegrationReport
- should the connector generate an integration reports?metadataSourceQualifiedName
- unique name of the software server capability that represents the metadata source.- Returns:
- the new integration context
- Throws:
InvalidParameterException
- the connector is not of the correct typeUserNotAuthorizedException
- user not authorized to issue this requestPropertyServerException
- problem accessing the property server
-