org.jboss.axis.transport.jms
Class JMSConnector
java.lang.Object
org.jboss.axis.transport.jms.JMSConnector
- Direct Known Subclasses:
- QueueConnector, TopicConnector
public abstract class JMSConnector
- extends Object
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)
Constructor Summary |
JMSConnector(javax.jms.ConnectionFactory connectionFactory,
int numRetries,
int numSessions,
long connectRetryInterval,
long interactRetryInterval,
long timeoutTime,
boolean allowReceive,
String clientID,
String username,
String password,
JMSVendorAdapter adapter)
|
Method Summary |
protected abstract JMSConnector.AsyncConnection |
createAsyncConnection(javax.jms.ConnectionFactory factory,
javax.jms.Connection connection,
String threadName,
String clientID,
String username,
String password)
|
protected javax.jms.Connection |
createConnectionWithRetry(javax.jms.ConnectionFactory connectionFactory,
String username,
String password)
|
abstract JMSEndpoint |
createEndpoint(javax.jms.Destination destination)
|
abstract JMSEndpoint |
createEndpoint(String destinationName)
|
protected abstract JMSConnector.SyncConnection |
createSyncConnection(javax.jms.ConnectionFactory factory,
javax.jms.Connection connection,
int numSessions,
String threadName,
String clientID,
String username,
String password)
|
protected abstract javax.jms.Connection |
internalConnect(javax.jms.ConnectionFactory connectionFactory,
String username,
String password)
|
void |
shutdown()
|
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
protected JMSConnector.AsyncConnection m_receiveConnection
m_sendConnection
protected JMSConnector.SyncConnection m_sendConnection
m_numSessions
protected int m_numSessions
m_allowReceive
protected boolean m_allowReceive
m_adapter
protected JMSVendorAdapter m_adapter
JMSConnector
public JMSConnector(javax.jms.ConnectionFactory connectionFactory,
int numRetries,
int numSessions,
long connectRetryInterval,
long interactRetryInterval,
long timeoutTime,
boolean allowReceive,
String clientID,
String username,
String password,
JMSVendorAdapter adapter)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
createConnectionWithRetry
protected javax.jms.Connection createConnectionWithRetry(javax.jms.ConnectionFactory connectionFactory,
String username,
String password)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
stop
public void stop()
start
public void start()
shutdown
public void shutdown()
createEndpoint
public abstract JMSEndpoint createEndpoint(String destinationName)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
createEndpoint
public abstract JMSEndpoint createEndpoint(javax.jms.Destination destination)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
internalConnect
protected abstract javax.jms.Connection internalConnect(javax.jms.ConnectionFactory connectionFactory,
String username,
String password)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
createSyncConnection
protected abstract JMSConnector.SyncConnection createSyncConnection(javax.jms.ConnectionFactory factory,
javax.jms.Connection connection,
int numSessions,
String threadName,
String clientID,
String username,
String password)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
createAsyncConnection
protected abstract JMSConnector.AsyncConnection createAsyncConnection(javax.jms.ConnectionFactory factory,
javax.jms.Connection connection,
String threadName,
String clientID,
String username,
String password)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
Copyright © 2002 JBoss Group, LLC. All Rights Reserved.