Class FixedQueueExecutor
- java.lang.Object
-
- org.apache.jmeter.protocol.jms.sampler.FixedQueueExecutor
-
- All Implemented Interfaces:
QueueExecutor
public class FixedQueueExecutor extends Object implements QueueExecutor
Request/reply executor with a fixed reply queue.
Used by JMS Sampler (Point to Point)
-
-
Constructor Summary
Constructors Constructor Description FixedQueueExecutor(MessageProducer producer, int timeout, boolean useReqMsgIdAsCorrelId)Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description MessagesendAndReceive(Message request, int deliveryMode, int priority, long expiration)Sends and receives a message.
-
-
-
Constructor Detail
-
FixedQueueExecutor
public FixedQueueExecutor(MessageProducer producer, int timeout, boolean useReqMsgIdAsCorrelId)Constructor.- Parameters:
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 id
-
-
Method Detail
-
sendAndReceive
public Message sendAndReceive(Message request, int deliveryMode, int priority, long expiration) throws JMSExceptionSends and receives a message.- Specified by:
sendAndReceivein interfaceQueueExecutor- Parameters:
request- the message to senddeliveryMode- the delivery mode to usepriority- the priority for this messageexpiration- messages lifetime in ms- Returns:
- the received message or
null - Throws:
JMSException
-
-