Interface QueueExecutor
- All Known Implementing Classes:
FixedQueueExecutor
,TemporaryQueueExecutor
public interface QueueExecutor
Executor for (pseudo) synchronous communication.
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
Close the resourcesjavax.jms.Message
sendAndReceive
(javax.jms.Message request, int deliveryMode, int priority, long expiration) Sends and receives a message.
-
Method Details
-
sendAndReceive
javax.jms.Message sendAndReceive(javax.jms.Message request, int deliveryMode, int priority, long expiration) throws javax.jms.JMSException Sends and receives a message.- Parameters:
request
- the message to senddeliveryMode
- the delivery mode to usepriority
- the priority for this messageexpiration
- messages lifetime in ms- Returns:
- the received message or
null
- Throws:
javax.jms.JMSException
- in case of an exception from the messaging system
-
close
void close() throws javax.jms.JMSExceptionClose the resources- Throws:
javax.jms.JMSException
- in case of an exception from the messaging system
-