如何使用 Java DSL 将 requestPayloadType 参数设置为 HashMap

Question

我有以下使用 java DSL 的集成流程，我想将 requestPayloadType 添加为 java.util.HashMap。我怎么做？我希望 JSON 输入被自动识别为 JSON 而不是 byte

public IntegrationFlow NotificationFlow() {
    return IntegrationFlows
            .from(Http.inboundChannelAdapter("/passenger")
                    .requestChannel(inputChannel())
                    .autoStartup(true)
                    .id("httpInnboundPass")
                    .requestMapping(r -> r.consumes("application/json"))
                    .**requestPayloadType**()
                    )
            .enrichHeaders(hes -> hes.header(HttpHeaders.ACCEPT, MediaType.APPLICATION_JSON_VALUE))
            .channel("inputChannel")
            .get();
}

Answer 1

你的问题不清楚。真的有那个方法：

Http.inboundChannelAdapter("/passenger")
                .requestPayloadType(HashMap.class)

如何使用 Java DSL 将 requestPayloadType 参数设置为 HashMap

How do i set the requestPayloadType parameter to a HashMap using Java DSL

dsl

spring-integration