| java.lang.Object org.objectweb.jonas_jms.JConnection org.objectweb.jonas_jms.JQueueConnection
JQueueConnection | public class JQueueConnection extends JConnection implements QueueConnection(Code) | | author: Laurent Chauvirey, Frederic Maistre, Nicolas Tachker author: Contributor(s): author: Philippe Durieux author: Jeff Mesnil |
Field Summary | |
protected XAQueueConnection | xaqc |
Method Summary | |
public ConnectionConsumer | createConnectionConsumer(Queue queue, String selector, ServerSessionPool pool, int maxmessages) Create a connection consumer for this connection
Parameters: queue - - the queue to access Parameters: selector - - only messages with properties matching the messageselector expression aredelivered Parameters: sessionPool - - the server session pool to associate with this connection consumer. Parameters: maxMessages - - the maximum number of messages that can be assignedto a server session at one time. | public QueueSession | createQueueSession(boolean transacted, int acknowledgeMode) Create a Queue Session
Parameters: transacted - - if true, the session is transacted. Parameters: acknowledgeMode - - indicates whether the consumer or the client will acknowledge any messages it receives.This parameter will be ignored if the session is transacted. |
xaqc | protected XAQueueConnection xaqc(Code) | | |
JQueueConnection | public JQueueConnection(JConnectionFactory jcf, XAQueueConnectionFactory xaqcf, String user, String passwd) throws JMSException(Code) | | Constructor of a JQueueConnection for a specified user.
Parameters: user - user's name Parameters: passwd - user's password |
JQueueConnection | public JQueueConnection(JConnectionFactory jcf, XAQueueConnectionFactory xaqcf) throws JMSException(Code) | | Constructor of a JQueueConnection for an anonymous user.
|
createConnectionConsumer | public ConnectionConsumer createConnectionConsumer(Queue queue, String selector, ServerSessionPool pool, int maxmessages) throws JMSException(Code) | | Create a connection consumer for this connection
Parameters: queue - - the queue to access Parameters: selector - - only messages with properties matching the messageselector expression aredelivered Parameters: sessionPool - - the server session pool to associate with this connection consumer. Parameters: maxMessages - - the maximum number of messages that can be assignedto a server session at one time. the connection consumer. throws: JMSException - - if JMS Connection fails to create a a connection consumerdue to some internal error or invalid arguments for sessionPool and message selector. throws: InvalidSelectorException - - if the message selector is invalid. |
createQueueSession | public QueueSession createQueueSession(boolean transacted, int acknowledgeMode) throws JMSException(Code) | | Create a Queue Session
Parameters: transacted - - if true, the session is transacted. Parameters: acknowledgeMode - - indicates whether the consumer or the client will acknowledge any messages it receives.This parameter will be ignored if the session is transacted. a newly created queue session. throws: JMSException - - if JMS Connection fails to create a session. |
|
|