CAMEL-4576: Add throwExceptiom with message to Scala DSL
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/1fa390ff Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/1fa390ff Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/1fa390ff Branch: refs/heads/master Commit: 1fa390ff114bc327a96223c57be2675ab8eb765f Parents: 6a8219a Author: Claus Ibsen <davscl...@apache.org> Authored: Sat Jul 11 13:04:28 2015 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sat Jul 11 13:04:28 2015 +0200 ---------------------------------------------------------------------- .../camel-scala/src/main/scala/org/apache/camel/scala/dsl/DSL.scala | 1 + .../main/scala/org/apache/camel/scala/dsl/SAbstractDefinition.scala | 1 + .../scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala | 1 + 3 files changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/1fa390ff/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/DSL.scala ---------------------------------------------------------------------- diff --git a/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/DSL.scala b/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/DSL.scala index ea74588..cfce461 100644 --- a/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/DSL.scala +++ b/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/DSL.scala @@ -103,6 +103,7 @@ trait DSL { def threads : SThreadsDefinition def throttle(frequency: Frequency) : SThrottleDefinition def throwException(exception: Exception) : DSL + def throwException(exceptionType: Class[_ <: Exception], message: String) : DSL def to(uris: String*) : DSL def transacted : DSL def transacted(ref: String) : DSL http://git-wip-us.apache.org/repos/asf/camel/blob/1fa390ff/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SAbstractDefinition.scala ---------------------------------------------------------------------- diff --git a/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SAbstractDefinition.scala b/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SAbstractDefinition.scala index 4f2f33c..23914dd 100644 --- a/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SAbstractDefinition.scala +++ b/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/SAbstractDefinition.scala @@ -148,6 +148,7 @@ abstract class SAbstractDefinition[P <: ProcessorDefinition[_]] extends DSL with def threads = SThreadsDefinition(target.threads) def throttle(frequency: Frequency) = SThrottleDefinition(target.throttle(frequency.count).timePeriodMillis(frequency.period.milliseconds)) def throwException(exception: Exception) = wrap(target.throwException(exception)) + def throwException(exceptionType: Class[_ <: Exception], message: String) = wrap(target.throwException(exceptionType, message)) def transacted = STransactedDefinition(target.transacted) def transacted(ref: String) = STransactedDefinition(target.transacted(ref)) def transform(expression: Exchange => Any) = wrap(target.transform(expression)) http://git-wip-us.apache.org/repos/asf/camel/blob/1fa390ff/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala ---------------------------------------------------------------------- diff --git a/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala b/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala index 3b5d8f1..9faf2a4 100644 --- a/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala +++ b/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala @@ -197,6 +197,7 @@ class RouteBuilder extends Preamble with DSL with RoutesBuilder with Languages w def threads = stack.top.threads def throttle(frequency: Frequency) = stack.top.throttle(frequency) def throwException(exception: Exception) = stack.top.throwException(exception) + def throwException(exceptionType: Class[_ <: Exception], message: String) = stack.top.throwException(exceptionType, message) def transacted = stack.top.transacted def transacted(uri: String) = stack.top.transacted def transform(expression: Exchange => Any) = stack.top.transform(expression)
