Package org.odpi.openmetadata.repositoryservices.enterprise.repositoryconnector.control

Class FederationControlBase

java.lang.Object

org.odpi.openmetadata.repositoryservices.enterprise.repositoryconnector.control.FederationControlBase

All Implemented Interfaces:

FederationControl

Direct Known Subclasses:

ParallelFederationControl, SequentialFederationControl

public abstract class FederationControlBase
extends Object
implements FederationControl

FederationControlBase provides the base class for control logic that manages a federated query across the repositories registered with the enterprise connector manager. An instance of the federation control class is created for each query. It is passed an executor object that is able to issue the appropriate query and handle the response. The federation control class calls the executor repeatedly, passing in the metadata collection until the executor tells it to stop, or it runs out of registered repositories. The caller (enterprise connector) then requests the response from the executor.

Field Summary

Fields

Modifier and Type	Field	Description
protected AuditLog	auditLog
protected List<OMRSRepositoryConnector>	cohortConnectors
protected String	methodName
protected String	userId

Constructor Summary

Constructors

Constructor	Description
FederationControlBase(String userId, List<OMRSRepositoryConnector> cohortConnectors, AuditLog auditLog, String methodName)	Constructor for a federated query

Method Summary

Modifier and Type	Method	Description
abstract void	executeCommand(RepositoryExecutor executor)	Issue the federated command

Methods inherited from class java.lang.Object

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

Field Details

userId

protected String userId

cohortConnectors

protected List<OMRSRepositoryConnector> cohortConnectors

auditLog

protected AuditLog auditLog

methodName

protected String methodName

Constructor Details

FederationControlBase

public FederationControlBase(String userId,
 List<OMRSRepositoryConnector> cohortConnectors,
 AuditLog auditLog,
 String methodName)

Constructor for a federated query

Parameters:

userId - calling user

cohortConnectors - list of connectors to call

auditLog - logging destination

methodName - calling method

Method Details

executeCommand

public abstract void executeCommand(RepositoryExecutor executor)
                             throws RepositoryErrorException

Issue the federated command

Specified by:

executeCommand in interface FederationControl

Parameters:

executor - command to execute

Throws:

RepositoryErrorException - problem with the state of one of the repositories. This is probably a logic error rather than an outage