QueueExecutor
public class FixedQueueExecutor extends Object implements QueueExecutor
Constructor | Description |
---|---|
FixedQueueExecutor(MessageProducer producer,
int timeout,
boolean useReqMsgIdAsCorrelId) |
Constructor.
|
Modifier and Type | Method | Description |
---|---|---|
Message |
sendAndReceive(Message request,
int deliveryMode,
int priority,
long expiration) |
Sends and receives a message.
|
public FixedQueueExecutor(MessageProducer producer, int timeout, boolean useReqMsgIdAsCorrelId)
producer
- the queue to send the message ontimeout
- timeout to use for the return messageuseReqMsgIdAsCorrelId
- whether to use the request message id as the correlation idpublic Message sendAndReceive(Message request, int deliveryMode, int priority, long expiration) throws JMSException
sendAndReceive
in interface QueueExecutor
request
- the message to senddeliveryMode
- the delivery mode to usepriority
- the priority for this messageexpiration
- messages lifetime in msnull
JMSException
Copyright © 1998-2018 Apache Software Foundation. All Rights Reserved.