Package org.apache.jmeter.protocol.jms.sampler

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

Modifier and Type	Method	Description
Message	sendAndReceive(Message request, int deliveryMode, int priority, long expiration)	Sends and receives a message.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FixedQueueExecutor

public FixedQueueExecutor(MessageProducer producer,
                          int timeout,
                          boolean useReqMsgIdAsCorrelId)

Constructor.

Parameters:

producer - the queue to send the message on

timeout - timeout to use for the return message

useReqMsgIdAsCorrelId - 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 interface QueueExecutor

Parameters:

request - the message to send

deliveryMode - the delivery mode to use

priority - the priority for this message

expiration - messages lifetime in ms

Returns:

the received message or null

Throws:

JMSException