QueueConnection

WebSphere MQ class: MQQueueConnection

java.lang.Object
   |
   +----com.ibm.mq.jms.MQConnection
           |
           +----com.ibm.mq.jms.MQQueueConnection

A QueueConnection is an active connection to a JMS point-to-point provider. A client uses a QueueConnection to create one or more QueueSessions for producing and consuming messages.

See also: Connection, QueueConnectionFactory, and XAQueueConnection

Methods

close *

public void close() throws JMSException

Overrides:

close in class MQConnection.

createConnectionConsumer

public ConnectionConsumer createConnectionConsumer
                                    (Queue queue,
                                     java.lang.String messageSelector,
                                     ServerSessionPool sessionPool,
                                     int maxMessages)
                                                 throws JMSException

Create a connection consumer for this connection. This is an expert facility that is not used by regular JMS clients.

Parameters:

• queue - the queue to access.
• messageSelector - only messages with properties that match the message selector expression are delivered.
• sessionPool - the server session pool to associate with this connection consumer.
• maxMessages - the maximum number of messages that can be assigned to a server session at one time.

Returns:

the connection consumer.

Throws:

• JMSException - if the JMS Connection fails to create a connection consumer because of an internal error, or incorrect arguments for sessionPool and messageSelector.
• InvalidSelectorException - if the message selector is not valid.

See Also:

ConnectionConsumer

createQueueSession

public QueueSession createQueueSession(boolean transacted,
                                       int acknowledgeMode)
                                                     throws JMSException

Create a QueueSession.

Parameters:

• transacted - if true, the session is transacted.
• acknowledgeMode - indicates whether the consumer or the client will acknowledge any messages it receives. Possible values are:

  Session.AUTO_ACKNOWLEDGE

  Session.CLIENT_ACKNOWLEDGE

  Session.DUPS_OK_ACKNOWLEDGE

  This parameter is ignored if the session is transacted.

Returns:

a newly created queue session.

Throws:

JMSException - if JMS Connection fails to create a session because of an internal error, or lack of support for specific transaction and acknowledgement mode.