CAMEL-5539 Circuit Breaker EIP Added circuitbreaker to jaxb and scala
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/9ed7d85f Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/9ed7d85f Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/9ed7d85f Branch: refs/heads/master Commit: 9ed7d85f66284ba8b9e39eb47c35d257900ad13c Parents: 1f2b83a Author: Bilgin Ibryam <[email protected]> Authored: Sat Apr 5 15:36:05 2014 +0100 Committer: Bilgin Ibryam <[email protected]> Committed: Sat Apr 5 15:36:05 2014 +0100 ---------------------------------------------------------------------- .../main/resources/org/apache/camel/model/loadbalancer/jaxb.index | 1 + .../scala/org/apache/camel/scala/dsl/SLoadBalanceDefinition.scala | 3 +++ 2 files changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/9ed7d85f/camel-core/src/main/resources/org/apache/camel/model/loadbalancer/jaxb.index ---------------------------------------------------------------------- diff --git a/camel-core/src/main/resources/org/apache/camel/model/loadbalancer/jaxb.index b/camel-core/src/main/resources/org/apache/camel/model/loadbalancer/jaxb.index index 23a7651..0f31bc7 100644 --- a/camel-core/src/main/resources/org/apache/camel/model/loadbalancer/jaxb.index +++ b/camel-core/src/main/resources/org/apache/camel/model/loadbalancer/jaxb.index @@ -14,6 +14,7 @@ ## See the License for the specific language governing permissions and ## limitations under the License. ## ------------------------------------------------------------------------ +CircuitBreakerLoadBalancerDefinition CustomLoadBalancerDefinition FailoverLoadBalancerDefinition RandomLoadBalancerDefinition http://git-wip-us.apache.org/repos/asf/camel/blob/9ed7d85f/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SLoadBalanceDefinition.scala ---------------------------------------------------------------------- diff --git a/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SLoadBalanceDefinition.scala b/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SLoadBalanceDefinition.scala index 339b7fc..70b9ab8 100644 --- a/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SLoadBalanceDefinition.scala +++ b/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SLoadBalanceDefinition.scala @@ -25,6 +25,9 @@ import org.apache.camel.Exchange */ case class SLoadBalanceDefinition(override val target: LoadBalanceDefinition)(implicit val builder: RouteBuilder) extends SAbstractDefinition[LoadBalanceDefinition] { + def circuitbreaker(threshold: Int, halfOpenAfter: Long, exceptions: Class[_]*) + = wrap(target.circuitBreaker(threshold, halfOpenAfter, exceptions)) + def failover(classes: Class[_]*) = wrap(target.failover(classes: _*)) def failover = wrap(target.failover)
