Package org.springframework.amqp.rabbit.connection

Class WebFluxNodeLocator

java.lang.Object

org.springframework.amqp.rabbit.connection.WebFluxNodeLocator

All Implemented Interfaces:

LocalizedQueueConnectionFactory.NodeLocator<WebClient>

public class WebFluxNodeLocator
extends Object
implements LocalizedQueueConnectionFactory.NodeLocator<WebClient>

A LocalizedQueueConnectionFactory.NodeLocator using the Spring WebFlux WebClient.

Since:

2.4.8

Author:

Gary Russell

Field Summary

Fields inherited from interface org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory.NodeLocator

LOGGER

Constructor Summary

Constructors

Constructor	Description
WebFluxNodeLocator()

Method Summary

Modifier and Type	Method	Description
WebClient	createClient(String username, String password)	Create a client instance.
Map<String,Object>	restCall(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, wait

Methods inherited from interface org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory.NodeLocator

close, locate

Constructor Details

WebFluxNodeLocator

public WebFluxNodeLocator()

Method Details

restCall

@Nullable
public Map<String,Object> restCall(WebClient client,
 String baseUri,
 String vhost,
 String queue)
                            throws 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:

URISyntaxException - if the syntax is bad.

createClient

public WebClient createClient(String username,
 String password)

Create a client instance.

Specified by:

createClient in interface LocalizedQueueConnectionFactory.NodeLocator<WebClient>

Parameters:

username - the username

password - the password.

Returns:

The client.