reactor.rabbitmq

Class RpcClient

java.lang.Object

reactor.rabbitmq.RpcClient

All Implemented Interfaces:

AutoCloseable

public class RpcClient
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RpcClient.RpcRequest

Constructor Summary

Constructors

Constructor and Description
RpcClient(Mono<Channel> channelMono, String exchange, String routingKey)
RpcClient(Mono<Channel> channelMono, String exchange, String routingKey, Supplier<String> correlationIdSupplier)

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	lockChannel()
Mono<Delivery>	rpc(Publisher<RpcClient.RpcRequest> request)
protected void	unlockChannel()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RpcClient

public RpcClient(Mono<Channel> channelMono,
                 String exchange,
                 String routingKey,
                 Supplier<String> correlationIdSupplier)

RpcClient

public RpcClient(Mono<Channel> channelMono,
                 String exchange,
                 String routingKey)

Method Detail

rpc

public Mono<Delivery> rpc(Publisher<RpcClient.RpcRequest> request)

close

public void close()

Specified by:

close in interface AutoCloseable

lockChannel

protected void lockChannel()

unlockChannel

protected void unlockChannel()