- Enclosing class:
- MockedSender
public static final class MockedSender.RpcPublisher
extends Object
-
Constructor Summary
Constructors
-
Method Summary
reactor.core.publisher.Mono<com.rabbitmq.client.Delivery>
Send a RPC request on the given exchange with given routing key.
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Constructor Details
-
RpcPublisher
public RpcPublisher()
-
Method Details
-
on
public reactor.core.publisher.Mono<com.rabbitmq.client.Delivery> on(String exchange,
String routingKey)
Send a RPC request on the given exchange with given routing key.
- Parameters:
exchange
- Exchange name.
routingKey
- Routing key.
- Returns:
- Non-blocking response.