This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch error-handling in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 55de3c47c17eb640354183050f586fb29358091d Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Fri Oct 30 08:00:08 2020 +0100 Fixed CS --- .../utils/CamelKafkaConnectMain.java | 26 +++++++++++----------- 1 file changed, 13 insertions(+), 13 deletions(-) diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java index 3dbf045..7a43f0f 100644 --- a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java +++ b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java @@ -126,8 +126,8 @@ public class CamelKafkaConnectMain extends SimpleMain { } public Builder withErrorHandler(String errorHandler) { - this.errorHandler = errorHandler; - return this; + this.errorHandler = errorHandler; + return this; } public Builder withMaxRedeliveries(int maxRedeliveries) { @@ -158,17 +158,17 @@ public class CamelKafkaConnectMain extends SimpleMain { LOG.info("Creating Camel route from({})", from); if (!ObjectHelper.isEmpty(props.get(CamelConnectorConfig.CAMEL_CONNECTOR_ERROR_HANDLER_CONF))) { - String errorHandler = props.get(CamelConnectorConfig.CAMEL_CONNECTOR_ERROR_HANDLER_CONF); - switch (errorHandler) { - case "no": - rd.errorHandler(noErrorHandler()); - break; - case "default": - rd.errorHandler(defaultErrorHandler().maximumRedeliveries(maxRedeliveries).redeliveryDelay(redeliveryDelay)); - break; - default: - break; - } + String errorHandler = props.get(CamelConnectorConfig.CAMEL_CONNECTOR_ERROR_HANDLER_CONF); + switch (errorHandler) { + case "no": + rd.errorHandler(noErrorHandler()); + break; + case "default": + rd.errorHandler(defaultErrorHandler().maximumRedeliveries(maxRedeliveries).redeliveryDelay(redeliveryDelay)); + break; + default: + break; + } } //dataformats