Apache JMeter

org.apache.jmeter.protocol.jms.sampler
Class FixedQueueExecutor

java.lang.Object
  extended by 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
FixedQueueExecutor(javax.jms.MessageProducer producer, int timeout, boolean useReqMsgIdAsCorrelId)
          Constructor.
 
Method Summary
 javax.jms.Message sendAndReceive(javax.jms.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(javax.jms.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 javax.jms.Message sendAndReceive(javax.jms.Message request,
                                        int deliveryMode,
                                        int priority,
                                        long expiration)
                                 throws javax.jms.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:
javax.jms.JMSException - in case of an exception from the messaging system

Apache JMeter

Copyright © 1998-2014 Apache Software Foundation. All Rights Reserved.