Package javax.jms
Interface QueueConnection
-
- All Superinterfaces:
java.lang.AutoCloseable
,Connection
- All Known Subinterfaces:
XAQueueConnection
public interface QueueConnection extends Connection
AQueueConnection
object is an active connection to a point-to-point JMS provider. A client uses aQueueConnection
object to create one or moreQueueSession
objects for producing and consuming messages.A
QueueConnection
can be used to create aQueueSession
, from which specialized queue-related objects can be created. A more general, and recommended, approach is to use theConnection
object.The
QueueConnection
object should be used to support existing code that has already used it.A
QueueConnection
cannot be used to create objects specific to the publish/subscribe domain. ThecreateDurableConnectionConsumer
method inherits fromConnection
, but must throw anIllegalStateException
if used fromQueueConnection
.- Since:
- JMS 1.0
- See Also:
Connection
,ConnectionFactory
,QueueConnectionFactory
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ConnectionConsumer
createConnectionConsumer(Queue queue, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages)
Creates a connection consumer for this connection (optional operation).QueueSession
createQueueSession(boolean transacted, int acknowledgeMode)
Creates aQueueSession
object.-
Methods inherited from interface javax.jms.Connection
close, createConnectionConsumer, createDurableConnectionConsumer, createSession, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
-
-
-
-
Method Detail
-
createQueueSession
QueueSession createQueueSession(boolean transacted, int acknowledgeMode) throws JMSException
Creates aQueueSession
object.- Parameters:
transacted
- indicates whether the session is transactedacknowledgeMode
- indicates whether the consumer or the client will acknowledge any messages it receives; ignored if the session is transacted. Legal values areSession.AUTO_ACKNOWLEDGE
,Session.CLIENT_ACKNOWLEDGE
, andSession.DUPS_OK_ACKNOWLEDGE
.- Returns:
- a newly created queue session
- Throws:
JMSException
- if theQueueConnection
object fails to create a session due to some internal error or lack of support for the specific transaction and acknowledgement mode.- See Also:
Session.AUTO_ACKNOWLEDGE
,Session.CLIENT_ACKNOWLEDGE
,Session.DUPS_OK_ACKNOWLEDGE
-
createConnectionConsumer
ConnectionConsumer createConnectionConsumer(Queue queue, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException
Creates a connection consumer for this connection (optional operation). This is an expert facility not used by regular JMS clients.- Parameters:
queue
- the queue to accessmessageSelector
- 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 consumermaxMessages
- the maximum number of messages that can be assigned to a server session at one time- Returns:
- the connection consumer
- Throws:
JMSException
- if theQueueConnection
object fails to create a connection consumer due to some internal error or invalid arguments forsessionPool
andmessageSelector
.InvalidDestinationException
- if an invalid queue is specified.InvalidSelectorException
- if the message selector is invalid.- See Also:
ConnectionConsumer
-
-