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 QueueExecutor
request
- the message to sendnull
javax.jms.JMSException
- in case of an exception from the messaging systemCopyright © 1998-2014 Apache Software Foundation. All Rights Reserved.