org.apache.shenyu.plugin.hystrix.command

接口 Command

所有超级接口:

org.apache.shenyu.plugin.base.fallback.FallbackHandler

所有已知实现类:

HystrixCommand, HystrixCommandOnThread

public interface Command
extends org.apache.shenyu.plugin.base.fallback.FallbackHandler

hystrix command for semaphore and thread.

字段概要

从接口继承的字段 org.apache.shenyu.plugin.base.fallback.FallbackHandler

PREFIX

方法概要

限定符和类型	方法和说明
void	cleanCommand() clean all command.
rx.Observable<java.lang.Void>	fetchObservable() wrap fetch Observable in HystrixCommand and HystrixCommandOnThread.
java.net.URI	getCallBackUri() get call back uri.
boolean	isCircuitBreakerOpen() whether the 'circuit-breaker' is open.
void	removeCommandKey(java.lang.String commandKey) removeCommandKey rule data.
default reactor.core.publisher.Mono<java.lang.Void>	withoutFallback(org.springframework.web.server.ServerWebExchange exchange, java.lang.Throwable throwable)

从接口继承的方法 org.apache.shenyu.plugin.base.fallback.FallbackHandler

fallback

方法详细资料

fetchObservable

rx.Observable<java.lang.Void> fetchObservable()

wrap fetch Observable in HystrixCommand and HystrixCommandOnThread.

返回:

Observable<R> that executes and calls back with the result of command execution or a fallback if the command fails for any reason.

isCircuitBreakerOpen

boolean isCircuitBreakerOpen()

whether the 'circuit-breaker' is open.

返回:

boolean

withoutFallback

default reactor.core.publisher.Mono<java.lang.Void> withoutFallback(org.springframework.web.server.ServerWebExchange exchange,
                                                                    java.lang.Throwable throwable)

指定者:

withoutFallback 在接口中 org.apache.shenyu.plugin.base.fallback.FallbackHandler

getCallBackUri

java.net.URI getCallBackUri()

get call back uri.

返回:

when some error occurs in hystrix invoke it will forward to this

removeCommandKey

void removeCommandKey(java.lang.String commandKey)

removeCommandKey rule data.

参数:

commandKey - commandKey

cleanCommand

void cleanCommand()

clean all command.