Весна Интеграция JAVA DSL Использование исходной полезной нагрузки при последующем вызове

Question

Я использую весеннюю интеграцию для определения потока, который будет делать две вещи: сначала выполнить HTTP-вызов с заданной полезной нагрузкой, а затем использовать предоставленный ответ и исходную полезную нагрузку, чтобы сделать еще один http-вызов ,

Как это можно достичь? В приведенном ниже коде я могу использовать и модифицировать первую полезную нагрузку и использовать ее в firstHttpRequest, но тогда как я могу использовать исходную полезную нагрузку с ответом от firstHttpRequest?

Любые хорошие практики?

@Bean 
public IntegrationFlow makeHttpCalls(){ 

    return message -> message    
      .transform(new GenericTransformer<Message<String>, String>() { 
        @Override 
        public String transform(Message<String> message){ 
          return message.getPayload() + " first call";  
        }  
      }) 
      .handle(makeFirstHttpRequest()) 
      .transform(new GenericTransformer<Message<String>, String>() { 
       @Override 
       public String transform(Message<String> message) { 
        logger.debug("Response from transform: " + message); 
        return message.getPayload(); 
       } 
      }) 
      .handle(makeSecondHttpRequest()) 
      .channel("entrypoint"); 
} 

Answer 1

Один подход .enrichHeaders() и место, что оригинальный payload в один пользовательский заголовок. Поэтому по течению, после ответа, обратитесь к этому заголовку, чтобы восстановить оригинал payload.

Другой подход - .enrich(), когда вы делаете внешний вызов и обогащаете оригинальное сообщение информацией из ответа.

Есть другие инструменты, такие как .routeToRecipients() и .publishSubscribeChannel(), где вы отправляете одно и то же сообщение в разные подпотоки для разных логик.

Но это все, что вам нужно.