Class AssetOwnerOutTopicClientConnector
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.assetowner.connectors.outtopic.AssetOwnerOutTopicClientConnector
- All Implemented Interfaces:
AssetOwnerEventInterface
,AuditLoggingComponent
,SecureConnectorExtension
,VirtualConnectorExtension
,OpenMetadataTopicListener
public class AssetOwnerOutTopicClientConnector
extends OpenMetadataTopicListenerConnectorBase
implements AssetOwnerEventInterface
AssetOwnerOutTopicClientConnector is the java base class implementation of the
the client side connector that receives events from the Asset Owner 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, AssetOwnerEventListener listener) Register a listener object that will be passed each of the events published by the Asset Owner 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
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
-
AssetOwnerOutTopicClientConnector
public AssetOwnerOutTopicClientConnector()
-
-
Method Details
-
registerListener
public void registerListener(String userId, AssetOwnerEventListener listener) throws InvalidParameterException Register a listener object that will be passed each of the events published by the Asset Owner OMAS.- Specified by:
registerListener
in interfaceAssetOwnerEventInterface
- 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
-