svn commit: r781745 - in /camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl: DSL.scala SAbstractDefinition.scala builder/RouteBuilder.scala

[ge...@apache.org]

Author: gertv
Date: Thu Jun  4 14:15:24 2009
New Revision: 781745

URL: http://svn.apache.org/viewvc?rev=781745&view=rev
Log:
CAMEL-463: Add support for setting transaction policy

Modified:
    camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/DSL.scala
    camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SAbstractDefinition.scala
    camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala

Modified: camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/DSL.scala
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/DSL.scala?rev=781745&r1=781744&r2=781745&view=diff
==============================================================================
--- camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/DSL.scala (original)
+++ camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/DSL.scala Thu Jun  4 14:15:24 2009
@@ -19,6 +19,8 @@
 import org.apache.camel.model.dataformat.DataFormatDefinition
 import org.apache.camel.processor.aggregate.AggregationStrategy
 
+import org.apache.camel.spi.Policy
+
 /**
  * Defines the 'keywords' in our Scala DSL
  */
@@ -39,6 +41,7 @@
   def marshal(format : DataFormatDefinition) : DSL
   def multicast : SMulticastDefinition
   def otherwise : DSL
+  def policy(policy: Policy) : DSL
   def process(function: Exchange => Unit) : DSL
   def recipients(expression: Exchange => Any) : DSL
   def resequence(expression: Exchange => Any) : SResequenceDefinition
@@ -55,5 +58,4 @@
   def wiretap(uri: String, expression: Exchange => Any) : DSL
   
   def -->(uris: String*) : DSL
-
 }

Modified: camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SAbstractDefinition.scala
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SAbstractDefinition.scala?rev=781745&r1=781744&r2=781745&view=diff
==============================================================================
--- camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SAbstractDefinition.scala (original)
+++ camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SAbstractDefinition.scala Thu Jun  4 14:15:24 2009
@@ -17,6 +17,7 @@
 package org.apache.camel.scala.dsl;
 
 import org.apache.camel.model._
+import org.apache.camel.spi.Policy
 
 import org.apache.camel.model.dataformat.DataFormatDefinition
 
@@ -87,6 +88,8 @@
   def loadbalance = SLoadBalanceDefinition(target.loadBalance)
   
   def delay(period: Period) = SDelayDefinition(target.delay(period.milliseconds))
+  
+  def policy(policy: Policy) = wrap(target.policy(policy))
 
   def recipients(expression: Exchange => Any) = wrap(target.recipientList(expression))
   

Modified: camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala?rev=781745&r1=781744&r2=781745&view=diff
==============================================================================
--- camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala (original)
+++ camel/trunk/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala Thu Jun  4 14:15:24 2009
@@ -18,6 +18,7 @@
 
 import org.apache.camel.model.{ChoiceDefinition, ProcessorDefinition}
 import org.apache.camel.model.dataformat.DataFormatDefinition
+import org.apache.camel.spi.Policy
 import org.apache.camel.processor.aggregate.AggregationStrategy
 import org.apache.camel.Routes
 
@@ -86,6 +87,7 @@
   def loadbalance = stack.top.loadbalance
   def delay(delay: Period) = stack.top.delay(delay)
   def enrich(uri: String, strategy: AggregationStrategy) = stack.top.enrich(uri, strategy)
+  def policy(policy: Policy) = stack.top.policy(policy)
   def resequence(expression: Exchange => Any) = stack.top.resequence(expression)
   def rollback = stack.top.rollback
   def setbody(expression : Exchange => Any) = stack.top.setbody(expression)