RequestorNaive.java

@Component
public class Requestor {

private static final class CorrelationIdPostProcessor implements MessagePostProcessor {

private final String correlationId;

public CorrelationIdPostProcessor( final String correlationId ) {
 this.correlationId = correlationId;
 }

@Override
 public Message postProcessMessage( final Message msg ) throws JMSException {
 msg.setJMSCorrelationID( correlationId );
 return msg;
 }
 }

private final JmsTemplate jmsTemplate;

@Autowired
 public RequestGateway( JmsTemplate jmsTemplate ) {
 this.jmsTemplate = jmsTemplate;
 }

public String request( final String request, String queue ) throws IOException {
 final String correlationId = UUID.randomUUID().toString();
 jmsTemplate.convertAndSend( queue+”.request”, request, new CorrelationIdPostProcessor( correlationId ) );
 return (String) jmsTemplate.receiveSelectedAndConvert( queue+”.response”, “JMSCorrelationID=’” + correlationId + “‘“ );
 }
}