如何在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
相关文章