Package org.odpi.openmetadata.adapters.repositoryservices.auditlogstore.eventtopic

Class EventTopicAuditLogStoreConnector

java.lang.Object

org.odpi.openmetadata.frameworks.connectors.Connector

org.odpi.openmetadata.frameworks.connectors.ConnectorBase

org.odpi.openmetadata.repositoryservices.connectors.stores.auditlogstore.OMRSAuditLogStoreConnectorBase

org.odpi.openmetadata.adapters.repositoryservices.auditlogstore.eventtopic.EventTopicAuditLogStoreConnector

All Implemented Interfaces:

SecureConnectorExtension, VirtualConnectorExtension, OMRSAuditLogStore

public class EventTopicAuditLogStoreConnector
extends OMRSAuditLogStoreConnectorBase

EventTopicAuditLogStoreConnector provides a connector implementation for an event topic audit log destination.

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.frameworks.connectors.ConnectorBase

auditLog, connectedAssetProperties, connectionBean, connectionProperties, connectorInstanceId, embeddedConnectors, messageFormatter, secretsStoreConnectorMap

Constructor Summary

Constructors

Constructor	Description
EventTopicAuditLogStoreConnector()	Default constructor used by the connector provider.

Method Summary

Modifier and Type	Method	Description
void	initializeEmbeddedConnectors(List<Connector> embeddedConnectors)	Set up the list of connectors that this virtual connector will use to support its interface.
void	start()	Indicates that the connector is completely configured and can begin processing.
String	storeLogRecord(OMRSAuditLogRecord logRecord)	Store the audit log record in the audit log store.

Methods inherited from class org.odpi.openmetadata.repositoryservices.connectors.stores.auditlogstore.OMRSAuditLogStoreConnectorBase

getAuditLogRecord, getAuditLogRecordsByComponent, getAuditLogRecordsBySeverity, getAuditLogRecordsByTimeStamp, getDestinationName, getJSONLogRecord, getSupportedSeverities, initialize, isSupportedSeverity, storeLogRecord, validateLogRecord

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

combineConfigurationProperties, disconnect, disconnectConnectors, equals, getArrayConfigurationProperty, getAssetTypeName, getBooleanConfigurationProperty, getConnectedAssetProperties, getConnection, getConnectorInstanceId, getDateConfigurationProperty, getIntConfigurationProperty, getLongConfigurationProperty, getNetworkAddresses, getStringConfigurationProperty, getSuppliedPlaceholderProperties, hashCode, 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

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

EventTopicAuditLogStoreConnector

public EventTopicAuditLogStoreConnector()

Default constructor used by the connector provider.

Method Details

storeLogRecord

public String storeLogRecord(OMRSAuditLogRecord logRecord)
                      throws InvalidParameterException

Store the audit log record in the audit log store.

Specified by:

storeLogRecord in interface OMRSAuditLogStore

Specified by:

storeLogRecord in class OMRSAuditLogStoreConnectorBase

Parameters:

logRecord - log record to store

Returns:

unique identifier assigned to the log record

Throws:

InvalidParameterException - indicates that the logRecord parameter is invalid.

initializeEmbeddedConnectors

public void initializeEmbeddedConnectors(List<Connector> embeddedConnectors)

Set 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().

Specified by:

initializeEmbeddedConnectors in interface VirtualConnectorExtension

Overrides:

initializeEmbeddedConnectors in class ConnectorBase

Parameters:

embeddedConnectors - list of connectors

start

public void start()
           throws ConnectorCheckedException

Indicates that the connector is completely configured and can begin processing. OMRSTopicConnector needs to pass on the start() to its embedded connectors.

Overrides:

start in class ConnectorBase

Throws:

ConnectorCheckedException - there is a problem within the connector.