我目前正在尝试将现有的 Spring Cloud Stream 应用程序移植到使用 Spring Cloud Function 来代替。运行应用程序时，我们使用绑定从输入队列（Kafka 或 IBMMQ）进行映射。在队列上发送的消息通过自定义 MessageConverter 传递，然后传递给我们的自定义路由函数。
例如，在 Spring Cloud Stream 中，绑定允许直接访问测试队列（通过调用 input()），并且可以简单地在该队列上发送一条消息以启动流程滚动。
我试图找到的是一种类似的机制，用于将消息发送到 Spring Cloud Function 绑定的队列。问题是我似乎无法弄清楚如何做到这一点。
我已经看到如何通过 HTTP 访问 routingFunction，但不幸的是，这绕过了我的 MessageConverter，所以我仍然无法真正进行端到端测试。
有没有人对我如何让它与 Cloud Function 一起工作有任何想法或指示？