Class OpenMetadataTopicListenerConnectorBase

    • Constructor Detail

      • OpenMetadataTopicListenerConnectorBase

        public OpenMetadataTopicListenerConnectorBase()
    • 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
        Overrides:
        initializeEmbeddedConnectors in class OpenMetadataTopicConsumerBase
        Parameters:
        embeddedConnectors - list of connectors
      • processEvent

        public abstract void processEvent​(java.lang.String event)
        Method to pass an event received on topic.
        Specified by:
        processEvent in interface OpenMetadataTopicListener
        Parameters:
        event - inbound event
      • getEventBean

        protected <T> T getEventBean​(java.lang.String event,
                                     java.lang.Class<T> eventClass)
                              throws java.lang.Exception
        Parse the event and return it to a Java bean.
        Type Parameters:
        T - the name of the class
        Parameters:
        event - event as a String
        eventClass - class of the Java bean.
        Returns:
        Java bean
        Throws:
        java.lang.Exception - something went wrong in the parsing process.