目前我有类似这样的 Spring Boot 应用程序。
@Component
@EnableBinding(Source::class)
class EmailMessageProducer(private val source: Source) {
suspend fun send(textMessage: TextMessage) {
source.output().send(
MessageBuilder.withPayload(textMessage).setHeader("service", "test").build()
)
}
}
我想在这里使用反应模式使用 Spring Cloud Function。
此外,我当前的解决方案是非阻塞的吗?我问这个是因为这是我第一次在这种情况下使用 Kotlin 协程。
Java 解决方案也适用于我,因为我只是想理解这里的概念。