ServiceActivator에서 새로운 InboundChannelAdapter로 메시지 전달

Question

Spring (boot) integration을 구현했습니다. InboundChannelAdapter이 있고이 메서드는 RestTemplate을 통해 웹 요청을 보내고 결과를 Splitter, Filter에 전달하고 마지막으로 ServiceActivator, ServiceActivator에 데이터를 데이터베이스에 저장합니다. . 데이터를 데이터베이스에 저장 한 후 메시지의 일부 추가 프로세스를 위해 새 "InboundChannelAdapter"에 메시지를 전달하고 싶습니다. 어떻게 구현해야합니까?
내 솔루션이 올바른 솔루션입니까?

@InboundChannelAdapter(value = "channel1", poller = @Poller("downloadTrigger")) 
public ResponseEntity<AppsItemParser[]> download() 
{ 
    String url = config.getUrl(); 
    // Call a rest webservice 
    return responseEntity; 
} 

@Splitter(inputChannel = "channel1", outputChannel = "channel2") 
public List<AppsItemParser> scrape(ResponseEntity<AppsItemParser[]> payload) 
{ 
    return new ArrayList<AppsItemParser>(Arrays.asList(payload.getBody())); 
} 

@Transformer(inputChannel = "channel2", outputChannel = "channel3") 
public App convert(AppsItemParser payload) 
{ 
    App app = new App(); 
    app.setAddDate(payload.getAddDate()); 
    app.setSize(payload.getSize()); 

    return app; 
} 

@Filter(inputChannel = "channel3", outputChannel = "channel4") 
public boolean filter(App app) 
{ 
    final Set<ConstraintViolation<App>> violations = validator.validate(app); 
    if (violations != null && !violations.isEmpty()) 
    { 
     return false; 
    } 
    return true; 
} 

    @ServiceActivator(inputChannel = "channel4") 
    public void save(App app) 
    { 
     appRepository.save(app); 
     //Send message to another spring integration flow 
    } 

Answer 1

인바운드 채널 어댑터는 플로우의 시작을 정의합니다. 그들은 다른 구성 요소로부터 메시지를받지 않습니다. 대신,

@ServiceActivator(inputChannel = "channel4", outputChannel="next") 
public App save(App app) 
{ 
    appRepository.save(app); 
    return app; 
} 

또는

@ServiceActivator(inputChannel = "channel4", outputChannel="next") 
public SomeResult save(App app) 
{ 
    appRepository.save(app); 
    return new SomeResult(...); 
}