import javax.jms.Connection;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TemporaryQueue;
import javax.jms.TextMessage;
 
import org.apache.activemq.ActiveMQConnectionFactory;
 
public class ReplyClient {
 
    public static class ReplyListener implements MessageListener {
 
        @Override
        public void onMessage(Message message) {
            try {
                System.out.println("Reply message found"+message.getJMSCorrelationID());
                if(message instanceof TextMessage){
                    System.out.println("messageText = " +((TextMessage)message).getText());
                }
            } catch (JMSException e) {
                e.printStackTrace();
            }
            // TODO Auto-generated method stub
        }
 
    }
 
    private static TemporaryQueue tempDest;
 
    public static void main(String[] args) {
 
        try {
            Connection connection = new ActiveMQConnectionFactory("tcp://localhost:61616").createConnection();
            Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
            Destination dest = session.createQueue("q1");
            MessageProducer messageProducer = session.createProducer(dest);
 
            tempDest = session.createTemporaryQueue();
            MessageConsumer responseConsumer = session.createConsumer(tempDest);
            responseConsumer.setMessageListener(new ReplyListener());
 
            TextMessage message = session.createTextMessage();
            message.setJMSReplyTo(tempDest); //ответ в темпдест
            message.setJMSCorrelationID(createRandomString());
//          message.setText("test1 ifdivhjduiv");
 
            messageProducer.send(message);
 
            System.out.println("send ok");
 
        } catch (JMSException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
 
    private static String createRandomString() {
        Random random = new Random(System.currentTimeMillis());
        long randomLong = random.nextLong();
        return Long.toHexString(randomLong);
    }
 
    static class MyListiner implements MessageListener {
 
        @Override
        public void onMessage(Message message) {
            try {
                System.out.println("new message found"
                        + message.getJMSCorrelationID());
            } catch (JMSException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
 
    }
}