如何在Spring JMS侦听器中从JMS消息中获取自定义属性

How to get custom properties from JMS message in a Spring JMS Listener(如何在Spring JMS侦听器中从JMS消息中获取自定义属性)

问题描述

我知道您可以使用如下内容访问Spring JMS侦听器中的标准标头：

public void receive(String in, @Header(JmsHeaders.MESSAGE_ID) String messageId) 

是否有用于访问自定义属性的类似批注？

推荐答案

完全相同.

• 使用@Header注释(请参阅方法listen)

或

• 使用封装消息头和负载的Message接口(参见方法listenMessage)

@SpringBootApplication
public class So52891334Application {

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

    @JmsListener(destination = "foo")
    public void listen(String payload, @Header("bar") String bar,
                                       @Header("qux") int qux) {
        System.out.println(payload + ", bar header: " + bar + ", qux header: " + qux);
    }

    @JmsListener(destination = "bar")
    public void listenMessage(Message<String> message) {
        String payload = message.getPayload();

        // Get headers from JMS message
        MessageHeaders headers = message.getHeaders();
        String headerBar = headers.get("bar", String.class);
        Integer headerQux = headers.get("qux", Integer.class);

        System.out.println(payload + ", bar header: " + headerBar + ", qux header: " + headerQux);
    }

    @Bean
    public ApplicationRunner runner(JmsTemplate template) {
        return args -> template.convertAndSend("foo", "test", m -> {
            m.setStringProperty("bar", "baz");
            m.setIntProperty("qux", 42);
            return m;
        });
    }

}

和

test, bar header: baz, qux header: 42

这篇关于如何在Spring JMS侦听器中从JMS消息中获取自定义属性的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！