public class RpcClient extends Object implements AutoCloseable
Modifier and Type | Class and Description |
---|---|
static class |
RpcClient.RpcRequest |
Constructor and Description |
---|
RpcClient(Mono<Channel> channelMono,
String exchange,
String routingKey) |
RpcClient(Mono<Channel> channelMono,
String exchange,
String routingKey,
Supplier<String> correlationIdSupplier) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected void |
lockChannel() |
Mono<Delivery> |
rpc(Publisher<RpcClient.RpcRequest> request) |
protected void |
unlockChannel() |
public RpcClient(Mono<Channel> channelMono, String exchange, String routingKey, Supplier<String> correlationIdSupplier)
public Mono<Delivery> rpc(Publisher<RpcClient.RpcRequest> request)
public void close()
close
in interface AutoCloseable
protected void lockChannel()
protected void unlockChannel()