Class ITInfrastructureOutTopicClientConnector
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.accessservices.itinfrastructure.connectors.outtopic.ITInfrastructureOutTopicClientConnector
- All Implemented Interfaces:
ITInfrastructureEventInterface
,AuditLoggingComponent
,SecureConnectorExtension
,VirtualConnectorExtension
,OpenMetadataTopicListener
public class ITInfrastructureOutTopicClientConnector
extends OpenMetadataTopicListenerConnectorBase
implements ITInfrastructureEventInterface
ITInfrastructureOutTopicClientConnector is the java base class implementation of the
the client side connector that receives events from the IT Infrastructure OMAS'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
connectedAssetProperties, connectionBean, connectionProperties, connectorInstanceId, messageFormatter, secretsStoreConnectorMap
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
processEvent
(String event) Method to pass an event received on topic.void
registerListener
(String userId, ITInfrastructureEventListener listener) Register a listener object that will be passed each of the events published by the IT Infrastructure OMAS.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, getAssetTypeName, getBooleanConfigurationProperty, getConnectedAssetProperties, getConnection, getConnectorInstanceId, getIntConfigurationProperty, getLongConfigurationProperty, getNetworkAddresses, getStringConfigurationProperty, getSuppliedPlaceholderProperties, hashCode, initialize, 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
-
Constructor Details
-
ITInfrastructureOutTopicClientConnector
public ITInfrastructureOutTopicClientConnector()
-
-
Method Details
-
registerListener
public void registerListener(String userId, ITInfrastructureEventListener listener) throws InvalidParameterException Register a listener object that will be passed each of the events published by the IT Infrastructure OMAS.- Specified by:
registerListener
in interfaceITInfrastructureEventInterface
- 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
-