Camel endpoint which wraps child endpoints into a synchronous or asynchronous hystrix circuit breaker.
This project allows easy integration of hystrix components into camel routes. A very simple example might look like this:
private class TestRoute extends RouteBuilder {
@Override
public void configure() throws Exception {
onException(HystrixRuntimeException.class).handled(true).setBody().constant("error");
from("direct:start").to("hystrix:mock:protectedRoute?hystrixGroup=test?hystrixCommand=slowCommand");
}
}In this example the mock endpoint is protected by a hystrix endpoint by prefixing the mock endpoint with hystrix. The hystrixGroup parameter can be used to identify and group hystrix commands for monitoring in scaled environments. The hystrixCommand parameter can be used to identify hystrix commands for distributed configuration of components. The hystrixCommandTimeout parameter can be used to set the timeout for the hystrix command
When wrapping direct endpoints with the hystrix component, whole sections of a route can be protected, including processors and endpoints:
private class TestRoute extends RouteBuilder {
@Override
public void configure() throws Exception {
onException(HystrixRuntimeException.class).handled(true).setBody().constant("error");
from("direct:start").to("hystrix:direct:protectedRoute?hystrixGroup=test&hystrixCommand=slowCommand");
from("direct:protectedRoute").marsha().json().to("mock:result");
}
}Binaries
Jars for Maven, Ivy, Gradle and others can be found at http://search.maven.org.
Example for Maven:
<dependency>
<groupId>com.jollydays.camel</groupId>
<artifactId>camel-hystrix-endpoint</artifactId>
<version>x.y.z</version>
</dependency>