public class QueueReceiver extends MessageConsumer implements jakarta.jms.QueueReceiver
jakarta.jms.QueueReceiver
interface.MessageConsumer.Closer
dest, noLocal, queueMode, selector, sess, targetName
Constructor and Description |
---|
QueueReceiver(QueueSession sess,
Destination queue,
String selector)
Constructs a receiver.
|
Modifier and Type | Method and Description |
---|---|
jakarta.jms.Queue |
getQueue()
API method.
|
String |
toString()
Returns a string view of this receiver.
|
checkClosed, close, doClose, getDest, getMessageListener, getMessageSelector, getQueueMode, getTargetName, isOpen, isQueueMode, receive, receive, receiveNoWait, setMessageListener
QueueReceiver(QueueSession sess, Destination queue, String selector) throws jakarta.jms.JMSException
sess
- The session the receiver belongs to.queue
- The queue the receiver consumes on.selector
- The selector for filtering messages.jakarta.jms.IllegalStateException
- If the connection is broken.jakarta.jms.JMSException
- If the creation fails for any other reason.public String toString()
toString
in class MessageConsumer
public jakarta.jms.Queue getQueue() throws jakarta.jms.JMSException
getQueue
in interface jakarta.jms.QueueReceiver
jakarta.jms.IllegalStateException
- If the receiver is closed.jakarta.jms.JMSException
Copyright © 2023 ScalAgent D.T.. All rights reserved.