Class OpenMetadataTopicConsumerBase

    • Field Detail

      • connectionName

        protected java.lang.String connectionName
    • Constructor Detail

      • OpenMetadataTopicConsumerBase

        public OpenMetadataTopicConsumerBase()
    • Method Detail

      • initializeEmbeddedConnectors

        public void initializeEmbeddedConnectors​(java.util.List<Connector> embeddedConnectors)
        Set up the list of connectors that this virtual connector will use to support its interface. The connectors are initialized waiting to start. When start() is called on the virtual connector, it needs to pass start() to each of the embedded connectors. Similarly for disconnect().
        Specified by:
        initializeEmbeddedConnectors in interface VirtualConnectorExtension
        Parameters:
        embeddedConnectors - list of connectors
      • setAuditLog

        public void setAuditLog​(AuditLog auditLog)
        Receive an audit log object that can be used to record audit log messages. The caller has initialized it with the correct component description and log destinations.
        Specified by:
        setAuditLog in interface AuditLoggingComponent
        Parameters:
        auditLog - audit log object
      • validateEventBusConnectors

        protected void validateEventBusConnectors​(java.lang.String methodName)
                                           throws ConnectorCheckedException
        Validates that there is at least one event bus connector receiving events.
        Parameters:
        methodName - calling method
        Throws:
        ConnectorCheckedException - no event bus connectors available.