ReactorNettyClient instead.@Deprecated
public class ReactiveClient
extends java.lang.Object
WebClient.
This class is deprecated and will be removed in 3.0.| Constructor and Description |
|---|
ReactiveClient(java.lang.String url)
Deprecated.
|
ReactiveClient(java.lang.String url,
java.util.function.Consumer<org.springframework.web.reactive.function.client.WebClient.Builder> configurator)
Deprecated.
|
ReactiveClient(java.lang.String url,
java.util.function.Consumer<org.springframework.web.reactive.function.client.WebClient.Builder> configurator,
javax.net.ssl.SSLContext sslContext)
Deprecated.
|
ReactiveClient(java.lang.String url,
java.lang.String username,
java.lang.String password)
Deprecated.
|
ReactiveClient(java.lang.String url,
java.lang.String username,
java.lang.String password,
java.util.function.Consumer<org.springframework.web.reactive.function.client.WebClient.Builder> configurator)
Deprecated.
|
ReactiveClient(java.lang.String url,
java.lang.String username,
java.lang.String password,
java.util.function.Consumer<org.springframework.web.reactive.function.client.WebClient.Builder> configurator,
javax.net.ssl.SSLContext sslContext)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
reactor.core.publisher.Mono<AlivenessTestResult> |
alivenessTest(java.lang.String vhost)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
bindExchange(java.lang.String vhost,
java.lang.String destination,
java.lang.String source,
java.lang.String routingKey)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
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)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
bindQueue(java.lang.String vhost,
java.lang.String queue,
java.lang.String exchange,
java.lang.String routingKey)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
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)
Deprecated.
|
protected org.springframework.web.reactive.function.client.WebClient |
buildWebClient(java.lang.String url,
java.lang.String username,
java.lang.String password,
java.util.function.Consumer<org.springframework.web.reactive.function.client.WebClient.Builder> configurator,
javax.net.ssl.SSLContext sslContext)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
clearPermissions(java.lang.String vhost,
java.lang.String username)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
closeConnection(java.lang.String name)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
closeConnection(java.lang.String name,
java.lang.String reason)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
createUser(java.lang.String username,
char[] password,
java.util.List<java.lang.String> tags)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
createUserWithPasswordHash(java.lang.String username,
char[] passwordHash,
java.util.List<java.lang.String> tags)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
createVhost(java.lang.String name)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
declareExchange(java.lang.String vhost,
java.lang.String name,
ExchangeInfo info)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
declarePolicy(java.lang.String vhost,
java.lang.String name,
PolicyInfo info)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
declareQueue(java.lang.String vhost,
java.lang.String name,
QueueInfo info)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
declareShovel(java.lang.String vhost,
ShovelInfo info)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
deleteExchange(java.lang.String vhost,
java.lang.String name)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
deletePolicy(java.lang.String vhost,
java.lang.String name)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
deleteQueue(java.lang.String vhost,
java.lang.String name)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
deleteShovel(java.lang.String vhost,
java.lang.String shovelName)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
deleteUser(java.lang.String username)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
deleteVhost(java.lang.String name)
Deprecated.
|
reactor.core.publisher.Flux<BindingInfo> |
getBindings()
Deprecated.
|
reactor.core.publisher.Flux<BindingInfo> |
getBindings(java.lang.String vhost)
Deprecated.
|
reactor.core.publisher.Mono<ChannelInfo> |
getChannel(java.lang.String name)
Deprecated.
|
reactor.core.publisher.Flux<ChannelInfo> |
getChannels()
Deprecated.
|
reactor.core.publisher.Flux<ChannelInfo> |
getChannels(java.lang.String connectionName)
Deprecated.
|
reactor.core.publisher.Mono<ClusterId> |
getClusterName()
Deprecated.
|
reactor.core.publisher.Mono<ConnectionInfo> |
getConnection(java.lang.String name)
Deprecated.
|
reactor.core.publisher.Flux<ConnectionInfo> |
getConnections()
Deprecated.
|
reactor.core.publisher.Mono<Definitions> |
getDefinitions()
Deprecated.
|
reactor.core.publisher.Flux<ExchangeInfo> |
getExchange(java.lang.String vhost,
java.lang.String name)
Deprecated.
|
reactor.core.publisher.Flux<BindingInfo> |
getExchangeBindingsBetween(java.lang.String vhost,
java.lang.String source,
java.lang.String destination)
Deprecated.
|
reactor.core.publisher.Flux<BindingInfo> |
getExchangeBindingsByDestination(java.lang.String vhost,
java.lang.String exchange)
Deprecated.
|
reactor.core.publisher.Flux<BindingInfo> |
getExchangeBindingsBySource(java.lang.String vhost,
java.lang.String exchange)
Deprecated.
|
reactor.core.publisher.Flux<ExchangeInfo> |
getExchanges()
Deprecated.
|
reactor.core.publisher.Flux<ExchangeInfo> |
getExchanges(java.lang.String vhost)
Deprecated.
|
reactor.core.publisher.Flux<java.util.Map> |
getExtensions()
Deprecated.
|
reactor.core.publisher.Mono<NodeInfo> |
getNode(java.lang.String name)
Deprecated.
|
reactor.core.publisher.Flux<NodeInfo> |
getNodes()
Deprecated.
|
reactor.core.publisher.Mono<OverviewResponse> |
getOverview()
Deprecated.
|
reactor.core.publisher.Flux<UserPermissions> |
getPermissions()
Deprecated.
|
reactor.core.publisher.Mono<UserPermissions> |
getPermissions(java.lang.String vhost,
java.lang.String username)
Deprecated.
|
reactor.core.publisher.Flux<UserPermissions> |
getPermissionsIn(java.lang.String vhost)
Deprecated.
|
reactor.core.publisher.Flux<UserPermissions> |
getPermissionsOf(java.lang.String username)
Deprecated.
|
reactor.core.publisher.Flux<PolicyInfo> |
getPolicies()
Deprecated.
|
reactor.core.publisher.Flux<PolicyInfo> |
getPolicies(java.lang.String vhost)
Deprecated.
|
reactor.core.publisher.Mono<QueueInfo> |
getQueue(java.lang.String vhost,
java.lang.String name)
Deprecated.
|
reactor.core.publisher.Flux<BindingInfo> |
getQueueBindings(java.lang.String vhost,
java.lang.String queue)
Deprecated.
|
reactor.core.publisher.Flux<BindingInfo> |
getQueueBindingsBetween(java.lang.String vhost,
java.lang.String exchange,
java.lang.String queue)
Deprecated.
|
reactor.core.publisher.Flux<QueueInfo> |
getQueues()
Deprecated.
|
reactor.core.publisher.Flux<QueueInfo> |
getQueues(java.lang.String vhost)
Deprecated.
|
reactor.core.publisher.Flux<ShovelInfo> |
getShovels()
Deprecated.
|
reactor.core.publisher.Flux<ShovelStatus> |
getShovelsStatus()
Deprecated.
|
reactor.core.publisher.Mono<UserInfo> |
getUser(java.lang.String username)
Deprecated.
|
reactor.core.publisher.Flux<UserInfo> |
getUsers()
Deprecated.
|
reactor.core.publisher.Mono<VhostInfo> |
getVhost(java.lang.String name)
Deprecated.
|
reactor.core.publisher.Flux<VhostInfo> |
getVhosts()
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
purgeQueue(java.lang.String vhost,
java.lang.String name)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
setClusterName(java.lang.String name)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
updatePermissions(java.lang.String vhost,
java.lang.String username,
UserPermissions permissions)
Deprecated.
|
reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> |
updateUser(java.lang.String username,
char[] password,
java.util.List<java.lang.String> tags)
Deprecated.
|
reactor.core.publisher.Mono<CurrentUserDetails> |
whoAmI()
Deprecated.
|
public ReactiveClient(java.lang.String url)
throws java.net.MalformedURLException
java.net.MalformedURLExceptionpublic ReactiveClient(java.lang.String url,
java.util.function.Consumer<org.springframework.web.reactive.function.client.WebClient.Builder> configurator)
throws java.net.MalformedURLException
java.net.MalformedURLExceptionpublic ReactiveClient(java.lang.String url,
java.util.function.Consumer<org.springframework.web.reactive.function.client.WebClient.Builder> configurator,
javax.net.ssl.SSLContext sslContext)
throws java.net.MalformedURLException
java.net.MalformedURLExceptionpublic ReactiveClient(java.lang.String url,
java.lang.String username,
java.lang.String password)
public ReactiveClient(java.lang.String url,
java.lang.String username,
java.lang.String password,
java.util.function.Consumer<org.springframework.web.reactive.function.client.WebClient.Builder> configurator)
public ReactiveClient(java.lang.String url,
java.lang.String username,
java.lang.String password,
java.util.function.Consumer<org.springframework.web.reactive.function.client.WebClient.Builder> configurator,
javax.net.ssl.SSLContext sslContext)
protected org.springframework.web.reactive.function.client.WebClient buildWebClient(java.lang.String url,
java.lang.String username,
java.lang.String password,
java.util.function.Consumer<org.springframework.web.reactive.function.client.WebClient.Builder> configurator,
javax.net.ssl.SSLContext sslContext)
public reactor.core.publisher.Mono<OverviewResponse> getOverview()
public reactor.core.publisher.Mono<AlivenessTestResult> alivenessTest(java.lang.String vhost)
public reactor.core.publisher.Mono<CurrentUserDetails> whoAmI()
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<org.springframework.web.reactive.function.client.ClientResponse> closeConnection(java.lang.String name)
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> closeConnection(java.lang.String name,
java.lang.String reason)
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<org.springframework.web.reactive.function.client.ClientResponse> createVhost(java.lang.String name)
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> deleteVhost(java.lang.String name)
public reactor.core.publisher.Flux<UserPermissions> getPermissionsIn(java.lang.String vhost)
public reactor.core.publisher.Flux<UserPermissions> getPermissionsOf(java.lang.String username)
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.Flux<ExchangeInfo> getExchanges()
public reactor.core.publisher.Flux<ExchangeInfo> getExchanges(java.lang.String vhost)
public reactor.core.publisher.Flux<ExchangeInfo> getExchange(java.lang.String vhost, java.lang.String name)
public reactor.core.publisher.Flux<UserInfo> getUsers()
public reactor.core.publisher.Mono<UserInfo> getUser(java.lang.String username)
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> deleteUser(java.lang.String username)
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> createUser(java.lang.String username,
char[] password,
java.util.List<java.lang.String> tags)
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> createUserWithPasswordHash(java.lang.String username,
char[] passwordHash,
java.util.List<java.lang.String> tags)
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> updateUser(java.lang.String username,
char[] password,
java.util.List<java.lang.String> tags)
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> updatePermissions(java.lang.String vhost,
java.lang.String username,
UserPermissions permissions)
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> clearPermissions(java.lang.String vhost,
java.lang.String username)
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> 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<org.springframework.web.reactive.function.client.ClientResponse> deletePolicy(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<ClusterId> getClusterName()
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> 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.Mono<org.springframework.web.reactive.function.client.ClientResponse> declareQueue(java.lang.String vhost,
java.lang.String name,
QueueInfo info)
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> purgeQueue(java.lang.String vhost,
java.lang.String name)
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> deleteQueue(java.lang.String vhost,
java.lang.String name)
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> declareExchange(java.lang.String vhost,
java.lang.String name,
ExchangeInfo info)
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> deleteExchange(java.lang.String vhost,
java.lang.String name)
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<org.springframework.web.reactive.function.client.ClientResponse> bindQueue(java.lang.String vhost,
java.lang.String queue,
java.lang.String exchange,
java.lang.String routingKey)
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> 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<org.springframework.web.reactive.function.client.ClientResponse> bindExchange(java.lang.String vhost,
java.lang.String destination,
java.lang.String source,
java.lang.String routingKey)
public reactor.core.publisher.Mono<org.springframework.web.reactive.function.client.ClientResponse> 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<org.springframework.web.reactive.function.client.ClientResponse> 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<org.springframework.web.reactive.function.client.ClientResponse> deleteShovel(java.lang.String vhost,
java.lang.String shovelName)