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 TypeMethodDescriptionvoid
create()
Using jndi context look the connection factory and attempt to create broker connection.boolean
destroy()
This method is called from stop().int
javax.jms.Connection
getState()
boolean
boolean
isOpen()
void
void
void
setConnection
(javax.jms.Connection connection) void
setConnectionValidator
(ConnectionValidator validator) void
start()
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:
-