@ManagedResource(description="Managed Hystrix Processor")
public class HystrixProcessor
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.AsyncProcessor, org.apache.camel.Navigate<org.apache.camel.Processor>, org.apache.camel.Traceable, org.apache.camel.spi.IdAware
Constructor and Description |
---|
HystrixProcessor(com.netflix.hystrix.HystrixCommandGroupKey groupKey,
com.netflix.hystrix.HystrixCommandKey commandKey,
com.netflix.hystrix.HystrixCommandKey fallbackCommandKey,
com.netflix.hystrix.HystrixCommand.Setter setter,
com.netflix.hystrix.HystrixCommand.Setter fallbackSetter,
org.apache.camel.Processor processor,
org.apache.camel.Processor fallback,
boolean fallbackViaNetwork) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
String |
getHystrixCommandKey() |
int |
getHystrixCurrentConcurrentExecutionCount() |
long |
getHystrixErrorCount() |
int |
getHystrixErrorPercentage() |
int |
getHystrixExecutionTimeMean() |
String |
getHystrixFallbackCommandKey() |
String |
getHystrixGroupKey() |
long |
getHystrixTotalRequests() |
int |
getHystrixTotalTimeMean() |
String |
getId() |
String |
getTraceLabel() |
boolean |
hasNext() |
boolean |
isCircuitBreakerOpen() |
boolean |
isFallbackViaNetwork() |
List<org.apache.camel.Processor> |
next() |
void |
process(org.apache.camel.Exchange exchange) |
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
void |
setId(String id) |
public HystrixProcessor(com.netflix.hystrix.HystrixCommandGroupKey groupKey, com.netflix.hystrix.HystrixCommandKey commandKey, com.netflix.hystrix.HystrixCommandKey fallbackCommandKey, com.netflix.hystrix.HystrixCommand.Setter setter, com.netflix.hystrix.HystrixCommand.Setter fallbackSetter, org.apache.camel.Processor processor, org.apache.camel.Processor fallback, boolean fallbackViaNetwork)
@ManagedAttribute public String getHystrixCommandKey()
@ManagedAttribute public String getHystrixFallbackCommandKey()
@ManagedAttribute public String getHystrixGroupKey()
@ManagedAttribute public boolean isFallbackViaNetwork()
@ManagedAttribute public int getHystrixTotalTimeMean()
@ManagedAttribute public int getHystrixExecutionTimeMean()
@ManagedAttribute public int getHystrixCurrentConcurrentExecutionCount()
@ManagedAttribute public long getHystrixTotalRequests()
@ManagedAttribute public long getHystrixErrorCount()
@ManagedAttribute public int getHystrixErrorPercentage()
@ManagedAttribute public boolean isCircuitBreakerOpen()
public String getId()
getId
in interface org.apache.camel.spi.HasId
public void setId(String id)
setId
in interface org.apache.camel.spi.IdAware
public String getTraceLabel()
getTraceLabel
in interface org.apache.camel.Traceable
public List<org.apache.camel.Processor> next()
next
in interface org.apache.camel.Navigate<org.apache.camel.Processor>
public boolean hasNext()
hasNext
in interface org.apache.camel.Navigate<org.apache.camel.Processor>
public void process(org.apache.camel.Exchange exchange) throws Exception
process
in interface org.apache.camel.Processor
Exception
public boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
process
in interface org.apache.camel.AsyncProcessor
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.ServiceSupport
Exception
Apache Camel