当前页面: 在线文档首页 > JBoss 4.0.1 sp1 jaxrpc API Documentation 英文版文档
org.apache.axis.transport.jms
JMSConnector (JAXRPC API) - JBoss 4.0.1 sp1 jaxrpc API Documentation 英文版文档
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
org.apache.axis.transport.jms
Class JMSConnector
java.lang.Objectorg.apache.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)
| Nested Class Summary | |
protected class |
JMSConnector.AsyncConnection
|
protected class |
JMSConnector.SyncConnection
|
| Field Summary | |
protected JMSVendorAdapter |
m_adapter
|
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 JMSConnector.AsyncConnection |
m_receiveConnection
|
protected JMSConnector.SyncConnection |
m_sendConnection
|
protected long |
m_timeoutTime
|
| 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 |
| Field Detail |
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
| Constructor Detail |
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
| Method Detail |
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
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
Copyright © 2002 JBoss Group, LLC. All Rights Reserved.