Class BaseUIMAAsynchronousEngineCommon_impl.SharedConnection
java.lang.Object
org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl.SharedConnection
- Enclosing class:
- BaseUIMAAsynchronousEngineCommon_impl
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic enum -
Constructor Summary
ConstructorsConstructorDescriptionSharedConnection(javax.jms.ConnectionFactory connectionFactory, String brokerURL) -
Method Summary
Modifier and TypeMethodDescriptionvoidcreate()Using jndi context look the connection factory and attempt to create broker connection.booleandestroy()This method is called from stop().intjavax.jms.ConnectiongetState()booleanbooleanisOpen()voidvoidvoidsetConnection(javax.jms.Connection connection) voidsetConnectionValidator(ConnectionValidator validator) voidstart()void
-
Constructor Details
-
SharedConnection
-
-
Method Details
-
getBroker
-
setConnectionValidator
-
isOpen
public boolean isOpen() -
isConnectionValid
public boolean isConnectionValid() -
create
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
- Throws:
Exception
-
getState
-
getConnection
public javax.jms.Connection getConnection() -
setConnection
public void setConnection(javax.jms.Connection connection) -
registerClient
-
unregisterClient
-
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:
-