java - 将自定义字段添加到 STOMP 消息的 header 中

Question

我想将版本:1.1 添加到 STOMP 消息 header 中，如下所示:

destination:/cora/1234/panelapp/code/responsecontent-type:application/json;charset=UTF-8subscription:sub-0message-id:bdyqehdj-5content-length:492**Version: 1.2**

@Override
    public Message<?> preSend(Message<?> message, MessageChannel channel) {
        StompHeaderAccessor sha = StompHeaderAccessor.wrap(message);
        StompCommand command = sha.getCommand();
        sha.setHeader(sha.STOMP_MESSAGE_HEADER, "1.2");
        sha.setVersion("1.2");
        sha.addNativeHeader(sha.STOMP_MESSAGE_HEADER, "1.2");
        return message;
}

但是在 postSend 方法中我无法在标题中找到版本信息。如何将版本信息获取到从 ChannelInterceptorAdapter 中的 preSend 方法设置的 PostSend 方法中。

<小时/>

更新:

@Override public Message<?> preSend(Message<?> message, MessageChannel channel) { 
 return MessageBuilder.fromMessage(message).setHeader("Version","1.‌​2").build(); 
}

Answer 1

我们可以将 header 设置为键/值对:

  MutableMessageBuilder.fromMessage(message)
            .setHeader("key","value")
            .build();