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
-
Field Summary
Fields inherited from interface org.springframework.amqp.rabbit.connection.NodeLocator
LOGGER -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.springframework.web.reactive.function.client.WebClientcreateClient(String username, String password) Create a client instance.restCall(org.springframework.web.reactive.function.client.WebClient client, String baseUri, String vhost, 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, waitMethods inherited from interface org.springframework.amqp.rabbit.connection.NodeLocator
close, locate
-
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:NodeLocatorRetrieve a map of queue properties using the RabbitMQ Management REST API.- Specified by:
restCallin interfaceNodeLocator<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:
createClientin interfaceNodeLocator<org.springframework.web.reactive.function.client.WebClient>- Parameters:
username- the usernamepassword- the password.- Returns:
- The client.
-