Class BaseUIMAAsynchronousEngineCommon_impl.SharedConnection

    • Constructor Detail

      • SharedConnection

        public SharedConnection​(javax.jms.ConnectionFactory connectionFactory,
                                java.lang.String brokerURL)
    • Method Detail

      • getBroker

        public java.lang.String getBroker()
      • setConnectionValidator

        public void setConnectionValidator​(ConnectionValidator validator)
      • isOpen

        public boolean isOpen()
      • isConnectionValid

        public boolean isConnectionValid()
      • create

        public void create()
                    throws java.lang.Exception
        Using jndi context look the connection factory and attempt to create broker connection. Throws exception if not successfull.
        Throws:
        java.lang.Exception
      • retryConnectionUntilSuccessfull

        public void retryConnectionUntilSuccessfull()
      • start

        public void start()
                   throws java.lang.Exception
        Throws:
        java.lang.Exception
      • getConnection

        public javax.jms.Connection getConnection()
      • setConnection

        public void setConnection​(javax.jms.Connection connection)
      • getClientCount

        public int getClientCount()
      • destroy

        public boolean destroy()
        This method is called from stop(). It will stop the shared connection if all of the clients have already terminated
        Returns: