- All Implemented Interfaces:
- Direct Known Subclasses:
public class OpenMetadataTopicConsumerBase extends ConnectorBase implements VirtualConnectorExtension, AuditLoggingComponent
OpenMetadataTopicConnectorBase is a base class to topic connectors that only send events on the embedded event bus connector
Nested Class Summary
Field SummaryModifier and TypeFieldDescription
Method SummaryModifier and TypeMethodDescription
voidFree up any resources held since the connector is no longer needed.Return the component description that is used by this connector in the audit log.
voidSet up the list of connectors that this virtual connector will use to support its interface.
voidReceive an audit log object that can be used to record audit log messages.
start()Indicates that the connector is completely configured and can begin processing.
protected voidValidates that there is at least one event bus connector receiving events.
Methods inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase
disconnectConnectors, equals, getConnectedAssetProperties, getConnection, getConnectorInstanceId, hashCode, initialize, initializeConnectedAssetProperties, initializeSecretsStoreConnector, isActive, toString
Methods inherited from class org.odpi.openmetadata.frameworks.connectors.Connector
clearStatisticProperty, clearStatisticTimestamp, getConnectorStatistics, getStatisticCounter, getStatisticProperty, getStatisticTimestamp, incrementStatisticCounter, initializeStatisticCounter, setStatisticProperty, setStatisticTimestamp
initializeEmbeddedConnectorsSet up the list of connectors that this virtual connector will use to support its interface. The connectors are initialized waiting to start. When start() is called on the virtual connector, it needs to pass start() to each of the embedded connectors. Similarly for disconnect().
setAuditLogpublic void setAuditLog
(AuditLog auditLog)Receive an audit log object that can be used to record audit log messages. The caller has initialized it with the correct component description and log destinations.
getConnectorComponentDescriptionpublic ComponentDescription getConnectorComponentDescription()Return the component description that is used by this connector in the audit log.
validateEventBusConnectorsValidates that there is at least one event bus connector receiving events.
methodName- calling method
ConnectorCheckedException- no event bus connectors available.
startpublic void start() throws ConnectorCheckedExceptionIndicates that the connector is completely configured and can begin processing. OMRSTopicConnector needs to pass on the start() to its embedded connectors.
disconnectpublic void disconnect() throws ConnectorCheckedExceptionFree up any resources held since the connector is no longer needed.