有没有办法调用变压器方法来更改春季集成流中的有效载荷

Question

在以下代码中，我将有效载荷转换为其他有效载荷，并将其作为请求主体发送到API呼叫。我想通过外部方法调用将转换外包。有可能吗？

    @Bean
            public IntegrationFlow flow3(){
                return integrationFlowDefinition -> integrationFlowDefinition
                        .channel(c -> c.executor(Executors.newCachedThreadPool())).log()
//                        .split("payload.employee")
//                        .transform(Transformers.toJson()).log()
                        .transform(Transformers.fromJson(Map.class)).log("json payload to Map object")
                        .<Map<String, String>, Map<String,String>>transform(
                                payload -> {
                                    payload.put("name","Somnath Mukhopadhyay");
                                    payload.put("company","xyz");
//                                    payload.put("salary", "20000");
                                    return payload;
                                }
                        ).log("Modifying the payload")
                        .transform(Transformers.toJson()).log("modified Map object to JSON")
                        .enrichHeaders(headerEnricherSpec -> headerEnricherSpec.header("ContentType","application/json"))
                        .handle(Http.outboundGateway("http://localhost:8888/Employee")
                                .httpMethod(HttpMethod.POST)
                                .expectedResponseType(String.class)
                                )
                        .log("Getting response back from flow3");
            }

Answer 1

有一个适合您的：

/**

 * Populate the {@code MessageTransformingHandler} for the {@link MethodInvokingTransformer}

 * to invoke the service method at runtime.

 * @param service the service to use.

 * @param methodName the method to invoke.

 * @return the current {@link BaseIntegrationFlowDefinition}.

 * @see MethodInvokingTransformer

 */

public B transform(Object service, String methodName) {

阅读这些DSL操作员的Javadocs。