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 2012/08/26 11:41:36 UTC
svn commit: r1377401 - in /camel/branches/camel-2.10.x: ./
components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala
Author: davsclaus
Date: Sun Aug 26 09:41:35 2012
New Revision: 1377401
URL: http://svn.apache.org/viewvc?rev=1377401&view=rev
Log:
CAMEL-5533: Added logging error handler to Scala DSL. Thanks to Henryk Konsek for the patch.
Modified:
camel/branches/camel-2.10.x/ (props changed)
camel/branches/camel-2.10.x/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala
Propchange: camel/branches/camel-2.10.x/
------------------------------------------------------------------------------
Merged /camel/trunk:r1377400
Propchange: camel/branches/camel-2.10.x/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.
Modified: camel/branches/camel-2.10.x/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.10.x/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala?rev=1377401&r1=1377400&r2=1377401&view=diff
==============================================================================
--- camel/branches/camel-2.10.x/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala (original)
+++ camel/branches/camel-2.10.x/components/camel-scala/src/main/scala/org/apache/camel/scala/dsl/builder/RouteBuilder.scala Sun Aug 26 09:41:35 2012
@@ -20,7 +20,7 @@ package dsl.builder
import org.apache.camel.model.DataFormatDefinition
import org.apache.camel.{Exchange, RoutesBuilder}
-import org.apache.camel.builder.{DeadLetterChannelBuilder, ErrorHandlerBuilder}
+import org.apache.camel.builder.{LoggingErrorHandlerBuilder, DeadLetterChannelBuilder, ErrorHandlerBuilder}
import org.apache.camel.spi.Policy
import org.apache.camel.processor.aggregate.AggregationStrategy
@@ -32,6 +32,7 @@ import org.apache.camel.scala.dsl._
import org.apache.camel.scala.dsl.languages.Languages
import java.lang.String
import java.util.Comparator
+import org.slf4j.{Logger, LoggerFactory}
/**
* Scala RouteBuilder implementation
@@ -114,6 +115,10 @@ class RouteBuilder extends Preamble with
dlc.setDeadLetterUri(uri)
dlc
}
+ def loggingErrorHandler : LoggingErrorHandlerBuilder = new LoggingErrorHandlerBuilder
+ def loggingErrorHandler(log: String) : LoggingErrorHandlerBuilder = loggingErrorHandler(LoggerFactory.getLogger(log))
+ def loggingErrorHandler(log: Logger) : LoggingErrorHandlerBuilder = new LoggingErrorHandlerBuilder(log)
+ def loggingErrorHandler(log: Logger, level: LoggingLevel) : LoggingErrorHandlerBuilder = new LoggingErrorHandlerBuilder(log, level)
def defaultErrorHandler = builder.defaultErrorHandler
def filter(predicate: Exchange => Any) = stack.top.filter(predicate)