public class QueueRequestor
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
private QueueSession |
queueSession |
private TemporaryQueue |
replyQueue |
private QueueReceiver |
replyReceiver |
private QueueSender |
requestSender |
| Constructor and Description |
|---|
QueueRequestor(QueueSession session,
Queue queue) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
Message |
request(Message message) |
private QueueSession queueSession
private QueueSender requestSender
private QueueReceiver replyReceiver
private TemporaryQueue replyQueue
public QueueRequestor(QueueSession session, Queue queue) throws JMSException
JMSExceptionpublic Message request(Message message) throws JMSException
JMSExceptionpublic void close()
throws JMSException
JMSException