Spring集成:无法使用IntegrationFlow从自定义消息适配器使用

我通过扩展MessageProducerSupport创建了MessageAdapter。我通过调用生成消息到输出通道 MessageProducerSupport.sendMessage . 然后我定义了一个IntegrationFlow来使用来自消息适配器的消息,并将其发送到一个通道。但我在频道上没有收到任何消息。

这是我的配置

 @Bean
  public MyAdapter myAdapter() {
    MyAdapter myAdapter = new MyAdapter();
    myAdapter.setOutputChannel(new QueueChannel());
    return myAdapter;
  }

  @Bean
  public IntegrationFlow integrationFlow() {

    return IntegrationFlows
        .from(myAdapter())
        .channel("myChannel")
        .get();
  }

以及“myChannel”的消息端点:

@MessageEndpoint
public class MyConsumer {

  @ServiceActivator(inputChannel = "myChannel")
  public void parseMessage(Message message) {
    System.out.println(message.getPayload().toString());
  }

}

谢谢你