Class WebFluxNodeLocator

    • Constructor Detail

      • WebFluxNodeLocator

        public WebFluxNodeLocator()
    • Method Detail

      • restCall

        @Nullable
        public java.util.Map<java.lang.String,​java.lang.Object> restCall​(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<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.