Как использовать JmsTemplate.sendAndReceive - PullRequest
Новая
       97

Как использовать JmsTemplate.sendAndReceive

0 голосов
/ 27 ноября 2018

Я хочу получить ответ синхронизации от jmsTemplate.sendAndReceive: 

    Message responseMessage = producer.produceAndReceive(gzip, mestype, uploadFile.getName(), uploadFile.getAbsolutePath());

Вызывает yieldAndReceive в другом классе: 

  @Override
  public Message produceAndReceive(final byte[] data, final String type, final String name, final String archivePath) {
    jmsTemplate.setReceiveTimeout(20000);
    return jmsTemplate.sendAndReceive(SAPPI_EXPORT_QUEUE, new MessageCreator() {
      @Override
      public Message createMessage(Session session) throws JMSException {
        String msgId = UUIDGen.getUUID();
        BytesMessage message = session.createBytesMessage();
        message.writeBytes(data);
        message.setStringProperty(ISapProducer.IDOC_TYPE, type);
        message.setStringProperty(ISapProducer.ORIGIN_FILE_NAME, name);
        message.setStringProperty(ISapProducer.MESSAGE_ID, msgId);
        message.setStringProperty(ISapProducer.ARCHIVE_PATH, archivePath);

        message.setJMSReplyTo(session.createTemporaryQueue());
        message.setJMSCorrelationID(msgId);
        return message;
      }
    });
  }

после этого шага я предполагаю, что сообщение уже помещено в очередь,У меня есть метод @JmsListener, который «слушает» эту очередь: 

  @Override
  @JmsListener(destination = "myqueue.export")
  public void consume(final Message message) throws ServerException {
     // some logic here
         final HttpStatus httpStatus = client.send(gzip, idocType, documentFileName, messageId, archivePath);
        jmsTemplate.send(message.getJMSReplyTo(), new MessageCreator() {
          @Override
          public Message createMessage(Session session) throws JMSException {
            Message responseMsg = session.createTextMessage(httpStatus.toString());
            responseMsg.setJMSCorrelationID(message.getJMSCorrelationID());
            return responseMsg;
          }
        });
    // some logic here

  }

Здесь я отправляю http-запрос в удаленную систему и пытаюсь использовать httpStatus при ответном сообщении для метода sendAndReceive ().Но в ответном сообщении всегда ноль.И похоже, что он работает асинхронно.

Как я могу это исправить?

1 Ответ

0 голосов
/ 27 ноября 2018

Работает нормально для меня ... 

@SpringBootApplication
public class So53506177Application {

    public static void main(String[] args) {
        SpringApplication.run(So53506177Application.class, args);
    }

    private final SimpleMessageConverter converter = new SimpleMessageConverter();

    @Bean
    public ApplicationRunner runner(JmsTemplate jmsTemplate) {
        return args -> {
            jmsTemplate.setReceiveTimeout(20000);
            Message received = jmsTemplate.sendAndReceive("foo", new MessageCreator() {

                @Override
                public Message createMessage(Session session) throws JMSException {
                    String msgId = "foo";
                    TextMessage message = session.createTextMessage("foo");
                    message.setJMSCorrelationID(msgId);
                    return message;
                }
            });
            System.out.println("Reply: " + this.converter.fromMessage(received));
        };
    }

    @Autowired
    private JmsTemplate jmsTemplate;

    @JmsListener(destination = "foo")
    public void consume(final Message message) throws Exception {
        System.out.println("Received: " + this.converter.fromMessage(message));
        jmsTemplate.send(message.getJMSReplyTo(), new MessageCreator() {

            @Override
            public Message createMessage(Session session) throws JMSException {
                Message responseMsg = session.createTextMessage("bar");
                responseMsg.setJMSCorrelationID(message.getJMSCorrelationID());
                return responseMsg;
            }
        });
    }

}

и 

Received: foo
Reply: bar

Однако, хотя это не влияет на результат, вы не должны создавать свои собственные replyTo- шаблон создает свой собственный после выхода из MessageCreator (и потребляет из него).Он также удаляет его, когда закончите: 

@Nullable
protected Message doSendAndReceive(Session session, Destination destination, MessageCreator messageCreator)
        throws JMSException {

    Assert.notNull(messageCreator, "MessageCreator must not be null");
    TemporaryQueue responseQueue = null;
    MessageProducer producer = null;
    MessageConsumer consumer = null;
    try {
        Message requestMessage = messageCreator.createMessage(session);
        responseQueue = session.createTemporaryQueue();
        producer = session.createProducer(destination);
        consumer = session.createConsumer(responseQueue);
        requestMessage.setJMSReplyTo(responseQueue);
        if (logger.isDebugEnabled()) {
            logger.debug("Sending created message: " + requestMessage);
        }
        doSend(producer, requestMessage);
        return receiveFromConsumer(consumer, getReceiveTimeout());
    }
    finally {
        JmsUtils.closeMessageConsumer(consumer);
        JmsUtils.closeMessageProducer(producer);
        if (responseQueue != null) {
            responseQueue.delete();
        }
    }
}

Вы также можете упростить ваш слушатель: 

@JmsListener(destination = "foo")
public String consume(final Message message) throws Exception {
    System.out.println("Received: " + this.converter.fromMessage(message));
    return "bar";
}
...