Class WebFluxNodeLocator

java.lang.Object
org.springframework.amqp.rabbit.connection.WebFluxNodeLocator
All Implemented Interfaces:
NodeLocator<org.springframework.web.reactive.function.client.WebClient>

public class WebFluxNodeLocator extends Object implements NodeLocator<org.springframework.web.reactive.function.client.WebClient>
A NodeLocator using the Spring WebFlux WebClient.
Since:
2.4.8
  • Constructor Details

    • WebFluxNodeLocator

      public WebFluxNodeLocator()
  • Method Details

    • restCall

      @Nullable public Map<String,Object> restCall(org.springframework.web.reactive.function.client.WebClient client, String baseUri, String vhost, String queue) throws URISyntaxException
      Description copied from interface: NodeLocator
      Retrieve a map of queue properties using the RabbitMQ Management REST API.
      Specified by:
      restCall in interface NodeLocator<org.springframework.web.reactive.function.client.WebClient>
      Parameters:
      client - the client.
      baseUri - the base uri.
      vhost - the virtual host.
      queue - the queue name.
      Returns:
      the map of queue properties.
      Throws:
      URISyntaxException - if the syntax is bad.
    • createClient

      public org.springframework.web.reactive.function.client.WebClient createClient(String username, String password)
      Create a client instance.
      Specified by:
      createClient in interface NodeLocator<org.springframework.web.reactive.function.client.WebClient>
      Parameters:
      username - the username
      password - the password.
      Returns:
      The client.