[camel-kafka-connector] 03/03: Fixed CS

[acosentino]

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

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

commit 7047fcc7b85e59cfee5ffb3b3eaf33ee132778ec
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Mon Jun 22 18:46:28 2020 +0200

    Fixed CS
---
 .../org/apache/camel/kafkaconnector/utils/CamelMainSupport.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java
 
b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java
index b695b1f..e6bb270 100644
--- 
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java
+++ 
b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java
@@ -108,10 +108,10 @@ public class CamelMainSupport {
                     LOG.info("Creating Camel route from({}).to({})", fromUrl, 
toUrl);
                 }
                 if (camel.getRegistry().lookupByName("aggregate") != null) {
-                       AggregationStrategy s = (AggregationStrategy) 
camel.getRegistry().lookupByName("aggregate");
-                       
rd.aggregate(s).constant(true).completionSize(aggregationSize).to(toUrl);
+                    AggregationStrategy s = (AggregationStrategy) 
camel.getRegistry().lookupByName("aggregate");
+                    
rd.aggregate(s).constant(true).completionSize(aggregationSize).to(toUrl);
                 } else {
-                rd.to(toUrl);
+                    rd.to(toUrl);
                 }
             }
         });