CAMEL-9470: Add missing bridgeErrorHandler option to component docs
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/ae75d8d1 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/ae75d8d1 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/ae75d8d1 Branch: refs/heads/camel-2.16.x Commit: ae75d8d1533e9e32315904c107588f2d9798cf18 Parents: 2f01cf1 Author: Claus Ibsen <davscl...@apache.org> Authored: Sun Jan 3 15:12:54 2016 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sun Jan 3 17:54:14 2016 +0100 ---------------------------------------------------------------------- .../org/apache/camel/impl/DefaultEndpoint.java | 25 +++++++++++++++++++- 1 file changed, 24 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/ae75d8d1/camel-core/src/main/java/org/apache/camel/impl/DefaultEndpoint.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/impl/DefaultEndpoint.java b/camel-core/src/main/java/org/apache/camel/impl/DefaultEndpoint.java index 24d7f6e..0bf9e74 100644 --- a/camel-core/src/main/java/org/apache/camel/impl/DefaultEndpoint.java +++ b/camel-core/src/main/java/org/apache/camel/impl/DefaultEndpoint.java @@ -59,6 +59,10 @@ public abstract class DefaultEndpoint extends ServiceSupport implements Endpoint private EndpointConfiguration endpointConfiguration; private CamelContext camelContext; private Component component; + @UriParam(label = "consumer", optionalPrefix = "consumer.", description = "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while" + + " the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler." + + " By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions,that by default will be logged at WARN/ERROR level and ignored.") + private boolean bridgeErrorHandler; @UriParam(defaultValue = "InOnly", label = "advanced", description = "Sets the default exchange pattern when creating an exchange") private ExchangePattern exchangePattern = ExchangePattern.InOnly; @@ -277,6 +281,22 @@ public abstract class DefaultEndpoint extends ServiceSupport implements Endpoint this.synchronous = synchronous; } + public boolean isBridgeErrorHandler() { + return bridgeErrorHandler; + } + + /** + * Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while + * the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and + * handled by the routing Error Handler. + * <p/> + * By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, + * that by default will be logged at WARN/ERROR level and ignored. + */ + public void setBridgeErrorHandler(boolean bridgeErrorHandler) { + this.bridgeErrorHandler = bridgeErrorHandler; + } + /** * Gets the {@link org.apache.camel.PollingConsumer} queue size, when {@link org.apache.camel.impl.EventDrivenPollingConsumer} * is being used. Notice some Camel components may have their own implementation of {@link org.apache.camel.PollingConsumer} and @@ -476,7 +496,10 @@ public abstract class DefaultEndpoint extends ServiceSupport implements Endpoint @Override protected void doStart() throws Exception { - // noop + // the bridgeErrorHandler was orignally configured as consumer.bridgeErrorHandler so map to that style + if (bridgeErrorHandler) { + getConsumerProperties().put("bridgeErrorHandler", "true"); + } } @Override
