JMSConnector is an abstract class that encapsulates the work of connecting
to JMS destinations. Its subclasses are TopicConnector and QueueConnector
which further specialize connections to the pub-sub and the ptp domains.
It also implements the capability to retry connections in the event of
failures.
m_allowReceive
protected boolean m_allowReceive
m_connectRetryInterval
protected long m_connectRetryInterval
m_interactRetryInterval
protected long m_interactRetryInterval
m_numRetries
protected int m_numRetries
m_numSessions
protected int m_numSessions
m_poolTimeout
protected long m_poolTimeout
m_timeoutTime
protected long m_timeoutTime
JMSConnector
public JMSConnector(ConnectionFactory connectionFactory,
int numRetries,
int numSessions,
long connectRetryInterval,
long interactRetryInterval,
long timeoutTime,
boolean allowReceive,
String clientID,
String username,
String password,
JMSVendorAdapter adapter,
JMSURLHelper jmsurl)
throws JMSException
createAsyncConnection
protected abstract JMSConnector.AsyncConnection createAsyncConnection(ConnectionFactory factory,
javax.jms.Connection connection,
String threadName,
String clientID,
String username,
String password)
throws JMSException
createConnectionWithRetry
protected javax.jms.Connection createConnectionWithRetry(ConnectionFactory connectionFactory,
String username,
String password)
throws JMSException
createEndpoint
public abstract JMSEndpoint createEndpoint(Destination destination)
throws JMSException
createEndpoint
public abstract JMSEndpoint createEndpoint(String destinationName)
throws JMSException
createSyncConnection
protected abstract JMSConnector.SyncConnection createSyncConnection(ConnectionFactory factory,
javax.jms.Connection connection,
int numSessions,
String threadName,
String clientID,
String username,
String password)
throws JMSException
getClientID
public String getClientID()
getConnectionFactory
public ConnectionFactory getConnectionFactory()
getNumRetries
public int getNumRetries()
getPassword
public String getPassword()
getUsername
public String getUsername()
internalConnect
protected abstract javax.jms.Connection internalConnect(ConnectionFactory connectionFactory,
String username,
String password)
throws JMSException
numSessions
public int numSessions()
shutdown
public void shutdown()