com.ibm.mq.jms

Class MQQueueConnection

java.lang.Object

com.ibm.mq.jms.MQRoot

com.ibm.mq.jms.MQConnection

com.ibm.mq.jms.MQQueueConnection

All Implemented Interfaces:

JmsConnection, JmsPropertyContext, JmsQueueConnection, JmsReadablePropertyContext, java.io.Serializable, java.lang.AutoCloseable, java.util.Map<java.lang.String,java.lang.Object>, javax.jms.Connection, javax.jms.QueueConnection

Direct Known Subclasses:

MQXAQueueConnection

public class MQQueueConnection
extends MQConnection
implements javax.jms.QueueConnection, JmsQueueConnection

An MQueueConnection is an active connection to a JMS point-to-point provider. A client uses an MQQueueConnection to create one or more MQQueueSessions for producing and consuming messages.

See Also:

Connection, QueueConnectionFactory, XAQueueConnection, Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.Map

java.util.Map.Entry<K,V>

Method Summary

Modifier and Type	Method and Description
javax.jms.ConnectionConsumer	createConnectionConsumer(javax.jms.Queue queue, java.lang.String selector, javax.jms.ServerSessionPool sessionPool, int maxMessages) Creates a connection consumer for this connection.
javax.jms.QueueSession	createQueueSession(boolean transacted, int acknowledgeMode) Creates an MQQueueSession object.

Methods inherited from class com.ibm.mq.jms.MQConnection

close, createConnectionConsumer, createDurableConnectionConsumer, createSession, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop

Methods inherited from class com.ibm.mq.jms.MQRoot

clear, containsKey, containsValue, entrySet, equals, get, getBooleanProperty, getByteProperty, getBytesProperty, getCharProperty, getDoubleProperty, getFloatProperty, getIntProperty, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, hashCode, isEmpty, keySet, propertyExists, put, putAll, remove, setBatchProperties, setBooleanProperty, setByteProperty, setBytesProperty, setCharProperty, setDoubleProperty, setFloatProperty, setIntProperty, setLongProperty, setObjectProperty, setShortProperty, setStringProperty, size, values

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.ibm.msg.client.jms.JmsPropertyContext

setBatchProperties, setBooleanProperty, setByteProperty, setBytesProperty, setCharProperty, setDoubleProperty, setFloatProperty, setIntProperty, setLongProperty, setObjectProperty, setShortProperty, setStringProperty

Methods inherited from interface com.ibm.msg.client.jms.JmsReadablePropertyContext

getBooleanProperty, getByteProperty, getBytesProperty, getCharProperty, getDoubleProperty, getFloatProperty, getIntProperty, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, propertyExists

Methods inherited from interface java.util.Map

clear, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, entrySet, equals, forEach, get, getOrDefault, hashCode, isEmpty, keySet, merge, put, putAll, putIfAbsent, remove, remove, replace, replace, replaceAll, size, values

Methods inherited from interface javax.jms.Connection

close, createConnectionConsumer, createDurableConnectionConsumer, createSession, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop

Method Detail

createConnectionConsumer

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

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

Specified by:

createConnectionConsumer in interface javax.jms.QueueConnection

Parameters:

queue - the queue to access.

selector - 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:

javax.jms.JMSException - if the JMS connection fails to create a connection consumer because of an internal error, or incorrect arguments for sessionPool and message selector.

javax.jms.InvalidDestinationException - if the queue is not valid.

javax.jms.InvalidSelectorException - if the message selector is not valid.

See Also:

ConnectionConsumer

createQueueSession

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

Creates an MQQueueSession object.

Specified by:

createQueueSession in interface javax.jms.QueueConnection

Parameters:

transacted - - indicates whether the session is transacted.

acknowledgeMode - - indicates whether the consumer or the client will acknowledge any messages it receives; ignored if the session is transacted. Legal values are Session.AUTO_ACKNOWLEDGE, Session.CLIENT_ACKNOWLEDGE, and Session.DUPS_OK_ACKNOWLEDGE.

Returns:

a newly created queue session.

Throws:

javax.jms.JMSException - if JMS Provider fails to create an MQQueueSession due to an internal error.