Class OMFOutTopicClientConnector
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.frameworkservices.omf.connectors.outtopic.OMFOutTopicClientConnector
- All Implemented Interfaces:
AuditLoggingComponent
,SecureConnectorExtension
,VirtualConnectorExtension
,OpenMetadataEventInterface
,OpenMetadataTopicListener
public class OMFOutTopicClientConnector
extends OpenMetadataTopicListenerConnectorBase
implements OpenMetadataEventInterface
OMFOutTopicClientConnector is the java base class implementation of
the client side connector that receives events from the Open Metadata Store'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
connectionBean, connectorInstanceId, messageFormatter, secretsStoreConnectorMap
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
processEvent
(String event) Method to pass an event received on topic.void
registerListener
(String userId, OpenMetadataEventListener listener) Register a listener object that will be passed each of the events published by the Open Metadata Store.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
combineConfigurationProperties, disconnectConnectors, equals, getArrayConfigurationProperty, getArrayConfigurationProperty, getArrayConfigurationProperty, getBooleanConfigurationProperty, getConnection, getConnectorInstanceId, getDateConfigurationProperty, getIntConfigurationProperty, getLongConfigurationProperty, getStringConfigurationProperty, getStringConfigurationProperty, getSuppliedPlaceholderProperties, hashCode, initialize, 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
-
OMFOutTopicClientConnector
public OMFOutTopicClientConnector()
-
-
Method Details
-
registerListener
public void registerListener(String userId, OpenMetadataEventListener listener) throws InvalidParameterException Register a listener object that will be passed each of the events published by the Open Metadata Store.- Specified by:
registerListener
in interfaceOpenMetadataEventInterface
- 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
-