Class ConnectionAbstract

    • Field Detail

      • brokerURL

        protected java.lang.String brokerURL
      • acceptor

        protected java.lang.String acceptor
      • user

        protected java.lang.String user
      • password

        protected java.lang.String password
      • clientID

        protected java.lang.String clientID
      • protocol

        protected java.lang.String protocol
    • Constructor Detail

      • ConnectionAbstract

        public ConnectionAbstract()
    • Method Detail

      • getBrokerURL

        public java.lang.String getBrokerURL()
      • setBrokerURL

        public void setBrokerURL​(java.lang.String brokerURL)
      • getAcceptor

        public java.lang.String getAcceptor()
      • getUser

        public java.lang.String getUser()
      • getPassword

        public java.lang.String getPassword()
      • getClientID

        public java.lang.String getClientID()
      • getProtocol

        public java.lang.String getProtocol()
      • setProtocol

        public void setProtocol​(java.lang.String protocol)
      • createConnectionFactory

        protected javax.jms.ConnectionFactory createConnectionFactory()
                                                               throws java.lang.Exception
        Throws:
        java.lang.Exception
      • createConnectionFactory

        protected javax.jms.ConnectionFactory createConnectionFactory​(java.lang.String brokerURL,
                                                                      java.lang.String user,
                                                                      java.lang.String password,
                                                                      java.lang.String clientID,
                                                                      java.lang.String protocol)
                                                               throws java.lang.Exception
        Throws:
        java.lang.Exception
      • createCoreConnectionFactory

        protected org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory createCoreConnectionFactory()
      • createCoreConnectionFactory

        protected org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory createCoreConnectionFactory​(java.lang.String brokerURL,
                                                                                                               java.lang.String user,
                                                                                                               java.lang.String password,
                                                                                                               java.lang.String clientID)