Class BaseUIMAAsynchronousEngineCommon_impl.SharedConnection

java.lang.Object
org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl.SharedConnection
Enclosing class:
BaseUIMAAsynchronousEngineCommon_impl

public static class BaseUIMAAsynchronousEngineCommon_impl.SharedConnection extends Object
  • Constructor Details

    • SharedConnection

      public SharedConnection(javax.jms.ConnectionFactory connectionFactory, String brokerURL)
  • Method Details

    • getBroker

      public String getBroker()
    • setConnectionValidator

      public void setConnectionValidator(ConnectionValidator validator)
    • isOpen

      public boolean isOpen()
    • isConnectionValid

      public boolean isConnectionValid()
    • create

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

      public void retryConnectionUntilSuccessfull()
    • start

      public void start() throws Exception
      Throws:
      Exception
    • getState

    • getConnection

      public javax.jms.Connection getConnection()
    • setConnection

      public void setConnection(javax.jms.Connection connection)
    • registerClient

      public void registerClient(BaseUIMAAsynchronousEngineCommon_impl client)
    • unregisterClient

      public void unregisterClient(BaseUIMAAsynchronousEngineCommon_impl client)
    • 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: