Package org.odpi.openmetadata.adapters.connectors.pepys

Class PepysTopicCatalogTargetProcessor

java.lang.Object

org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipProperties

org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipBeanProperties

org.odpi.openmetadata.frameworks.openmetadata.properties.assets.processes.connectors.CatalogTargetProperties

org.odpi.openmetadata.frameworks.opengovernance.properties.CatalogTarget

org.odpi.openmetadata.frameworks.integration.properties.RequestedCatalogTarget

org.odpi.openmetadata.frameworks.integration.connectors.CatalogTargetProcessorBase

org.odpi.openmetadata.adapters.connectors.pepys.PepysTopicCatalogTargetProcessor

public class PepysTopicCatalogTargetProcessor
extends CatalogTargetProcessorBase

PepysTopicCatalogTargetProcessor looks after one of the audit log topics that Pepys is listening to. It registers the connector as a listener with the topic's connector and starts it. The records themselves are processed by the connector, since the counts for an anchor element are gathered from every topic.

Field Summary

Fields inherited from class org.odpi.openmetadata.frameworks.integration.connectors.CatalogTargetProcessorBase

auditLog, connectorName, metadataCollectionGUID, metadataCollectionName, propertyHelper

Fields inherited from class org.odpi.openmetadata.frameworks.integration.properties.RequestedCatalogTarget

connectorToTarget, integrationContext

Fields inherited from class org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipBeanProperties

typeName

Constructor Summary

Constructors

Constructor	Description
PepysTopicCatalogTargetProcessor(CatalogTarget template, CatalogTargetContext catalogTargetContext, Connector connectorToTarget, String connectorName, AuditLog auditLog, OpenMetadataTopicListener listener)	Principle constructor.

Method Summary

Modifier and Type	Method	Description
void	refresh()	There is nothing to refresh for a topic - the records arrive as events.

Methods inherited from class org.odpi.openmetadata.frameworks.integration.connectors.CatalogTargetProcessorBase

disconnect, getArrayConfigurationProperty, getArrayConfigurationProperty, getArrayConfigurationProperty, getBooleanConfigurationProperty, getCatalogTargetElement, getDateConfigurationProperty, getHostIdentifier, getIntConfigurationProperty, getLongConfigurationProperty, getPortNumber, getStringConfigurationProperty, getSuppliedPlaceholderProperties, setUpMetadataSource, setUpSoftwareCapability, start, throwBadBeanClass, throwMissingConnectionInfo, throwMissingPropertyValue, throwWrongTypeOfCatalogTarget, throwWrongTypeOfResourceConnector

Methods inherited from class org.odpi.openmetadata.frameworks.integration.properties.RequestedCatalogTarget

clearRetrievedCatalogTargetElement, equals, getCatalogTargetElement, getCatalogTargetElementHeader, getCatalogTargetElementRetrievalException, getConnectorToTarget, getIntegrationContext, getNetworkAddress, hashCode, isStarted, toString

Methods inherited from class org.odpi.openmetadata.frameworks.opengovernance.properties.CatalogTarget

getRelationshipGUID, getRelationshipVersions, setCatalogTargetElement, setRelationshipGUID, setRelationshipVersions

Methods inherited from class org.odpi.openmetadata.frameworks.openmetadata.properties.assets.processes.connectors.CatalogTargetProperties

getCatalogTargetName, getConfigurationProperties, getConnectionName, getDeleteMethod, getMetadataCollectionQualifiedName, getMetadataSourceQualifiedName, getPermittedSynchronization, getTemplates, setCatalogTargetName, setConfigurationProperties, setConnectionName, setDeleteMethod, setMetadataCollectionQualifiedName, setMetadataSourceQualifiedName, setPermittedSynchronization, setTemplates

Methods inherited from class org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipBeanProperties

getExtendedProperties, getTypeName, setExtendedProperties, setTypeName

Methods inherited from class org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipProperties

getEffectiveFrom, getEffectiveTo, setEffectiveFrom, setEffectiveTo

Methods inherited from class java.lang.Object

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

Constructor Details

PepysTopicCatalogTargetProcessor

public PepysTopicCatalogTargetProcessor(CatalogTarget template,
 CatalogTargetContext catalogTargetContext,
 Connector connectorToTarget,
 String connectorName,
 AuditLog auditLog,
 OpenMetadataTopicListener listener)
                                 throws ConnectorCheckedException,
UserNotAuthorizedException

Principle constructor.

Parameters:

template - object to copy

catalogTargetContext - specialized context for this catalog target

connectorToTarget - connector to access the target resource

connectorName - name of this integration connector

auditLog - logging destination

listener - listener for the audit log records

Throws:

ConnectorCheckedException - the connector detected a problem.

UserNotAuthorizedException - the connector was disconnected before/during start

Method Details

refresh

public void refresh()

There is nothing to refresh for a topic - the records arrive as events.

Overrides:

refresh in class CatalogTargetProcessorBase