Package org.odpi.openmetadata.governanceservers.dataengineproxy.processor

Class DataEngineProxyService

java.lang.Object

org.odpi.openmetadata.governanceservers.dataengineproxy.processor.DataEngineProxyService

All Implemented Interfaces:

Runnable

public class DataEngineProxyService
extends Object
implements Runnable

Class to handle periodically polling a Data Engine for changes, for those data engines that do not provide any event-based mechanism to notify on changes.

Constructor Summary

Constructors

Constructor	Description
DataEngineProxyService(DataEngineConnectorBase connector, String userId, DataEngineProxyConfig dataEngineProxyConfig, DataEngineClient dataEngineOMASClient, OMRSAuditLog auditLog)	Default constructor

Method Summary

Modifier and Type	Method	Description
void	initialize()
void	load()
void	pollProcessChanges(String processId)
void	run()	Poll for Process changes.
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Details

DataEngineProxyService

public DataEngineProxyService(DataEngineConnectorBase connector,
 String userId,
 DataEngineProxyConfig dataEngineProxyConfig,
 DataEngineClient dataEngineOMASClient,
 OMRSAuditLog auditLog)

Default constructor

Parameters:

connector - Data Engine Connector through which to connect to the data engine to poll

userId - the user ID used to poll for changes against the connector

dataEngineProxyConfig - configuration of the Data Engine (Proxy)

dataEngineOMASClient - Data Engine OMAS client through which to push any changes into Egeria

auditLog - audit log through which to record activities

Method Details

initialize

public void initialize()
                throws ConnectorCheckedException,
UserNotAuthorizedException,
InvalidParameterException,
PropertyServerException

Throws:

ConnectorCheckedException

UserNotAuthorizedException

InvalidParameterException

PropertyServerException

stop

public void stop()

run

public void run()

Poll for Process changes.

Specified by:

run in interface Runnable

load

public void load()

pollProcessChanges

public void pollProcessChanges(String processId)