Как реализовать ReplyToQueue?

Question

[Денис Кузнецов]

Здравствуйте, у меня есть приложение 1 и в нем метод

@PostMapping
    public ResponseEntity<String> createOrder(@RequestBody OrderRequest order) throws JMSException {
        log.info("### 1 ### Order Service sending order message '{}' to the queue", order.getMessage());

        MQQueue orderRequestQueue = new MQQueue("DEV.QUEUE.1");
        jmsTemplate.convertAndSend(orderRequestQueue, order.getMessage(), textMessage -> {
            textMessage.setJMSCorrelationID(order.getIdentifier());
            return textMessage;
        });
        return new ResponseEntity(order, HttpStatus.ACCEPTED);
    }

который отправляет в очередь запрос
и есть приложение 2, которое, если я правильно понял, слушает эту очередь и отправляет в нее ответ

@JmsListener(destination = "DEV.QUEUE.1")
    public void receive(Message message) throws JMSException {
        TextMessage textMessage = (TextMessage) message;
        final String textMessageBody = textMessage.getText();
        log.info("### 2 ### Payment Service received message: {} with correlationId: {}",
                textMessageBody,
                textMessage.getJMSCorrelationID());
        // some random logic to complete the order (80% of times it returns true)
        Random random = new Random(); //message to convertAndSend
        String orderCompleted = (random.nextInt(101) >= 20) ? "payment_ok" : "payment_failed";
        // send response
        log.info("### 3 ### Payment Service sending response");
        MQQueue mqQueue = new MQQueue("DEV.QUEUE.1");
        jmsTemplate.convertAndSend(mqQueue, orderCompleted, responseMessage -> {
            responseMessage.setJMSCorrelationID(textMessage.getJMSCorrelationID());
            return responseMessage;
        });
    }

Если я правильно понял, то тут реализован принцип CorrelationId to CorrelationId.
Как изменить receive метод под принцип replyToQueue,гуглить пробовал, но не очень удачно?

Answer 1

[Dmitry Roo]

Вот тут же все написано:

MQQueue mqQueue = new MQQueue("DEV.QUEUE.1");
        jmsTemplate.convertAndSend(mqQueue, orderCompleted, responseMessage -> {
            responseMessage.setJMSCorrelationID(textMessage.getJMSCorrelationID());
            return responseMessage;
        });

Есть объявление очереди. Объявите ее так как вам надо.
Если вам не нужен CorrelationID - не устанавливайте его.

replyTo - так же можно получить из исходного сообщения:

Destination destination = textMessage.getJMSReplyTo();

Comments

[Денис Кузнецов]

а как его установить, он ведь изначально null

[Dmitry Roo]

Денис Кузнецов, кого "его" ?

[Денис Кузнецов]

Dmitry Roo, Destination
тоесть мне надо в jmsTemplate в convertAndSend передать вместо новой очереди - textMessage.getJMSReplyTo();?

[Денис Кузнецов]

Dmitry Roo, все дошло, спасибо за наводку