Class MockedSender.RpcPublisher

java.lang.Object
fr.ght1pc9kc.testy.beat.messaging.MockedSender.RpcPublisher
Enclosing class:
MockedSender

public static final class MockedSender.RpcPublisher extends Object
Publisher created by MockedSender to publish a RPC request.
  • 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.