Class OpenMetadataTopicSenderConnectorBase
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.OpenMetadataTopicSenderConnectorBase
- All Implemented Interfaces:
AuditLoggingComponent
,SecureConnectorExtension
,VirtualConnectorExtension
- Direct Known Subclasses:
AssetConsumerOutTopicServerConnector
,AssetManagerOutTopicServerConnector
,AssetOwnerOutTopicServerConnector
,CommunityProfileOutTopicServerConnector
,DataManagerOutTopicServerConnector
,DigitalArchitectureOutTopicServerConnector
,GovernanceEngineOutTopicServerConnector
,GovernanceServerOutTopicServerConnector
,ITInfrastructureOutTopicServerConnector
,SecurityManagerOutTopicServerConnector
,StewardshipActionOutTopicServerConnector
OpenMetadataTopicConnectorBase is a base class to topic connectors that only send
events on the embedded event bus connector
-
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, secretsStoreConnectorMap
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected CompletableFuture<Void>
Send the request to the embedded event bus connector(s).Methods inherited from class org.odpi.openmetadata.repositoryservices.connectors.openmetadatatopic.OpenMetadataTopicConsumerBase
disconnect, getConnectorComponentDescription, initializeEmbeddedConnectors, setAuditLog, start, validateEventBusConnectors
Methods inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase
disconnectConnectors, equals, getArrayConfigurationProperty, getAssetTypeName, getBooleanConfigurationProperty, getConnectedAssetProperties, getConnection, getConnectorInstanceId, getIntConfigurationProperty, getNetworkAddresses, getStringConfigurationProperty, getSuppliedPlaceholderProperties, hashCode, initialize, initializeConnectedAssetProperties, initializeSecretsStoreConnector, isActive, 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
-
OpenMetadataTopicSenderConnectorBase
public OpenMetadataTopicSenderConnectorBase()
-
-
Method Details
-
sendEvent
protected CompletableFuture<Void> sendEvent(String event) throws InvalidParameterException, ConnectorCheckedException Send the request to the embedded event bus connector(s).- Parameters:
event
- event as a string- Returns:
- a completable future with the sendEvent result
- Throws:
InvalidParameterException
- the event is nullConnectorCheckedException
- there is a problem with the embedded event bus connector(s).
-