Author: davsclaus
Date: Sun Aug 26 09:40:15 2012
New Revision: 1377400
URL: http://svn.apache.org/viewvc?rev=1377400&view=rev
Log:
CAMEL-5533: Added logging error handler to Scala DSL. Thanks to Henryk Konsek
for the patch.
Modified:
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/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=1377400&r1=1377399&r2=1377400&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
Sun Aug 26 09:40:15 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)
