Class WebFluxNodeLocator

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.springframework.web.reactive.function.client.WebClient createClient​(java.lang.String username, java.lang.String password)
      Create a client instance.
      java.util.Map<java.lang.String,​java.lang.Object> restCall​(org.springframework.web.reactive.function.client.WebClient client, java.lang.String baseUri, java.lang.String vhost, java.lang.String queue)
      Retrieve a map of queue properties using the RabbitMQ Management REST API.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • WebFluxNodeLocator

        public WebFluxNodeLocator()
    • Method Detail

      • restCall

        @Nullable
        public java.util.Map<java.lang.String,​java.lang.Object> restCall​(org.springframework.web.reactive.function.client.WebClient client,
                                                                               java.lang.String baseUri,
                                                                               java.lang.String vhost,
                                                                               java.lang.String queue)
                                                                        throws java.net.URISyntaxException
        Description copied from interface: LocalizedQueueConnectionFactory.NodeLocator
        Retrieve a map of queue properties using the RabbitMQ Management REST API.
        Specified by:
        restCall in interface LocalizedQueueConnectionFactory.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:
        java.net.URISyntaxException - if the syntax is bad.
      • createClient

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