public class MessageAnalyzer implements MessageListener {

    @Override
    public void onMessage(Message requestMessage) {
        Message replyMessage = jmsContext.createTextMessage("This is a reply message");
        replyMessage.setJMSCorrelationID(requestMessage.getJMSMessageID());
        jmsContext.createProducer().send((Topic)requestMessage.getJMSReplyTo(), replyMessage);
    }
    
    // ...

}