如何使用 spring 云流 RabbitMQ 发送和等待 return 消息?
How to send and wait for return message with spring cloud stream RabbitMQ?
我正在尝试使用 spring 云流发送消息,但我找不到如何发送消息并以相同的方法获取 return,与我用过 rabbitTemplate。
RabbitTemplate template = new RabbitTemplate(cf);
//configs template here...
Object test = template.convertSendAndReceive("Hello world");
//On Cloud Stream
private MessageChannel output;
public <T extends DomainEvent> void publish(T domainEvent){
output.send(MessageBuilder.withPayload(domainEvent).build());
//How to wait and receive the answer?
}
Spring Cloud Stream 不适用于 request/reply 消息传递。
我正在尝试使用 spring 云流发送消息,但我找不到如何发送消息并以相同的方法获取 return,与我用过 rabbitTemplate。
RabbitTemplate template = new RabbitTemplate(cf);
//configs template here...
Object test = template.convertSendAndReceive("Hello world");
//On Cloud Stream
private MessageChannel output;
public <T extends DomainEvent> void publish(T domainEvent){
output.send(MessageBuilder.withPayload(domainEvent).build());
//How to wait and receive the answer?
}
Spring Cloud Stream 不适用于 request/reply 消息传递。