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)

Nested Class Summary
protected abstract classJMSConnector.AsyncConnection
protected abstract classJMSConnector.SyncConnection
Field Summary
protected JMSVendorAdapterm_adapter
protected booleanm_allowReceive
protected longm_connectRetryInterval
protected longm_interactRetryInterval
protected JMSURLHelperm_jmsurl
protected intm_numRetries
protected intm_numSessions
protected longm_poolTimeout
protected JMSConnector.AsyncConnectionm_receiveConnection
protected JMSConnector.SyncConnectionm_sendConnection
protected longm_timeoutTime
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.AsyncConnectioncreateAsyncConnection(ConnectionFactory factory, Connection connection, String threadName, String clientID, String username, String password)
protected ConnectioncreateConnectionWithRetry(ConnectionFactory connectionFactory, String username, String password)
abstract JMSEndpointcreateEndpoint(String destinationName)
abstract JMSEndpointcreateEndpoint(Destination destination)
protected abstract JMSConnector.SyncConnectioncreateSyncConnection(ConnectionFactory factory, Connection connection, int numSessions, String threadName, String clientID, String username, String password)
StringgetClientID()
ConnectionFactorygetConnectionFactory()
JMSURLHelpergetJMSURL()
intgetNumRetries()
StringgetPassword()
StringgetUsername()
JMSVendorAdaptergetVendorAdapter()
protected abstract ConnectioninternalConnect(ConnectionFactory connectionFactory, String username, String password)
intnumSessions()
voidshutdown()
voidstart()
voidstop()

Field Detail

m_adapter

protected JMSVendorAdapter m_adapter

m_allowReceive

protected boolean m_allowReceive

m_connectRetryInterval

protected long m_connectRetryInterval

m_interactRetryInterval

protected long m_interactRetryInterval

m_jmsurl

protected JMSURLHelper m_jmsurl

m_numRetries

protected int m_numRetries

m_numSessions

protected int m_numSessions

m_poolTimeout

protected long m_poolTimeout

m_receiveConnection

protected JMSConnector.AsyncConnection m_receiveConnection

m_sendConnection

protected JMSConnector.SyncConnection m_sendConnection

m_timeoutTime

protected long m_timeoutTime

Constructor Detail

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)

Method Detail

createAsyncConnection

protected abstract JMSConnector.AsyncConnection createAsyncConnection(ConnectionFactory factory, Connection connection, String threadName, String clientID, String username, String password)

createConnectionWithRetry

protected Connection createConnectionWithRetry(ConnectionFactory connectionFactory, String username, String password)

createEndpoint

public abstract JMSEndpoint createEndpoint(String destinationName)

createEndpoint

public abstract JMSEndpoint createEndpoint(Destination destination)

createSyncConnection

protected abstract JMSConnector.SyncConnection createSyncConnection(ConnectionFactory factory, Connection connection, int numSessions, String threadName, String clientID, String username, String password)

getClientID

public String getClientID()

getConnectionFactory

public ConnectionFactory getConnectionFactory()

getJMSURL

public JMSURLHelper getJMSURL()

getNumRetries

public int getNumRetries()

getPassword

public String getPassword()

getUsername

public String getUsername()

getVendorAdapter

public JMSVendorAdapter getVendorAdapter()

internalConnect

protected abstract Connection internalConnect(ConnectionFactory connectionFactory, String username, String password)

numSessions

public int numSessions()

shutdown

public void shutdown()

start

public void start()

stop

public void stop()
Copyright B) 2005 Apache Web Services Project. All Rights Reserved.