@Override
public void onMessage(Message message) {
    try {
        Destination replyTo = message.getJMSReplyTo(); (1)
        if (replyTo == null) {
            return;
        }
        TextMessage request = (TextMessage) message;
        String payload = request.getText();            (2)

        System.out.println("Got request: "+payload);

        String response = "Processed: "+payload;       (3)
        jms.createProducer().send(replyTo, response);  (4)
    } catch (JMSException e) {
        e.printStackTrace();
    }
}

@TransactionAttribute(TransactionAttributeType.NOT_SUPPORTED)        (1)
public String process(String request) {

    TextMessage requestMessage = jms.createTextMessage(request);
    TemporaryQueue responseQueue = jms.createTemporaryQueue();
    jms.createProducer()
            .setJMSReplyTo(responseQueue)                            (2)
            .send(requestQueue, requestMessage);                     (3)

    try (JMSConsumer consumer = jms.createConsumer(responseQueue)) { (4)

        String response = consumer.receiveBody(String.class, 2000);  (5)

        if (response == null) {                                      (6)
            throw new IllegalStateException("Message processing timed out");
        } else {
            return response;
        }
    }
}

@Deployment
public static WebArchive deployment() {
    return ShrinkWrap.create(WebArchive.class)
            .addClasses(RequestResponseOverJMS.class, JmsClient.class, Resources.class);
}

@Test
public void testRequestResposne() {
    String response = client.process("Hello");
    Assert.assertEquals("Processed: Hello", response);
}