public class QueueRequestor
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private QueueReceiver |
receiver |
private QueueSender |
sender |
private QueueSession |
session |
private TemporaryQueue |
temporaryQueue |
Constructor and Description |
---|
QueueRequestor(QueueSession session,
Queue queue) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
private QueueReceiver |
getReceiver() |
private QueueSender |
getSender() |
private QueueSession |
getSession() |
private TemporaryQueue |
getTemporaryQueue() |
Message |
request(Message message) |
private void |
setReceiver(QueueReceiver receiver) |
private void |
setSender(QueueSender sender) |
private void |
setSession(QueueSession session) |
private void |
setTemporaryQueue(TemporaryQueue temporaryQueue) |
private QueueSession session
private TemporaryQueue temporaryQueue
private QueueSender sender
private QueueReceiver receiver
public QueueRequestor(QueueSession session, Queue queue) throws JMSException
JMSException
public Message request(Message message) throws JMSException
JMSException
public void close() throws JMSException
JMSException
private void setReceiver(QueueReceiver receiver)
private QueueReceiver getReceiver()
private void setSender(QueueSender sender)
private QueueSender getSender()
private void setSession(QueueSession session)
private QueueSession getSession()
private void setTemporaryQueue(TemporaryQueue temporaryQueue)
private TemporaryQueue getTemporaryQueue()