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) Created on: October 28, 2004

Constructor Summary

Constructors

Constructor and Description
FixedQueueExecutor(MessageProducer producer, int timeout, boolean useReqMsgIdAsCorrelId) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
Message	sendAndReceive(Message request) 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)
                       throws JMSException

Sends and receives a message.

Specified by:

sendAndReceive in interface QueueExecutor

Parameters:

request - the message to send

Returns:

the received message or null

Throws:

JMSException - in case of an exception from the messaging system