Spring Messaging JMS перехватчик ответа - PullRequest
Новая
       13

Spring Messaging JMS перехватчик ответа

0 голосов
/ 28 июня 2018

У меня есть метод @JmsListener, который получает параметр и возвращает экземпляр объекта, все это работает с XML и маршалингом JAXB. 

@JmsListener(
    containerFactory = ...,
    destination = ...,
    selector = ...
)
public RunReport.Response run(RunReport runReport) throws Exception
{
    // ...

    RunReport.Response response = new RunReport.Response();
    return response;
}

Это работает, как я хочу, возвращая RunReport.Response вместо Message<RunReport.Response>.

Но я хочу внедрить заголовки JMS для ответа на все мои методы JmsListener, т.е. я хочу сделать это в «промежуточном программном обеспечении» (настройка в моей конфигурации).

По какому пути я должен идти? Кажется, что классы поддержки JmsListener в Spring не настраиваются до этого уровня.

1 Ответ

0 голосов
/ 28 июня 2018

Вот этот: 

/**
 * @see AbstractMessageListenerContainer#setMessageConverter(MessageConverter)
 */
public void setMessageConverter(MessageConverter messageConverter) {
    this.messageConverter = messageConverter;
}

На AbstractJmsListenerContainerFactory вы можете предоставить. На самом деле вам нужно только указать @Bean в контексте приложения, поскольку вы работаете с Spring Boot.

Этот вызывается из AbstractAdaptableMessageListener: 

/**
 * Build a JMS message to be sent as response based on the given result object.
 * @param session the JMS Session to operate on
 * @param result the content of the message, as returned from the listener method
 * @return the JMS {@code Message} (never {@code null})
 * @throws JMSException if thrown by JMS API methods
 * @see #setMessageConverter
 */
protected Message buildMessage(Session session, Object result) throws JMSException {

Итак, это действительно место, где вы можете создать свой собственный JMS Message и установить его свойства и заголовки.

UPDATE

Я не знаю, что мне не хватает в ваших требованиях, но вот как я это вижу: 

@SpringBootApplication
public class So51088580Application {

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

    @Bean
    public MessageConverter messageConverter() {
        return new SimpleMessageConverter() {

            @Override
            public Message toMessage(Object object, Session session) throws JMSException, MessageConversionException {
                Message message = super.toMessage(object, session);
                message.setStringProperty("myProp", "bar");
                return message;
            }

        };
    }

    @JmsListener(destination = "foo")
    public String jmsHandle(String payload) {
        return payload.toUpperCase();
    }

}

И тест-кейс по этому вопросу: 

@RunWith(SpringRunner.class)
@SpringBootTest
public class So51088580ApplicationTests {

    @Autowired
    private JmsTemplate jmsTemplate;

    @Test
    public void testReplyWithProperty() throws JMSException {
        Message message = this.jmsTemplate.sendAndReceive("foo", session -> session.createTextMessage("foo"));

        assertThat(message).isInstanceOf(TextMessage.class);
        TextMessage textMessage = (TextMessage) message;
        assertThat(textMessage.getText()).isEqualTo("FOO");
        assertThat(textMessage.getStringProperty("myProp")).isEqualTo("bar");
    }

}
...