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

FixedQueueExecutor(QueueSender producer, int timeout)
Constructor.

FixedQueueExecutor(QueueSender producer, int timeout, boolean useReqMsgIdAsCorrelId)
Constructor.

Method Summary

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(QueueSender producer,
                          int timeout)

Constructor.

Parameters:

producer - the queue to send the message on

timeout - timeout to use for the return message

FixedQueueExecutor

public FixedQueueExecutor(QueueSender 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

Description copied from interface: QueueExecutor

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