public class JmsQueueReceiver extends JmsMessageConsumer implements AutoCloseable, javax.jms.QueueReceiver
acknowledgementMode, availableListener, closed, connection, consumerInfo, failureCause, lock, messageListener, messageQueue, session, started, suspendedConnection
Modifier | Constructor and Description |
---|---|
protected |
JmsQueueReceiver(JmsConsumerId id,
JmsSession session,
JmsDestination dest,
String selector)
Constructor
|
Modifier and Type | Method and Description |
---|---|
javax.jms.Queue |
getQueue() |
checkClosed, checkMessageListener, close, doClose, getAvailableListener, getConsumerId, getDestination, getMessageListener, getMessageQueueSize, getMessageSelector, getPrefetchSize, init, isBrowser, isDurableSubscription, isNoLocal, isPullConsumer, onConnectionInterrupted, onConnectionRecovered, onConnectionRecovery, onConnectionRestored, onInboundMessage, performPullIfRequired, receive, receive, receiveNoWait, redeliveryExceeded, setAvailableListener, setMessageListener, shutdown, shutdown, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
protected JmsQueueReceiver(JmsConsumerId id, JmsSession session, JmsDestination dest, String selector) throws javax.jms.JMSException
id
- This receiver's assigned Id.session
- The session that created this receiver.dest
- The destination that this receiver listens on.selector
- The selector used to filter messages for this receiver.javax.jms.JMSException
- if an error occurs during the creation of the QueueReceiver.Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.