コントロールバス経由でインバウンドチャネルアダプタを起動するには？

Question

コントロールバスを介してファイルインバウンドチャネルアダプタを起動しようとしていますが、ExpressionCommandMessageProcessorがコマンドを解析しようとしている間に例外が発生しています。私は制御バスBeanをautowiredしている私の統合テストで

@Bean(name = "inboundChannelAdapter") 
public IntegrationFlow inputFilesReadingFlow() 
{ 
     return IntegrationFlows 
        .from(s -> s.file(new File(inputDirectory)) 
           .filter(new AcceptAllFileListFilter<File>()), 
         e -> e.poller(Pollers.fixedDelay(FILE_POLLER_RATE)) 
           .autoStartup(false) 
         ) 
        .handle(messageProcessingService) 
        .channel(fileOutputChannel) 
        .get(); 
} 

@Bean 
public IntegrationFlow controlBusFlow() 
{ 
    return IntegrationFlows.from("controlBusChannel").controlBus().get(); 
} 

：

@Autowired 
private MessageChannel controlBusChannel; 

@Test 
public void testInboundChannelAdapter() 
{ 
    controlBusChannel.send(new GenericMessage<String>("@'inboundChannelAdapter.<property_name_placeholder>'.start()")); // ???? 

    // ..... 
} 

だから、私は「アダプターにアクセスする方法をお願いしたいと思います。ここ

は私のインバウンドチャネルアダプタの設定です'ポーンプロセスを開始するためのBean（または開始/停止アクションの責任を負うBean）。

ありがとうございます。

Answer 1

.autoStartup(false)に加えて、簡単な.id()フックを見つけることができます。

あなたはControlBusを経由して、正確に希望SourcePollingChannelAdapterを開始できるようになることを持つ：

controlBusChannel.send(new GenericMessage<>("@myFilePollingAdapter.start()")); 

IntegrationFlowは豆のその束のコンテナを表し、彼らので、それらへのアクセスを取得することはできませんあなたの混乱とにかくトップレベルのBeanとして登録されています。

バージョン1.2StandardIntegrationFlowで始まることはすでにSmartLifecycleですが、そう、あなたは本当に一度にstart/stopすべてのそれらの関連豆することができます。最初のファイルポーラー1を含む。