public class ReactorNettyClient
extends java.lang.Object
ReactorNettyClientOptions constructors for
advanced settings, e.g. TLS, authentication other than HTTP basic, etc.
The default settings for this class are the following:
HttpClient: created with target host and port. Other typical
settings are accessible with the HttpClient.create(Consumer): connection pooling,
SSLContext for TLS.
ObjectMapper: DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES and
MapperFeature.DEFAULT_VIEW_INCLUSION are disabled.
Mono<String> token: basic HTTP authentication used for the
authorization header.
Function<? super Throwable, ? extends Throwable> errorHandler:
HttpClientException are wrapped into
HttpClientException, other exceptions are wrapped into HttpException.
| Constructor and Description |
|---|
ReactorNettyClient(java.lang.String url) |
ReactorNettyClient(java.lang.String url,
ReactorNettyClientOptions options) |
ReactorNettyClient(java.lang.String url,
java.lang.String username,
java.lang.String password) |
ReactorNettyClient(java.lang.String url,
java.lang.String username,
java.lang.String password,
ReactorNettyClientOptions options) |
| Modifier and Type | Method and Description |
|---|---|
reactor.core.publisher.Mono<AlivenessTestResult> |
alivenessTest(java.lang.String vhost) |
static java.lang.String |
basicAuthentication(java.lang.String username,
java.lang.String password) |
reactor.core.publisher.Mono<HttpResponse> |
bindExchange(java.lang.String vhost,
java.lang.String destination,
java.lang.String source,
java.lang.String routingKey) |
reactor.core.publisher.Mono<HttpResponse> |
bindExchange(java.lang.String vhost,
java.lang.String destination,
java.lang.String source,
java.lang.String routingKey,
java.util.Map<java.lang.String,java.lang.Object> args) |
reactor.core.publisher.Mono<HttpResponse> |
bindQueue(java.lang.String vhost,
java.lang.String queue,
java.lang.String exchange,
java.lang.String routingKey) |
reactor.core.publisher.Mono<HttpResponse> |
bindQueue(java.lang.String vhost,
java.lang.String queue,
java.lang.String exchange,
java.lang.String routingKey,
java.util.Map<java.lang.String,java.lang.Object> args) |
reactor.core.publisher.Mono<HttpResponse> |
clearPermissions(java.lang.String vhost,
java.lang.String username) |
reactor.core.publisher.Mono<HttpResponse> |
closeConnection(java.lang.String name) |
reactor.core.publisher.Mono<HttpResponse> |
closeConnection(java.lang.String name,
java.lang.String reason) |
static reactor.core.publisher.Mono<java.lang.String> |
createBasicAuthenticationToken(java.lang.String username,
java.lang.String password) |
static com.fasterxml.jackson.databind.ObjectMapper |
createDefaultObjectMapper() |
reactor.core.publisher.Mono<HttpResponse> |
createUser(java.lang.String username,
char[] password,
java.util.List<java.lang.String> tags) |
reactor.core.publisher.Mono<HttpResponse> |
createUserWithPasswordHash(java.lang.String username,
char[] passwordHash,
java.util.List<java.lang.String> tags) |
reactor.core.publisher.Mono<HttpResponse> |
createVhost(java.lang.String name) |
reactor.core.publisher.Mono<HttpResponse> |
declareExchange(java.lang.String vhost,
java.lang.String name,
ExchangeInfo info) |
reactor.core.publisher.Mono<HttpResponse> |
declarePolicy(java.lang.String vhost,
java.lang.String name,
PolicyInfo info) |
reactor.core.publisher.Mono<HttpResponse> |
declareQueue(java.lang.String vhost,
java.lang.String name,
QueueInfo info) |
reactor.core.publisher.Mono<HttpResponse> |
declareShovel(java.lang.String vhost,
ShovelInfo info) |
reactor.core.publisher.Mono<HttpResponse> |
deleteExchange(java.lang.String vhost,
java.lang.String name) |
reactor.core.publisher.Mono<HttpResponse> |
deletePolicy(java.lang.String vhost,
java.lang.String name) |
reactor.core.publisher.Mono<HttpResponse> |
deleteQueue(java.lang.String vhost,
java.lang.String name) |
reactor.core.publisher.Mono<HttpResponse> |
deleteShovel(java.lang.String vhost,
java.lang.String shovelName) |
reactor.core.publisher.Mono<HttpResponse> |
deleteUser(java.lang.String username) |
reactor.core.publisher.Mono<HttpResponse> |
deleteVhost(java.lang.String name) |
reactor.core.publisher.Flux<BindingInfo> |
getBindings() |
reactor.core.publisher.Flux<BindingInfo> |
getBindings(java.lang.String vhost) |
reactor.core.publisher.Mono<ChannelInfo> |
getChannel(java.lang.String name) |
reactor.core.publisher.Flux<ChannelInfo> |
getChannels() |
reactor.core.publisher.Flux<ChannelInfo> |
getChannels(java.lang.String connectionName) |
reactor.core.publisher.Mono<ClusterId> |
getClusterName() |
reactor.core.publisher.Mono<ConnectionInfo> |
getConnection(java.lang.String name) |
reactor.core.publisher.Flux<ConnectionInfo> |
getConnections() |
reactor.core.publisher.Mono<Definitions> |
getDefinitions() |
reactor.core.publisher.Mono<ExchangeInfo> |
getExchange(java.lang.String vhost,
java.lang.String name) |
reactor.core.publisher.Flux<BindingInfo> |
getExchangeBindingsBetween(java.lang.String vhost,
java.lang.String source,
java.lang.String destination) |
reactor.core.publisher.Flux<BindingInfo> |
getExchangeBindingsByDestination(java.lang.String vhost,
java.lang.String exchange) |
reactor.core.publisher.Flux<BindingInfo> |
getExchangeBindingsBySource(java.lang.String vhost,
java.lang.String exchange) |
reactor.core.publisher.Flux<ExchangeInfo> |
getExchanges() |
reactor.core.publisher.Flux<ExchangeInfo> |
getExchanges(java.lang.String vhost) |
reactor.core.publisher.Flux<java.util.Map> |
getExtensions() |
reactor.core.publisher.Mono<NodeInfo> |
getNode(java.lang.String name) |
reactor.core.publisher.Flux<NodeInfo> |
getNodes() |
reactor.core.publisher.Mono<OverviewResponse> |
getOverview() |
reactor.core.publisher.Flux<UserPermissions> |
getPermissions() |
reactor.core.publisher.Mono<UserPermissions> |
getPermissions(java.lang.String vhost,
java.lang.String username) |
reactor.core.publisher.Flux<UserPermissions> |
getPermissionsIn(java.lang.String vhost) |
reactor.core.publisher.Flux<UserPermissions> |
getPermissionsOf(java.lang.String username) |
reactor.core.publisher.Flux<PolicyInfo> |
getPolicies() |
reactor.core.publisher.Flux<PolicyInfo> |
getPolicies(java.lang.String vhost) |
reactor.core.publisher.Mono<QueueInfo> |
getQueue(java.lang.String vhost,
java.lang.String name) |
reactor.core.publisher.Flux<BindingInfo> |
getQueueBindings(java.lang.String vhost,
java.lang.String queue) |
reactor.core.publisher.Flux<BindingInfo> |
getQueueBindingsBetween(java.lang.String vhost,
java.lang.String exchange,
java.lang.String queue) |
reactor.core.publisher.Flux<QueueInfo> |
getQueues() |
reactor.core.publisher.Flux<QueueInfo> |
getQueues(java.lang.String vhost) |
reactor.core.publisher.Flux<ShovelInfo> |
getShovels() |
reactor.core.publisher.Flux<ShovelStatus> |
getShovelsStatus() |
reactor.core.publisher.Mono<UserInfo> |
getUser(java.lang.String username) |
reactor.core.publisher.Flux<UserInfo> |
getUsers() |
reactor.core.publisher.Mono<VhostInfo> |
getVhost(java.lang.String name) |
reactor.core.publisher.Flux<VhostInfo> |
getVhosts() |
static <T extends java.lang.Throwable> |
handleError(T cause) |
reactor.core.publisher.Mono<HttpResponse> |
purgeQueue(java.lang.String vhost,
java.lang.String name) |
reactor.core.publisher.Mono<HttpResponse> |
setClusterName(java.lang.String name) |
reactor.core.publisher.Mono<HttpResponse> |
updatePermissions(java.lang.String vhost,
java.lang.String username,
UserPermissions permissions) |
reactor.core.publisher.Mono<HttpResponse> |
updateUser(java.lang.String username,
char[] password,
java.util.List<java.lang.String> tags) |
reactor.core.publisher.Mono<CurrentUserDetails> |
whoAmI() |
public ReactorNettyClient(java.lang.String url,
ReactorNettyClientOptions options)
public ReactorNettyClient(java.lang.String url)
public ReactorNettyClient(java.lang.String url,
java.lang.String username,
java.lang.String password)
public ReactorNettyClient(java.lang.String url,
java.lang.String username,
java.lang.String password,
ReactorNettyClientOptions options)
public static com.fasterxml.jackson.databind.ObjectMapper createDefaultObjectMapper()
public static reactor.core.publisher.Mono<java.lang.String> createBasicAuthenticationToken(java.lang.String username,
java.lang.String password)
public static java.lang.String basicAuthentication(java.lang.String username,
java.lang.String password)
public static <T extends java.lang.Throwable> T handleError(T cause)
public reactor.core.publisher.Mono<OverviewResponse> getOverview()
public reactor.core.publisher.Flux<NodeInfo> getNodes()
public reactor.core.publisher.Mono<NodeInfo> getNode(java.lang.String name)
public reactor.core.publisher.Flux<ConnectionInfo> getConnections()
public reactor.core.publisher.Mono<ConnectionInfo> getConnection(java.lang.String name)
public reactor.core.publisher.Mono<HttpResponse> closeConnection(java.lang.String name)
public reactor.core.publisher.Mono<HttpResponse> closeConnection(java.lang.String name, java.lang.String reason)
public reactor.core.publisher.Mono<HttpResponse> declarePolicy(java.lang.String vhost, java.lang.String name, PolicyInfo info)
public reactor.core.publisher.Flux<PolicyInfo> getPolicies()
public reactor.core.publisher.Flux<PolicyInfo> getPolicies(java.lang.String vhost)
public reactor.core.publisher.Mono<HttpResponse> deletePolicy(java.lang.String vhost, java.lang.String name)
public reactor.core.publisher.Flux<ChannelInfo> getChannels()
public reactor.core.publisher.Flux<ChannelInfo> getChannels(java.lang.String connectionName)
public reactor.core.publisher.Mono<ChannelInfo> getChannel(java.lang.String name)
public reactor.core.publisher.Flux<VhostInfo> getVhosts()
public reactor.core.publisher.Mono<VhostInfo> getVhost(java.lang.String name)
public reactor.core.publisher.Mono<HttpResponse> createVhost(java.lang.String name)
public reactor.core.publisher.Mono<HttpResponse> deleteVhost(java.lang.String name)
public reactor.core.publisher.Flux<UserPermissions> getPermissionsIn(java.lang.String vhost)
public reactor.core.publisher.Mono<HttpResponse> updatePermissions(java.lang.String vhost, java.lang.String username, UserPermissions permissions)
public reactor.core.publisher.Flux<UserInfo> getUsers()
public reactor.core.publisher.Mono<UserInfo> getUser(java.lang.String username)
public reactor.core.publisher.Mono<HttpResponse> deleteUser(java.lang.String username)
public reactor.core.publisher.Mono<HttpResponse> createUser(java.lang.String username, char[] password, java.util.List<java.lang.String> tags)
public reactor.core.publisher.Mono<HttpResponse> updateUser(java.lang.String username, char[] password, java.util.List<java.lang.String> tags)
public reactor.core.publisher.Flux<UserPermissions> getPermissionsOf(java.lang.String username)
public reactor.core.publisher.Mono<HttpResponse> createUserWithPasswordHash(java.lang.String username, char[] passwordHash, java.util.List<java.lang.String> tags)
public reactor.core.publisher.Mono<CurrentUserDetails> whoAmI()
public reactor.core.publisher.Flux<UserPermissions> getPermissions()
public reactor.core.publisher.Mono<UserPermissions> getPermissions(java.lang.String vhost, java.lang.String username)
public reactor.core.publisher.Mono<HttpResponse> clearPermissions(java.lang.String vhost, java.lang.String username)
public reactor.core.publisher.Flux<ExchangeInfo> getExchanges()
public reactor.core.publisher.Flux<ExchangeInfo> getExchanges(java.lang.String vhost)
public reactor.core.publisher.Mono<ExchangeInfo> getExchange(java.lang.String vhost, java.lang.String name)
public reactor.core.publisher.Mono<HttpResponse> declareExchange(java.lang.String vhost, java.lang.String name, ExchangeInfo info)
public reactor.core.publisher.Mono<HttpResponse> deleteExchange(java.lang.String vhost, java.lang.String name)
public reactor.core.publisher.Mono<AlivenessTestResult> alivenessTest(java.lang.String vhost)
public reactor.core.publisher.Mono<ClusterId> getClusterName()
public reactor.core.publisher.Mono<HttpResponse> setClusterName(java.lang.String name)
public reactor.core.publisher.Flux<java.util.Map> getExtensions()
public reactor.core.publisher.Mono<Definitions> getDefinitions()
public reactor.core.publisher.Flux<QueueInfo> getQueues()
public reactor.core.publisher.Flux<QueueInfo> getQueues(java.lang.String vhost)
public reactor.core.publisher.Mono<QueueInfo> getQueue(java.lang.String vhost, java.lang.String name)
public reactor.core.publisher.Mono<HttpResponse> declareQueue(java.lang.String vhost, java.lang.String name, QueueInfo info)
public reactor.core.publisher.Mono<HttpResponse> purgeQueue(java.lang.String vhost, java.lang.String name)
public reactor.core.publisher.Mono<HttpResponse> deleteQueue(java.lang.String vhost, java.lang.String name)
public reactor.core.publisher.Flux<BindingInfo> getBindings()
public reactor.core.publisher.Flux<BindingInfo> getBindings(java.lang.String vhost)
public reactor.core.publisher.Flux<BindingInfo> getExchangeBindingsBySource(java.lang.String vhost, java.lang.String exchange)
public reactor.core.publisher.Flux<BindingInfo> getExchangeBindingsByDestination(java.lang.String vhost, java.lang.String exchange)
public reactor.core.publisher.Flux<BindingInfo> getQueueBindings(java.lang.String vhost, java.lang.String queue)
public reactor.core.publisher.Flux<BindingInfo> getQueueBindingsBetween(java.lang.String vhost, java.lang.String exchange, java.lang.String queue)
public reactor.core.publisher.Flux<BindingInfo> getExchangeBindingsBetween(java.lang.String vhost, java.lang.String source, java.lang.String destination)
public reactor.core.publisher.Mono<HttpResponse> bindExchange(java.lang.String vhost, java.lang.String destination, java.lang.String source, java.lang.String routingKey)
public reactor.core.publisher.Mono<HttpResponse> bindExchange(java.lang.String vhost, java.lang.String destination, java.lang.String source, java.lang.String routingKey, java.util.Map<java.lang.String,java.lang.Object> args)
public reactor.core.publisher.Mono<HttpResponse> bindQueue(java.lang.String vhost, java.lang.String queue, java.lang.String exchange, java.lang.String routingKey)
public reactor.core.publisher.Mono<HttpResponse> bindQueue(java.lang.String vhost, java.lang.String queue, java.lang.String exchange, java.lang.String routingKey, java.util.Map<java.lang.String,java.lang.Object> args)
public reactor.core.publisher.Mono<HttpResponse> declareShovel(java.lang.String vhost, ShovelInfo info)
public reactor.core.publisher.Flux<ShovelInfo> getShovels()
public reactor.core.publisher.Flux<ShovelStatus> getShovelsStatus()
public reactor.core.publisher.Mono<HttpResponse> deleteShovel(java.lang.String vhost, java.lang.String shovelName)