Package org.odpi.openmetadata.accessservices.itinfrastructure.connectors.outtopic

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

Constructors

Constructor	Description
ITInfrastructureOutTopicClientConnector()

Method Summary

Modifier and Type	Method	Description
void	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, getDateConfigurationProperty, 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

Methods inherited from class java.lang.Object

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

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 interface ITInfrastructureEventInterface

Parameters:

userId - calling user

listener - listener object

Throws:

InvalidParameterException - one of the parameters is null or invalid.

processEvent

public void processEvent(String event)

Method to pass an event received on topic.

Specified by:

processEvent in interface OpenMetadataTopicListener

Specified by:

processEvent in class OpenMetadataTopicListenerConnectorBase

Parameters:

event - inbound event