public static class BaseUIMAAsynchronousEngineCommon_impl.SharedConnection extends Object
Modifier and Type | Class and Description |
---|---|
static class |
BaseUIMAAsynchronousEngineCommon_impl.SharedConnection.ConnectionState |
Constructor and Description |
---|
SharedConnection(javax.jms.ConnectionFactory connectionFactory,
String brokerURL) |
Modifier and Type | Method and Description |
---|---|
void |
create()
Using jndi context look the connection factory and
attempt to create broker connection.
|
boolean |
destroy()
This method is called from stop().
|
String |
getBroker() |
int |
getClientCount() |
javax.jms.Connection |
getConnection() |
BaseUIMAAsynchronousEngineCommon_impl.SharedConnection.ConnectionState |
getState() |
boolean |
isConnectionValid() |
boolean |
isOpen() |
void |
registerClient(BaseUIMAAsynchronousEngineCommon_impl client) |
void |
retryConnectionUntilSuccessfull() |
void |
setConnection(javax.jms.Connection connection) |
void |
setConnectionValidator(ConnectionValidator validator) |
void |
start() |
void |
unregisterClient(BaseUIMAAsynchronousEngineCommon_impl client) |
public SharedConnection(javax.jms.ConnectionFactory connectionFactory, String brokerURL)
public String getBroker()
public void setConnectionValidator(ConnectionValidator validator)
public boolean isOpen()
public boolean isConnectionValid()
public void create() throws Exception
Exception
public void retryConnectionUntilSuccessfull()
public BaseUIMAAsynchronousEngineCommon_impl.SharedConnection.ConnectionState getState()
public javax.jms.Connection getConnection()
public void setConnection(javax.jms.Connection connection)
public void registerClient(BaseUIMAAsynchronousEngineCommon_impl client)
public void unregisterClient(BaseUIMAAsynchronousEngineCommon_impl client)
public int getClientCount()
public boolean destroy()
Copyright © 2016. All rights reserved.