This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit 44d5a6d1ec1e9284d3aa970394cd92ceed3782d3
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

Reply via email to