org.apache.axis.transport.jms
Class JMSConnector
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) Ray Chun (rchun@sonicsoftware.com)
Constructor Summary |
| 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) |
Method Summary |
protected abstract JMSConnector.AsyncConnection | createAsyncConnection(ConnectionFactory factory, Connection connection, String threadName, String clientID, String username, String password) |
protected Connection | createConnectionWithRetry(ConnectionFactory connectionFactory, String username, String password) |
abstract JMSEndpoint | createEndpoint(String destinationName) |
abstract JMSEndpoint | createEndpoint(Destination destination) |
protected abstract JMSConnector.SyncConnection | createSyncConnection(ConnectionFactory factory, Connection connection, int numSessions, String threadName, String clientID, String username, String password) |
String | getClientID() |
ConnectionFactory | getConnectionFactory() |
JMSURLHelper | getJMSURL() |
int | getNumRetries() |
String | getPassword() |
String | getUsername() |
JMSVendorAdapter | getVendorAdapter() |
protected abstract Connection | internalConnect(ConnectionFactory connectionFactory, String username, String password) |
int | numSessions() |
void | shutdown() |
void | start() |
void | stop() |
protected boolean m_allowReceive
protected long m_connectRetryInterval
protected long m_interactRetryInterval
protected int m_numRetries
protected int m_numSessions
protected long m_poolTimeout
protected long m_timeoutTime
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)
protected abstract
JMSConnector.
AsyncConnection createAsyncConnection(ConnectionFactory factory, Connection connection, String threadName, String clientID, String username, String password)
protected Connection createConnectionWithRetry(ConnectionFactory connectionFactory, String username, String password)
public abstract
JMSEndpoint createEndpoint(String destinationName)
public abstract
JMSEndpoint createEndpoint(Destination destination)
protected abstract
JMSConnector.
SyncConnection createSyncConnection(ConnectionFactory factory, Connection connection, int numSessions, String threadName, String clientID, String username, String password)
public String getClientID()
public ConnectionFactory getConnectionFactory()
public int getNumRetries()
public String getPassword()
public String getUsername()
protected abstract Connection internalConnect(ConnectionFactory connectionFactory, String username, String password)
public int numSessions()
public void shutdown()
public void start()
public void stop()
Copyright B) 2005 Apache Web Services Project. All Rights Reserved.