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

oalsafi pushed a commit to branch rearrange-date-time
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit f04f2f81133e56d8e32f38471f9fa876240b3c45
Author: Omar Al-Safi <omars...@gmail.com>
AuthorDate: Tue Dec 17 17:23:30 2019 +0100

    Add checkstyle profile and rename sub modules in poms
---
 .../java/org/apache/camel/kafkaconnector/CamelSourceTask.java  | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java 
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
index 2c39f1e..6a31008 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
@@ -171,6 +171,10 @@ public class CamelSourceTask extends SourceTask {
                 record.headers().addByte(keyCamelHeader, (byte)value);
             } else if (value instanceof Byte[]) {
                 record.headers().addBytes(keyCamelHeader, (byte[])value);
+            } else if (value instanceof Time) {
+                record.headers().addTime(keyCamelHeader, (Time)value);
+            } else if (value instanceof Timestamp) {
+                record.headers().addTimestamp(keyCamelHeader, 
(Timestamp)value);
             } else if (value instanceof Date) {
                 SimpleDateFormat sdf = new SimpleDateFormat("YYYY-MM-dd");
                 String convertedDate = sdf.format(value);
@@ -187,11 +191,7 @@ public class CamelSourceTask extends SourceTask {
                 record.headers().addLong(keyCamelHeader, (long)value);
             } else if (value instanceof Short) {
                 record.headers().addShort(keyCamelHeader, (short)value);
-            } else if (value instanceof Time) {
-                record.headers().addTime(keyCamelHeader, (Time)value);
-            } else if (value instanceof Timestamp) {
-                record.headers().addTimestamp(keyCamelHeader, 
(Timestamp)value);
-            } 
+            }
         }
     }
 

Reply via email to