java - 如何避免在 Spring Integration @ServiceActivator 方法中将 header 从输入复制到输出

Question

我使用简单的代码来处理来自 Google PubSub 订阅的消息并将结果返回到主题中。 但由于某种原因，添加到输入消息的所有 header 也会出现在输出消息 header 上。

有办法消除这种行为吗？

处理代码如下所示:

@ServiceActivator(inputChannel = "myInput", outputChannel = "myOutput")
public Message<String> onMessage(String payload, @Headers Map<String,Object> headers) throws SocketTimeoutException {
...
  return new GenericMessage<>(responseJson, Collections.singletonMap("type", "something"));
}

我在 Spring Integration 文档中没有找到任何关于从输入到输出的“克隆”的内容。

Answer 1

你不能；如果您使用 @Transformer相反(并返回 Message<?> )入站 header 不会传播。