org.apache.camel.component.hystrix.processor

Class HystrixProcessor

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.component.hystrix.processor.HystrixProcessor

All Implemented Interfaces:

org.apache.camel.AsyncProcessor, org.apache.camel.Navigate<org.apache.camel.Processor>, org.apache.camel.Processor, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.spi.IdAware, org.apache.camel.StatefulService, org.apache.camel.SuspendableService, org.apache.camel.Traceable

@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

Implementation of the Hystrix EIP.

Field Summary

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

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)

Method Summary

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)

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HystrixProcessor

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)

Method Detail

getHystrixCommandKey

@ManagedAttribute
public String getHystrixCommandKey()

getHystrixFallbackCommandKey

@ManagedAttribute
public String getHystrixFallbackCommandKey()

getHystrixGroupKey

@ManagedAttribute
public String getHystrixGroupKey()

isFallbackViaNetwork

@ManagedAttribute
public boolean isFallbackViaNetwork()

getHystrixTotalTimeMean

@ManagedAttribute
public int getHystrixTotalTimeMean()

getHystrixExecutionTimeMean

@ManagedAttribute
public int getHystrixExecutionTimeMean()

getHystrixCurrentConcurrentExecutionCount

@ManagedAttribute
public int getHystrixCurrentConcurrentExecutionCount()

getHystrixTotalRequests

@ManagedAttribute
public long getHystrixTotalRequests()

getHystrixErrorCount

@ManagedAttribute
public long getHystrixErrorCount()

getHystrixErrorPercentage

@ManagedAttribute
public int getHystrixErrorPercentage()

isCircuitBreakerOpen

@ManagedAttribute
public boolean isCircuitBreakerOpen()

getId

public String getId()

Specified by:

getId in interface org.apache.camel.spi.HasId

setId

public void setId(String id)

Specified by:

setId in interface org.apache.camel.spi.IdAware

getTraceLabel

public String getTraceLabel()

Specified by:

getTraceLabel in interface org.apache.camel.Traceable

next

public List<org.apache.camel.Processor> next()

Specified by:

next in interface org.apache.camel.Navigate<org.apache.camel.Processor>

hasNext

public boolean hasNext()

Specified by:

hasNext in interface org.apache.camel.Navigate<org.apache.camel.Processor>

process

public void process(org.apache.camel.Exchange exchange)
             throws Exception

Specified by:

process in interface org.apache.camel.Processor

Throws:

Exception

process

public boolean process(org.apache.camel.Exchange exchange,
                       org.apache.camel.AsyncCallback callback)

Specified by:

process in interface org.apache.camel.AsyncProcessor

doStart

protected void doStart()
                throws Exception

Specified by:

doStart in class org.apache.camel.support.ServiceSupport

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Specified by:

doStop in class org.apache.camel.support.ServiceSupport

Throws:

Exception