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 Message
sendAndReceive(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 JMSException
Sends and receives a message.- Specified by:
sendAndReceive
in 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
-
-