Package org.springframework.amqp.rabbit.connection

Class RestTemplateNodeLocator

java.lang.Object

org.springframework.amqp.rabbit.connection.RestTemplateNodeLocator

All Implemented Interfaces:

LocalizedQueueConnectionFactory.NodeLocator<org.springframework.amqp.rabbit.connection.RestTemplateHolder>

public class RestTemplateNodeLocator
extends java.lang.Object
implements LocalizedQueueConnectionFactory.NodeLocator<org.springframework.amqp.rabbit.connection.RestTemplateHolder>

A LocalizedQueueConnectionFactory.NodeLocator using the RestTemplate.

Since:

3.0

Author:

Gary Russell

Field Summary

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

LOGGER

Constructor Summary

Constructors

Constructor	Description
RestTemplateNodeLocator()

Method Summary

Modifier and Type	Method	Description
org.springframework.amqp.rabbit.connection.RestTemplateHolder	createClient(java.lang.String userName, java.lang.String password)	Create a client for subsequent use.
java.util.Map<java.lang.String,java.lang.Object>	restCall(org.springframework.amqp.rabbit.connection.RestTemplateHolder 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

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

close, locate

Constructor Detail

RestTemplateNodeLocator

public RestTemplateNodeLocator()

Method Detail

createClient

public org.springframework.amqp.rabbit.connection.RestTemplateHolder createClient(java.lang.String userName,
                                                                                  java.lang.String password)

Description copied from interface: LocalizedQueueConnectionFactory.NodeLocator

Create a client for subsequent use.

Specified by:

createClient in interface LocalizedQueueConnectionFactory.NodeLocator<org.springframework.amqp.rabbit.connection.RestTemplateHolder>

Parameters:

userName - the user name.

password - the password.

Returns:

the client.

restCall

@Nullable
public java.util.Map<java.lang.String,java.lang.Object> restCall(org.springframework.amqp.rabbit.connection.RestTemplateHolder 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.amqp.rabbit.connection.RestTemplateHolder>

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.