org.apache.axis.transport.jms

Class JMSConnector

Known Direct Subclasses:
QueueConnector, TopicConnector

public abstract class JMSConnector
extends java.lang.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.

Authors:
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 class
JMSConnector.AsyncConnection
protected abstract class
JMSConnector.SyncConnection

Field Summary

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 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 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)
JMSEndpoint
createEndpoint(Destination destination)
JMSEndpoint
createEndpoint(String destinationName)
protected JMSConnector.SyncConnection
createSyncConnection(ConnectionFactory factory, javax.jms.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 javax.jms.Connection
internalConnect(ConnectionFactory connectionFactory, String username, String password)
int
numSessions()
void
shutdown()
void
start()
void
stop()

Field Details

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 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

Method Details

createAsyncConnection

protected JMSConnector.AsyncConnection createAsyncConnection(ConnectionFactory factory,
                                                             javax.jms.Connection connection,
                                                             String threadName,
                                                             String clientID,
                                                             String username,
                                                             String password)
            throws JMSException


createConnectionWithRetry

protected javax.jms.Connection createConnectionWithRetry(ConnectionFactory connectionFactory,
                                                         String username,
                                                         String password)
            throws JMSException


createEndpoint

public JMSEndpoint createEndpoint(Destination destination)
            throws JMSException


createEndpoint

public JMSEndpoint createEndpoint(String destinationName)
            throws JMSException


createSyncConnection

protected JMSConnector.SyncConnection createSyncConnection(ConnectionFactory factory,
                                                           javax.jms.Connection connection,
                                                           int numSessions,
                                                           String threadName,
                                                           String clientID,
                                                           String username,
                                                           String password)
            throws JMSException


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 javax.jms.Connection internalConnect(ConnectionFactory connectionFactory,
                                               String username,
                                               String password)
            throws JMSException


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.