Package org.apache.axis.transport.jms
Class JMSConnector
java.lang.Object
org.apache.axis.transport.jms.JMSConnector
- Direct Known Subclasses:
QueueConnector
,TopicConnector
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.
- Author:
- Jaime Meritt (jmeritt@sonicsoftware.com), Richard Chung (rchung@sonicsoftware.com), Dave Chappell (chappell@sonicsoftware.com), Ray Chun (rchun@sonicsoftware.com)
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprotected class
protected class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected JMSVendorAdapter
protected boolean
protected long
protected long
protected JMSURLHelper
protected int
protected int
protected long
protected JMSConnector.AsyncConnection
protected JMSConnector.SyncConnection
protected long
-
Constructor Summary
ConstructorsConstructorDescriptionJMSConnector
(ConnectionFactory connectionFactory, int numRetries, int numSessions, long connectRetryInterval, long interactRetryInterval, long timeoutTime, boolean allowReceive, String clientID, String username, String password, JMSVendorAdapter adapter, JMSURLHelper jmsurl) -
Method Summary
Modifier and TypeMethodDescriptionprotected abstract JMSConnector.AsyncConnection
createAsyncConnection
(ConnectionFactory factory, javax.jms.Connection connection, String threadName, String clientID, String username, String password) protected javax.jms.Connection
createConnectionWithRetry
(ConnectionFactory connectionFactory, String username, String password) abstract JMSEndpoint
createEndpoint
(Destination destination) abstract JMSEndpoint
createEndpoint
(String destinationName) protected abstract JMSConnector.SyncConnection
createSyncConnection
(ConnectionFactory factory, javax.jms.Connection connection, int numSessions, String threadName, String clientID, String username, String password) ConnectionFactory
int
protected abstract javax.jms.Connection
internalConnect
(ConnectionFactory connectionFactory, String username, String password) int
void
shutdown()
void
start()
void
stop()
-
Field Details
-
m_numRetries
protected int m_numRetries -
m_connectRetryInterval
protected long m_connectRetryInterval -
m_interactRetryInterval
protected long m_interactRetryInterval -
m_timeoutTime
protected long m_timeoutTime -
m_poolTimeout
protected long m_poolTimeout -
m_receiveConnection
-
m_sendConnection
-
m_numSessions
protected int m_numSessions -
m_allowReceive
protected boolean m_allowReceive -
m_adapter
-
m_jmsurl
-
-
Constructor Details
-
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 - Throws:
JMSException
-
-
Method Details
-
getNumRetries
public int getNumRetries() -
numSessions
public int numSessions() -
getConnectionFactory
public ConnectionFactory getConnectionFactory() -
getClientID
-
getUsername
-
getPassword
-
getVendorAdapter
-
getJMSURL
-
createConnectionWithRetry
protected javax.jms.Connection createConnectionWithRetry(ConnectionFactory connectionFactory, String username, String password) throws JMSException - Throws:
JMSException
-
stop
public void stop() -
start
public void start() -
shutdown
public void shutdown() -
createEndpoint
- Throws:
JMSException
-
createEndpoint
- Throws:
JMSException
-
internalConnect
protected abstract javax.jms.Connection internalConnect(ConnectionFactory connectionFactory, String username, String password) throws JMSException - 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 - Throws:
JMSException
-
createAsyncConnection
protected abstract JMSConnector.AsyncConnection createAsyncConnection(ConnectionFactory factory, javax.jms.Connection connection, String threadName, String clientID, String username, String password) throws JMSException - Throws:
JMSException
-