如何通过Source bean使用现有的Spring Cloud数据流启动器/示例应用程序？

public interface Source {
    String OUTPUT = "output";

    @Output(Source.OUTPUT)
    MessageChannel output();
}

@Service
public class MessageProducer {
    private final Source source;

    public MessageProducer(Source source) {
        this.source = source;
    }

    public void sendMessage(String message) {
        source.output().send(MessageBuilder.withPayload(message).build());
    }
}

@RestController
public class MyController {
    private final MessageProducer messageProducer;

    public MyController(MessageProducer messageProducer) {
        this.messageProducer = messageProducer;
    }

    @PostMapping("/send")
    public void sendMessage(@RequestBody String message) {
        messageProducer.sendMessage(message);
    }
}