Spring集成DSL：handle与enrichHeaders

Question

我有一个集成流程，其中我使用处理程序向我的消息添加一些标题：

...
.handle(this, "enrichTaskHeaders")
...

public Message<?> enrichTaskHeaders(Map<String, String> payload) {
    var id = payload.get("id");
    var t = service.findById(id);

    return MessageBuilder.withPayload(payload).setHeader("a", t.getA())
                                              .setHeader("b", t.getB())
                                              .setHeader(...)
                         .build();
}

它工作得很好，但因为它是关于丰富标题的，我想知道是否可以使用一个enrichHeaders方法来做同样的事情。我最接近的是：

.enrichHeaders(consumer -> consumer.headerFunction("a",
        (Message<Map<String, String>> m) -> {
            var id = m.getPayload().get("id");
            var t = service.findById(id);
            return t.getA();})
                                   .headerFunction("b",
        (Message<Map<String, String>> m) -> {
            var id = m.getPayload().get("id");
            var t = service.findById(i));
            return t.getB();})

        ...
)

它按预期工作，但显然效率低下，因为我为添加的每个标头复制了一个服务调用。有没有办法有效地重写它，或者我应该使用处理程序？

Answer 1

参见丰富（消费者

            .enrich(e -> e
                        .<Map<String, String>>requestPayload(m -> "v")
                        .headerFunction("a", m -> m.getPayload().getA())
                        .headerFunction("b", m -> m.getPayload().getB()))

在文档中查看更多信息：https://docs.spring.io/spring-integration/docs/current/reference/html/message-transformation.html#payload-enricher公司