Class GovernanceEngineOutTopicClientConnector
java.lang.Object
org.odpi.openmetadata.frameworks.connectors.Connector
org.odpi.openmetadata.frameworks.connectors.ConnectorBase
org.odpi.openmetadata.repositoryservices.connectors.openmetadatatopic.OpenMetadataTopicConsumerBase
org.odpi.openmetadata.repositoryservices.connectors.openmetadatatopic.OpenMetadataTopicListenerConnectorBase
org.odpi.openmetadata.accessservices.governanceengine.connectors.outtopic.GovernanceEngineOutTopicClientConnector
- All Implemented Interfaces:
GovernanceEngineEventInterface
,AuditLoggingComponent
,SecureConnectorExtension
,VirtualConnectorExtension
,OpenMetadataTopicListener
public class GovernanceEngineOutTopicClientConnector
extends OpenMetadataTopicListenerConnectorBase
implements GovernanceEngineEventInterface
GovernanceEngineOutTopicClientConnector is the java base class implementation of the
the client side connector that receives events from the Governance Engine OMAS's OutTopic.
-
Nested Class Summary
Nested classes/interfaces inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase
ConnectorBase.ProtectedConnection
-
Field Summary
Fields inherited from class org.odpi.openmetadata.repositoryservices.connectors.openmetadatatopic.OpenMetadataTopicConsumerBase
auditLog, connectionName, embeddedConnectors, eventBusConnectors
Fields inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase
connectedAssetProperties, connectionBean, connectionProperties, connectorInstanceId, messageFormatter, secretsStoreConnectorMap
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
processEvent
(String event) Method to pass an event received on topic.void
registerListener
(String userId, GovernanceEngineEventListener listener) Register a listener object that will be passed each of the events published by the Governance Engine OMAS.Methods inherited from class org.odpi.openmetadata.repositoryservices.connectors.openmetadatatopic.OpenMetadataTopicListenerConnectorBase
disconnect, getEventBean, initializeEmbeddedConnectors
Methods inherited from class org.odpi.openmetadata.repositoryservices.connectors.openmetadatatopic.OpenMetadataTopicConsumerBase
getConnectorComponentDescription, setAuditLog, start, validateEventBusConnectors
Methods inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase
combineConfigurationProperties, disconnectConnectors, equals, getArrayConfigurationProperty, getAssetTypeName, getBooleanConfigurationProperty, getConnectedAssetProperties, getConnection, getConnectorInstanceId, getIntConfigurationProperty, getLongConfigurationProperty, getNetworkAddresses, getStringConfigurationProperty, getSuppliedPlaceholderProperties, hashCode, initialize, initializeConnectedAssetProperties, initializeSecretsStoreConnector, isActive, logExceptionRecord, logRecord, logRecord, throwMissingConfigurationProperty, throwMissingResource, throwNoAsset, throwWrongTypeOfAsset, throwWrongTypeOfResource, throwWrongTypeOfRootSchema, toString
Methods inherited from class org.odpi.openmetadata.frameworks.connectors.Connector
clearStatisticProperty, clearStatisticTimestamp, getConnectorStatistics, getStatisticCounter, getStatisticProperty, getStatisticTimestamp, incrementStatisticCounter, initializeStatisticCounter, setStatisticProperty, setStatisticTimestamp
-
Constructor Details
-
GovernanceEngineOutTopicClientConnector
public GovernanceEngineOutTopicClientConnector()
-
-
Method Details
-
registerListener
public void registerListener(String userId, GovernanceEngineEventListener listener) throws InvalidParameterException Register a listener object that will be passed each of the events published by the Governance Engine OMAS.- Specified by:
registerListener
in interfaceGovernanceEngineEventInterface
- Parameters:
userId
- calling userlistener
- listener object- Throws:
InvalidParameterException
- one of the parameters is null or invalid.
-
processEvent
Method to pass an event received on topic.- Specified by:
processEvent
in interfaceOpenMetadataTopicListener
- Specified by:
processEvent
in classOpenMetadataTopicListenerConnectorBase
- Parameters:
event
- inbound event
-