Example: In your demo, you have account-service and method to process order in account-service with the code below:
List accounts = accountRepository.findByCustomer(order.getCustomerId());
Account account = accounts.get(0);
LOGGER.info(“Account found: {}”, mapper.writeValueAsString(account));
if (order.getPrice() <= account.getBalance()) {
order.setStatus(OrderStatus.ACCEPTED);
account.setBalance(account.getBalance() – order.getPrice());
} else {
order.setStatus(OrderStatus.REJECTED);
}
orderSender.send(order);
LOGGER.info("Order response sent: {}", mapper.writeValueAsString(order));

But, once orderSender.send(order), I want to wait and get OrderId and return to the method like that:
Order orderResponse = orderSender.send(order);

In the RabbitMQ, we have already a method to do that. It's wait and receive response after send to queue
this.rabbitTemplate.convertSendAndReceive(RabbitmqApplication.EXCHANGE_NAME,
RabbitmqApplication.ROUTING_KEY, message);

So, Does have any way in Spring Cloud Stream to do like that?

Hi, I’m not sure what are you asking for. Generally you are able to send messages and receive them asynchronously by consumer.

Thanks, it would be really great as I haven’t found any examples which are similar to yours but with the reactive module. I replaced all modules with the reactive ones, changed controller etc. But what I didn’t know how to change is the OrderSender class, there’s no ReactiveSource or something similar.

Hi. Ok, the answer is that I wanted to show usage of “standard” version of Spring Cloud Stream. Maybe, I’ll describe reactive variant in one of future articles.