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 and Description
    `FixedQueueExecutor(javax.jms.MessageProducer producer, int timeout, boolean useReqMsgIdAsCorrelId)` Constructor.

  - ### Method Summary

    All Methods Instance Methods Concrete Methods
    Modifier and Type | Method and Description
    --- | ---
    `void` | `close()` Close the resources
    `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
        `deliveryMode` - the delivery mode to use
        `priority` - the priority for this message
        `expiration` - messages lifetime in ms
      Returns:
        the received message or `null`
      Throws:
        `javax.jms.JMSException` - in case of an exception from the messaging system

    - #### close

          public void close()
                     throws javax.jms.JMSException

      Description copied from interface: `QueueExecutor`
      Close the resources
      Specified by:
        `close` in interface `QueueExecutor`
      Throws:
        `javax.jms.JMSException` - in case of an exception from the messaging system

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