public interface QueueConnection extends Connection
QueueConnectionobject is an active connection to a point-to-point JMS provider. A client uses a
QueueConnectionobject to create one or more
QueueSessionobjects for producing and consuming messages.
QueueConnection can be used to create a
QueueSession, from which specialized queue-related objects can be created. A more general, and recommended, approach is to use the
QueueConnection object should be used to support existing code that has already used it.
QueueConnection cannot be used to create objects specific to the publish/subscribe domain. The
createDurableConnectionConsumer method inherits from
Connection, but must throw an
IllegalStateException if used from
|Modifier and Type||Method and Description|
Creates a connection consumer for this connection (optional operation).
QueueSession createQueueSession(boolean transacted, int acknowledgeMode) throws JMSException
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
JMSException- if the
QueueConnectionobject fails to create a session due to some internal error or lack of support for the specific transaction and acknowledgement mode.
ConnectionConsumer createConnectionConsumer(Queue queue, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException
queue- the queue to access
messageSelector- only messages with properties matching the message selector expression are delivered. A value of null or an empty string indicates that there is no message selector for the message consumer.
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
JMSException- if the
QueueConnectionobject fails to create a connection consumer due to some internal error or invalid arguments for
InvalidDestinationException- if an invalid queue is specified.
InvalidSelectorException- if the message selector is invalid.