Package org.odpi.openmetadata.adapters.eventbus.topic.inmemory

Class InMemoryOpenMetadataTopicConnector

java.lang.Object

org.odpi.openmetadata.frameworks.connectors.Connector

org.odpi.openmetadata.frameworks.connectors.ConnectorBase

org.odpi.openmetadata.repositoryservices.connectors.openmetadatatopic.OpenMetadataTopicConnector

org.odpi.openmetadata.adapters.eventbus.topic.inmemory.InMemoryOpenMetadataTopicConnector

All Implemented Interfaces:

Runnable, AuditLoggingComponent, SecureConnectorExtension, VirtualConnectorExtension, OpenMetadataTopic

public class InMemoryOpenMetadataTopicConnector
extends OpenMetadataTopicConnector

InMemoryOpenMetadataTopicConnector provides a concrete implementation of the OpenMetadataTopicConnector that uses an in-memory list as the event/messaging infrastructure. This connector is used internally in the OMRS to pass events received on the OMRS Topic to the OMAS Topic Listeners.

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.OpenMetadataTopicConnector

auditLog

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

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

Constructor Summary

Constructors

Constructor	Description
InMemoryOpenMetadataTopicConnector()	Constructor

Method Summary

Modifier and Type	Method	Description
protected List<String>	checkForEvents()	Look to see if there is one of more new events to process.
void	disconnect()	Free up any resources held since the connector is no longer needed.
void	sendEvent(String event)	Sends the supplied event to the topic.
void	start()	Indicates that the connector is completely configured and can begin processing.

Methods inherited from class org.odpi.openmetadata.repositoryservices.connectors.openmetadatatopic.OpenMetadataTopicConnector

checkForIncomingEvents, getConnectorComponentDescription, registerListener, run, setAuditLog

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

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

InMemoryOpenMetadataTopicConnector

public InMemoryOpenMetadataTopicConnector()

Constructor

Method Details

sendEvent

public void sendEvent(String event)

Sends the supplied event to the topic.

Parameters:

event - OMRSEvent object containing the event properties.

checkForEvents

protected List<String> checkForEvents()

Look to see if there is one of more new events to process.

Overrides:

checkForEvents in class OpenMetadataTopicConnector

Returns:

a list of received events or null

start

public void start()
           throws ConnectorCheckedException

Indicates that the connector is completely configured and can begin processing.

Overrides:

start in class OpenMetadataTopicConnector

Throws:

ConnectorCheckedException - there is a problem within the connector.

disconnect

public void disconnect()
                throws ConnectorCheckedException

Free up any resources held since the connector is no longer needed.

Overrides:

disconnect in class OpenMetadataTopicConnector

Throws:

ConnectorCheckedException - there is a problem within the connector.