RPC-клиент с Reactor RabbitMQ - прямой ответ

Question

Я использовал Reactor RabbitMQ для создания Reactive Programming с RabbitMQ. Моя проблема в том, как клиент получает сообщение, когда запрос получен и обработан получателем. Я прочитал о документе RPC Reactor RabbitMQ ( http://projectreactor.io/docs/rabbitmq/snapshot/reference/), здесь есть демонстрационный код для RPC:

String queue = "rpc.server.queue";
Supplier<String> correlationIdSupplier = () -> UUID.randomUUID().toString(); 
Sender sender = ReactorRabbitMq.createSender();
RpcClient rpcClient = sender.rpcClient(
    "", queue, correlationIdSupplier                                         
);
Mono<Delivery> reply = rpcClient.rpc(Mono.just(
    new RpcClient.RpcRequest("hello".getBytes())
));
rpcClient.close();

Но когда я побежал, ничего не случилось.

Как получить то, что я хочу!!! Большое спасибо <3