File	Doc	Category	Size	Date	Package
QueueConnector.java	API Doc	Apache Axis 1.4	10253	Sat Apr 22 18:57:26 BST 2006	org.apache.axis.transport.jms

QueueConnector

• java.lang.Object
  • JMSConnector

Fields Summary

Constructors Summary

public QueueConnector(javax.jms.ConnectionFactory factory, int numRetries, int numSessions, long connectRetryInterval, long interactRetryInterval, long timeoutTime, boolean allowReceive, String clientID, String username, String password, org.apache.axis.components.jms.JMSVendorAdapter adapter, JMSURLHelper jmsurl) super(factory, numRetries, numSessions, connectRetryInterval, interactRetryInterval, timeoutTime, allowReceive, clientID, username, password, adapter, jmsurl);

Methods Summary
protected AsyncConnection	createAsyncConnection(javax.jms.ConnectionFactory factory, javax.jms.Connection connection, java.lang.String threadName, java.lang.String clientID, java.lang.String username, java.lang.String password) return new QueueAsyncConnection((QueueConnectionFactory)factory, (QueueConnection)connection, threadName, clientID, username, password);
public JMSEndpoint	createEndpoint(java.lang.String destination) return new QueueEndpoint(destination);
public JMSEndpoint	createEndpoint(javax.jms.Destination destination) Create an endpoint for a queue destination. param destination return throws JMSException if(!(destination instanceof Queue)) throw new IllegalArgumentException("The input must be a queue for this connector"); return new QueueDestinationEndpoint((Queue)destination);
private javax.jms.Queue	createQueue(javax.jms.QueueSession session, java.lang.String subject) return m_adapter.getQueue(session, subject);
private javax.jms.QueueSession	createQueueSession(javax.jms.QueueConnection connection, int ackMode) return connection.createQueueSession(false, ackMode);
private javax.jms.QueueReceiver	createReceiver(javax.jms.QueueSession session, javax.jms.Queue queue, java.lang.String messageSelector) return session.createReceiver(queue, messageSelector);
protected SyncConnection	createSyncConnection(javax.jms.ConnectionFactory factory, javax.jms.Connection connection, int numSessions, java.lang.String threadName, java.lang.String clientID, java.lang.String username, java.lang.String password) return new QueueSyncConnection((QueueConnectionFactory)factory, (QueueConnection)connection, numSessions, threadName, clientID, username, password);
protected javax.jms.Connection	internalConnect(javax.jms.ConnectionFactory connectionFactory, java.lang.String username, java.lang.String password) QueueConnectionFactory qcf = (QueueConnectionFactory)connectionFactory; if(username == null) return qcf.createQueueConnection(); return qcf.createQueueConnection(username, password);