Class 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 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