public abstract class JMSConnector
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
protected class |
JMSConnector.AsyncConnection |
protected class |
JMSConnector.SyncConnection |
Modifier and Type | Field and Description |
---|---|
protected JMSVendorAdapter |
m_adapter |
protected boolean |
m_allowReceive |
protected long |
m_connectRetryInterval |
protected long |
m_interactRetryInterval |
protected JMSURLHelper |
m_jmsurl |
protected int |
m_numRetries |
protected int |
m_numSessions |
protected long |
m_poolTimeout |
protected JMSConnector.AsyncConnection |
m_receiveConnection |
protected JMSConnector.SyncConnection |
m_sendConnection |
protected long |
m_timeoutTime |
Constructor and Description |
---|
JMSConnector(ConnectionFactory connectionFactory,
int numRetries,
int numSessions,
long connectRetryInterval,
long interactRetryInterval,
long timeoutTime,
boolean allowReceive,
java.lang.String clientID,
java.lang.String username,
java.lang.String password,
JMSVendorAdapter adapter,
JMSURLHelper jmsurl) |
Modifier and Type | Method and Description |
---|---|
protected abstract JMSConnector.AsyncConnection |
createAsyncConnection(ConnectionFactory factory,
javax.jms.Connection connection,
java.lang.String threadName,
java.lang.String clientID,
java.lang.String username,
java.lang.String password) |
protected javax.jms.Connection |
createConnectionWithRetry(ConnectionFactory connectionFactory,
java.lang.String username,
java.lang.String password) |
abstract JMSEndpoint |
createEndpoint(Destination destination) |
abstract JMSEndpoint |
createEndpoint(java.lang.String destinationName) |
protected abstract JMSConnector.SyncConnection |
createSyncConnection(ConnectionFactory factory,
javax.jms.Connection connection,
int numSessions,
java.lang.String threadName,
java.lang.String clientID,
java.lang.String username,
java.lang.String password) |
java.lang.String |
getClientID() |
ConnectionFactory |
getConnectionFactory() |
JMSURLHelper |
getJMSURL() |
int |
getNumRetries() |
java.lang.String |
getPassword() |
java.lang.String |
getUsername() |
JMSVendorAdapter |
getVendorAdapter() |
protected abstract javax.jms.Connection |
internalConnect(ConnectionFactory connectionFactory,
java.lang.String username,
java.lang.String password) |
int |
numSessions() |
void |
shutdown() |
void |
start() |
void |
stop() |
protected int m_numRetries
protected long m_connectRetryInterval
protected long m_interactRetryInterval
protected long m_timeoutTime
protected long m_poolTimeout
protected JMSConnector.AsyncConnection m_receiveConnection
protected JMSConnector.SyncConnection m_sendConnection
protected int m_numSessions
protected boolean m_allowReceive
protected JMSVendorAdapter m_adapter
protected JMSURLHelper m_jmsurl
public JMSConnector(ConnectionFactory connectionFactory, int numRetries, int numSessions, long connectRetryInterval, long interactRetryInterval, long timeoutTime, boolean allowReceive, java.lang.String clientID, java.lang.String username, java.lang.String password, JMSVendorAdapter adapter, JMSURLHelper jmsurl) throws JMSException
JMSException
public int getNumRetries()
public int numSessions()
public ConnectionFactory getConnectionFactory()
public java.lang.String getClientID()
public java.lang.String getUsername()
public java.lang.String getPassword()
public JMSVendorAdapter getVendorAdapter()
public JMSURLHelper getJMSURL()
protected javax.jms.Connection createConnectionWithRetry(ConnectionFactory connectionFactory, java.lang.String username, java.lang.String password) throws JMSException
JMSException
public void stop()
public void start()
public void shutdown()
public abstract JMSEndpoint createEndpoint(java.lang.String destinationName) throws JMSException
JMSException
public abstract JMSEndpoint createEndpoint(Destination destination) throws JMSException
JMSException
protected abstract javax.jms.Connection internalConnect(ConnectionFactory connectionFactory, java.lang.String username, java.lang.String password) throws JMSException
JMSException
protected abstract JMSConnector.SyncConnection createSyncConnection(ConnectionFactory factory, javax.jms.Connection connection, int numSessions, java.lang.String threadName, java.lang.String clientID, java.lang.String username, java.lang.String password) throws JMSException
JMSException
protected abstract JMSConnector.AsyncConnection createAsyncConnection(ConnectionFactory factory, javax.jms.Connection connection, java.lang.String threadName, java.lang.String clientID, java.lang.String username, java.lang.String password) throws JMSException
JMSException
Copyright ? 2005 Apache Web Services Project. All Rights Reserved.