评估异常：此命令处理器不支持“启动”方法

Question

我想使用 spring 集成开发控制总线示例。我决定做同样的事情，但使用 java DSL。现在我有以下源代码：@Configuration@EnableIntegration@IntegrationComponentScanpublic class Config {    @Bean    public IntegrationFlow controlBusFlow() {        return IntegrationFlows.from("operationChannel")                .controlBus()                .get();    }    @Bean    @InboundChannelAdapter(channel = "adapterOutputChanel", autoStartup = "false", poller = @Poller(fixedDelay = "1000"))    public MessageSource<String> inboundAdapter() {        return new MessageSource<String>() {            @Override            public Message receive() {                return new Message() {                    @Override                    public String getPayload() {                        return "some_output_message";                    }                    @Override                    public MessageHeaders getHeaders() {                        return null;                    }                };            }        };    }    @Bean    public AbstractMessageChannel adapterOutputChanel() {        return new QueueChannel();    }}和应用：@SpringBootApplicationpublic class MyApplication {    public static void main(String[] args) {        ConfigurableApplicationContext ctx = new SpringApplication(MyApplication.class).run(args);        MessageChannel controlChannel = ctx.getBean("operationChannel", MessageChannel.class);        PollableChannel adapterOutputChanel = ctx.getBean("adapterOutputChanel", PollableChannel.class);        controlChannel.send(new GenericMessage<String>("@inboundAdapter.start()"));        adapterOutputChanel.receive(1000);    }}我有什么错吗？

Answer 1

根据Spring中的Java和Annotation配置，inboundAdapterbean名称（本质上是bean方法名称）被准确地分配给您声明为bean的内容。在您的情况下，它是一个MessageSource实现。您确实需要在控制总线命令中处理通过那个SourcePollingChannelAdapter分配给您的 bean 。唯一的问题是我们需要找出一个正确的 bean 名称以从命令中引用它：MessageSource@InboundChannelAdapter

AbstractEndpoint bean 名称使用以下模式生成：[configurationComponentName].[methodName].[decapitalizedAnnotationClassShortName]。例如，前面显示的 consoleSource() 定义的 SourcePollingChannelAdapter 端点获取 myFlowConfiguration.consoleSource.inboundChannelAdapter 的 bean 名称。另请参见端点 Bean 名称。

因此，我建议您参考端点 Bean 名称@EndpointId建议，并与它一起使用@InboundChannelAdapter：

@Bean

@InboundChannelAdapter(channel = "adapterOutputChanel", autoStartup = "false", poller = @Poller(fixedDelay = "1000"))

@EndpointId("myInboundAdapter")

public MessageSource<String> inboundAdapter() {

因此，您的控制总线命令将如下所示："@myInboundAdapter.start()"

更新

用于连接的 Java DSL 变体MessageSource：

@Bean

public IntegrationFlow channelAdapterFlow() {

    return IntegrationFlows.from(new MyMessageSource(), 

                e -> e.id("myInboundAdapter").autoStartup(false).poller(p -> p.fixedDelay(100)))

            .channel(adapterOutputChanel())

            .get();

}