public class FixedQueueExecutor extends Object implements QueueExecutor
| Constructor and Description |
|---|
FixedQueueExecutor(javax.jms.MessageProducer producer,
int timeout,
boolean useReqMsgIdAsCorrelId)
Constructor.
|
public FixedQueueExecutor(javax.jms.MessageProducer producer,
int timeout,
boolean useReqMsgIdAsCorrelId)
producer - the queue to send the message ontimeout - timeout to use for the return messageuseReqMsgIdAsCorrelId - whether to use the request message id as the correlation idpublic javax.jms.Message sendAndReceive(javax.jms.Message request)
throws javax.jms.JMSException
sendAndReceive in interface QueueExecutorrequest - the message to sendnulljavax.jms.JMSException - in case of an exception from the messaging systemCopyright © 1998-2013 Apache Software Foundation. All Rights Reserved.