org.jboss.axis.transport.jms
Class QueueConnector
java.lang.Object
org.jboss.axis.transport.jms.JMSConnector (src)
org.jboss.axis.transport.jms.QueueConnector
- public class QueueConnector
- extends JMSConnector (src)
QueueConnector is a concrete JMSConnector subclass that specifically handles
connections to queues (ptp domain).
Constructor Summary |
QueueConnector(ConnectionFactory (src) factory,
int numRetries,
int numSessions,
long connectRetryInterval,
long interactRetryInterval,
long timeoutTime,
boolean allowReceive,
java.lang.String clientID,
java.lang.String username,
java.lang.String password,
JMSVendorAdapter (src) adapter)
|
Method Summary |
protected JMSConnector.AsyncConnection (src) |
createAsyncConnection(ConnectionFactory (src) factory,
Connection (src) connection,
java.lang.String threadName,
java.lang.String clientID,
java.lang.String username,
java.lang.String password)
|
JMSEndpoint (src) |
createEndpoint(Destination (src) destination)
Create an endpoint for a queue destination. |
JMSEndpoint (src) |
createEndpoint(java.lang.String destination)
|
protected JMSConnector.SyncConnection (src) |
createSyncConnection(ConnectionFactory (src) factory,
Connection (src) connection,
int numSessions,
java.lang.String threadName,
java.lang.String clientID,
java.lang.String username,
java.lang.String password)
|
protected Connection (src) |
internalConnect(ConnectionFactory (src) connectionFactory,
java.lang.String username,
java.lang.String password)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
QueueConnector
public QueueConnector(ConnectionFactory (src) factory,
int numRetries,
int numSessions,
long connectRetryInterval,
long interactRetryInterval,
long timeoutTime,
boolean allowReceive,
java.lang.String clientID,
java.lang.String username,
java.lang.String password,
JMSVendorAdapter (src) adapter)
throws JMSException (src)
createEndpoint
public JMSEndpoint (src) createEndpoint(java.lang.String destination)
- Specified by:
createEndpoint
in class JMSConnector (src)
createEndpoint
public JMSEndpoint (src) createEndpoint(Destination (src) destination)
throws JMSException (src)
- Create an endpoint for a queue destination.
- Specified by:
createEndpoint
in class JMSConnector (src)
- Parameters:
destination
-
- Returns:
-
- Throws:
JMSException (src)
internalConnect
protected Connection (src) internalConnect(ConnectionFactory (src) connectionFactory,
java.lang.String username,
java.lang.String password)
throws JMSException (src)
- Specified by:
internalConnect
in class JMSConnector (src)
- Throws:
JMSException (src)
createSyncConnection
protected JMSConnector.SyncConnection (src) createSyncConnection(ConnectionFactory (src) factory,
Connection (src) connection,
int numSessions,
java.lang.String threadName,
java.lang.String clientID,
java.lang.String username,
java.lang.String password)
throws JMSException (src)
- Specified by:
createSyncConnection
in class JMSConnector (src)
- Throws:
JMSException (src)
createAsyncConnection
protected JMSConnector.AsyncConnection (src) createAsyncConnection(ConnectionFactory (src) factory,
Connection (src) connection,
java.lang.String threadName,
java.lang.String clientID,
java.lang.String username,
java.lang.String password)
throws JMSException (src)
- Specified by:
createAsyncConnection
in class JMSConnector (src)
- Throws:
JMSException (src)