[camel-kafka-connector] branch master updated: Clean up

[oalsafi]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new e989f4b  Clean up
e989f4b is described below

commit e989f4b7d8fa93b466e3e00852451dda5931488b
Author: Omar Al-Safi <omars...@gmail.com>
AuthorDate: Tue Dec 17 17:44:46 2019 +0100

    Clean up
---
 .../org/apache/camel/kafkaconnector/CamelSourceTask.java   | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 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..65af7c6 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
@@ -91,8 +91,8 @@ public class CamelSourceTask extends SourceTask {
 
     @Override
     public synchronized List<SourceRecord> poll() {
-        Long startPollEpochMilli = Instant.now().toEpochMilli();
-        Long collectedRecords = 0L;
+        long startPollEpochMilli = Instant.now().toEpochMilli();
+        long collectedRecords = 0L;
 
         List<SourceRecord> records = new ArrayList<>();
 
@@ -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);
-            } 
+            }
         }
     }