Поток Spring Cloud — синхронизация отправки и получения

#spring-boot #spring-integration #spring-cloud-stream #spring-cloud-function

#весенняя загрузка #spring-интеграция #поток spring-cloud-stream #spring-cloud-функция

Вопрос:

В моем контроллере spring boot rest я использую StreamBridge для отправки сообщения на сервер RabbitMQ с чем-то вроде

 streamBridge.send("consumer-in-0", "hello world");
  

Есть ли способ сделать send and wait the response ?

Комментарии:

1. Опоздал на вечеринку, но получил ли ты какой-либо ответ на это?

2. К сожалению, нет.

Ответ №1:

Хорошо, как я уже сказал, поздно на вечеринку, но, похоже, есть способ. просто вы можете сделать производителя синхронным, это можно сделать в application.properties как таковом:

 spring.cloud.stream.kafka.bindings.functionName-out-0.producer.sync=true
  

Та же конфигурация изначально работала для функции MessageChannel до Spring cloud, но, насколько я понимаю, базовая функциональность уже та же