Class AbstractConnectionFactory

  • All Implemented Interfaces:
    adams.core.Destroyable, adams.core.GlobalInfoSupporter, adams.core.logging.LoggingLevelHandler, adams.core.logging.LoggingSupporter, adams.core.option.OptionHandler, adams.core.QuickInfoSupporter, adams.core.SizeOfHandler, adams.flow.core.FlowContextHandler, Serializable
    Direct Known Subclasses:
    BasicAuthConnectionFactory, GuestConnectionFactory, NonValidatingSSLConnectionFactory, SSLConnectionFactory

    public abstract class AbstractConnectionFactory
    extends adams.core.option.AbstractOptionHandler
    implements adams.core.QuickInfoSupporter, adams.flow.core.FlowContextHandler
    Ancestor for RabbitMQ connection factory objects.
    Author:
    FracPete (fracpete at waikato dot ac dot nz)
    See Also:
    Serialized Form
    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected adams.flow.core.Actor m_FlowContext
      the flow context.
      • Fields inherited from class adams.core.option.AbstractOptionHandler

        m_OptionManager
      • Fields inherited from class adams.core.logging.LoggingObject

        m_Logger, m_LoggingIsEnabled, m_LoggingLevel
    • Method Summary

      All Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method Description
      protected String check()
      Hook method for performing checks.
      protected abstract com.rabbitmq.client.ConnectionFactory doGenerate​(adams.core.MessageCollection errors)
      Generates the connection factory object.
      com.rabbitmq.client.ConnectionFactory generate​(adams.core.MessageCollection errors)
      Generates the connection factory object.
      adams.flow.core.Actor getFlowContext()
      Returns the flow context, if any.
      String getQuickInfo()
      Returns a quick info about the object, which can be displayed in the GUI.
      protected abstract boolean requiresFlowContext()
      Returns whether a flow context is required.
      void setFlowContext​(adams.flow.core.Actor value)
      Sets the flow context.
      • Methods inherited from class adams.core.option.AbstractOptionHandler

        cleanUpOptions, defineOptions, destroy, finishInit, getDefaultLoggingLevel, getOptionManager, globalInfo, initialize, loggingLevelTipText, newOptionManager, reset, setLoggingLevel, toCommandLine, toString
      • Methods inherited from class adams.core.logging.LoggingObject

        configureLogger, getLogger, getLoggingLevel, initializeLogging, isLoggingEnabled, sizeOf
      • Methods inherited from interface adams.core.logging.LoggingLevelHandler

        getLoggingLevel
    • Field Detail

      • m_FlowContext

        protected adams.flow.core.Actor m_FlowContext
        the flow context.
    • Constructor Detail

      • AbstractConnectionFactory

        public AbstractConnectionFactory()
    • Method Detail

      • setFlowContext

        public void setFlowContext​(adams.flow.core.Actor value)
        Sets the flow context.
        Specified by:
        setFlowContext in interface adams.flow.core.FlowContextHandler
        Parameters:
        value - the actor
      • getFlowContext

        public adams.flow.core.Actor getFlowContext()
        Returns the flow context, if any.
        Specified by:
        getFlowContext in interface adams.flow.core.FlowContextHandler
        Returns:
        the actor, null if none available
      • getQuickInfo

        public String getQuickInfo()
        Returns a quick info about the object, which can be displayed in the GUI.
        Default implementation returns null.
        Specified by:
        getQuickInfo in interface adams.core.QuickInfoSupporter
        Returns:
        null if no info available, otherwise short string
      • requiresFlowContext

        protected abstract boolean requiresFlowContext()
        Returns whether a flow context is required.
        Returns:
        true if required
      • check

        protected String check()
        Hook method for performing checks.
        Returns:
        null if successful, otherwise error message
      • doGenerate

        protected abstract com.rabbitmq.client.ConnectionFactory doGenerate​(adams.core.MessageCollection errors)
        Generates the connection factory object.
        Parameters:
        errors - for collecting errors
        Returns:
        the factory, null in case of error
      • generate

        public com.rabbitmq.client.ConnectionFactory generate​(adams.core.MessageCollection errors)
        Generates the connection factory object.
        Parameters:
        errors - for collecting errors
        Returns:
        the factory, null in case of error