PROSAGA码农传奇-部署模型-Spring批量集成启动/停止来自Controller的文件适配器

<div class =“post-text”itemprop =“text”>
  
    入站通道适配器由（至少两个）bean组成;在这种情况下，一个
     <code>
 MessageSource
 </code>
     和a
     <code>
 SourcePollingChannelAdapter
 </code>
    。
  
  
    在您的示例中，消息源获取指定的bean名称（
     <code>
 filePoller
 </code>
    ）。将生成通道适配器的名称
  
   <pre>
 <code>
 filePoller.fileMessageSource.inboundChannelAdapter

</code>
 </pre>
  
    （
     <code>
 @Configuration
 </code>
     class bean name + method name + type）
  
  
    我们有一个
    <a href="https://jira.spring.io/browse/INT-3671" rel="nofollow">
      打开JIRA问题
    </A>
     记录这些生成的bean名称。
  
  
    由于名称是虚线的，因此在使用控制总线时需要引用它：
  
   <pre>
 <code>
 @'filePoller.fileMessageSource.inboundChannelAdapter'.stop()

</code>
 </pre>
  
    的
      编辑
    </强>
  
  
    我刚测试了这个，它工作得很好......
  
   <pre>
 <code>
 @Configuration
@EnableIntegration
public class Foo {

@Bean
    QueueChannel inboundFileChannel() {
        return new QueueChannel();
    }

@Bean
 @InboundChannelAdapter(value = "inboundFileChannel", poller = @Poller(fixedDelay="1000"))
 public MessageSource<?> fileMessageSource() {
 MessageSource<?> source = mock(MessageSource.class);
 return source;
 }

@Bean
    MessageChannel control() {
        return new DirectChannel();
    }

@Bean
    @ServiceActivator(inputChannel="control")
    public ExpressionControlBusFactoryBean controlBus() {
        return new ExpressionControlBusFactoryBean();
    }

public static void main(String[] args) throws Exception {
 AnnotationConfigApplicationContext ctx = new AnnotationConfigApplicationContext(Foo.class);
 Thread.sleep(2000);
 ctx.getBean("control", MessageChannel.class).send(
 new GenericMessage<String>("@'foo.fileMessageSource.inboundChannelAdapter'.stop()"));
 assertFalse(ctx.getBean(SourcePollingChannelAdapter.class).isRunning());
 Thread.sleep(2000);
 ctx.close();
 }
}

</code>
 </pre>
  
    的
      EDIT2
    </强>
     ：
  
  
    我在上面的例子中放了一些睡眠，看到这个......
  
   <pre>
 <code>
 2015-08-03 12:23:34,528 [task-scheduler-1] DEBUG: org.springframework.integration.endpoint.SourcePollingChannelAdapter - Received no Message during the poll, returning 'false'
2015-08-03 12:23:35,530 [task-scheduler-2] DEBUG: org.springframework.integration.endpoint.SourcePollingChannelAdapter - Received no Message during the poll, returning 'false'
2015-08-03 12:23:35,615 [main] DEBUG: org.springframework.beans.factory.support.DefaultListableBeanFactory - Returning cached instance of singleton bean 'control'
2015-08-03 12:23:35,616 [main] DEBUG: org.springframework.integration.channel.DirectChannel - preSend on channel 'control', message: GenericMessage [payload=@'foo.fileMessageSource.inboundChannelAdapter'.stop(), headers={id=d0049777-025c-5439-6ee7-d66bce34868a, timestamp=1438619015616}]
2015-08-03 12:23:35,616 [main] DEBUG: org.springframework.integration.handler.ServiceActivatingHandler - ServiceActivator for [org.springframework.integration.handler.ExpressionCommandMessageProcessor@1e0b4072] received message: GenericMessage [payload=@'foo.fileMessageSource.inboundChannelAdapter'.stop(), headers={id=d0049777-025c-5439-6ee7-d66bce34868a, timestamp=1438619015616}]
2015-08-03 12:23:35,617 [main] DEBUG: org.springframework.beans.factory.support.DefaultListableBeanFactory - Returning cached instance of singleton bean 'foo.fileMessageSource.inboundChannelAdapter'
2015-08-03 12:23:35,618 [main] INFO : org.springframework.integration.endpoint.SourcePollingChannelAdapter - stopped foo.fileMessageSource.inboundChannelAdapter
2015-08-03 12:23:35,618 [main] DEBUG: org.springframework.integration.handler.ServiceActivatingHandler - handler 'ServiceActivator for [org.springframework.integration.handler.ExpressionCommandMessageProcessor@1e0b4072]' produced no reply for request Message: GenericMessage [payload=@'foo.fileMessageSource.inboundChannelAdapter'.stop(), headers={id=d0049777-025c-5439-6ee7-d66bce34868a, timestamp=1438619015616}]
2015-08-03 12:23:35,618 [main] DEBUG: org.springframework.integration.channel.DirectChannel - postSend (sent=true) on channel 'control', message: GenericMessage [payload=@'foo.fileMessageSource.inboundChannelAdapter'.stop(), headers={id=d0049777-025c-5439-6ee7-d66bce34868a, timestamp=1438619015616}]
2015-08-03 12:23:35,618 [main] DEBUG: org.springframework.beans.factory.support.DefaultListableBeanFactory - Returning cached instance of singleton bean 'foo.fileMessageSource.inboundChannelAdapter'

</code>
 </pre>
  
    （停止后没有民意调查）
  
</DIV>