You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2015/10/03 10:06:26 UTC
camel git commit: CAMEL-9186: Camel-Scala: Ability to add route
policy in the Scala DSL based route definition. Thanks to Naresh Khalasi for
the patch.
Repository: camel
Updated Branches:
refs/heads/master 0f2d23260 -> 4a25526b6
CAMEL-9186: Camel-Scala: Ability to add route policy in the Scala DSL based route definition. Thanks to Naresh Khalasi for the patch.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/4a25526b
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/4a25526b
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/4a25526b
Branch: refs/heads/master
Commit: 4a25526b67d7a93ce00a27328878eea03f49da35
Parents: 0f2d232
Author: Claus Ibsen <da...@apache.org>
Authored: Sat Oct 3 10:08:22 2015 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Sat Oct 3 10:08:22 2015 +0200
----------------------------------------------------------------------
.../scala/org/apache/camel/scala/dsl/SRouteDefinition.scala | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/4a25526b/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SRouteDefinition.scala
----------------------------------------------------------------------
diff --git a/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SRouteDefinition.scala b/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SRouteDefinition.scala
index 3e012e4..a196911 100644
--- a/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SRouteDefinition.scala
+++ b/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SRouteDefinition.scala
@@ -19,6 +19,9 @@ package org.apache.camel.scala.dsl
import org.apache.camel.model.RouteDefinition
import org.apache.camel.scala.dsl.builder.RouteBuilder
import org.apache.camel.builder.ErrorHandlerBuilder
+import org.apache.camel.spi.RoutePolicy
+
+import scala.collection.JavaConversions._
case class SRouteDefinition(override val target: RouteDefinition, builder: RouteBuilder) extends SAbstractDefinition[RouteDefinition] {
@@ -40,4 +43,6 @@ case class SRouteDefinition(override val target: RouteDefinition, builder: Route
def noAutoStartup() = wrap(target.autoStartup(false))
+ def routePolicy(routePolicy: RoutePolicy*) = wrap(target.setRoutePolicies(routePolicy))
+
}