change time rep from Long to Joda DateTime

build.gradle

@@ -21,6 +21,8 @@ dependencies {
     implementation 'ch.qos.logback:logback-classic:1.3.0-alpha4'
     implementation 'org.fusesource.jansi:jansi:1.8'
     implementation 'commons-cli:commons-cli:1.4'
+    implementation 'joda-time:joda-time:2.9.9'
+    implementation 'com.fasterxml.jackson.datatype:jackson-datatype-joda:2.9.5'
 }
 
 repositories {

src/main/java/CSVReader.java

@@ -2,6 +2,7 @@ import java.io.File;
 import java.io.IOException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import com.fasterxml.jackson.datatype.joda.JodaModule;
 import com.espertech.esper.client.EPServiceProvider;
 import com.fasterxml.jackson.databind.MappingIterator;
 import com.fasterxml.jackson.dataformat.csv.CsvMapper;
@@ -19,6 +20,10 @@ public class CSVReader implements TickStreamReader {
 
 	public void run(TickProcessor processor) {
 		CsvMapper mapper = new CsvMapper();
+
+		// allow deserializing Joda time classes
+		mapper.registerModule(new JodaModule());
+
 		CsvSchema schema = mapper.schemaFor(TrueFXTickEvent.class);
 
 		try {

src/main/java/EPLHelpers.java

@@ -1,12 +1,9 @@
-import java.util.Date;
+import org.joda.time.DateTime;
-import java.util.Calendar;
 
 
 public class EPLHelpers {
 
-	public static int getHour(Date date) {
+    public static int getHour(DateTime date) {
-		Calendar c = Calendar.getInstance();
+        return date.getHourOfDay();
-		c.setTime(date);
-		return c.get(Calendar.HOUR_OF_DAY);
     }
 }

src/main/java/EsperProcessor.java

@@ -4,7 +4,6 @@ import com.espertech.esper.client.EPServiceProviderManager;
 import com.espertech.esper.client.EPStatement;
 import java.math.BigDecimal;
 import java.io.File;
-import java.util.Date;
 import com.espertech.esper.client.time.CurrentTimeEvent;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -12,6 +11,7 @@ import java.lang.reflect.Array;
 import java.util.Arrays;
 import java.util.stream.Stream;
 import java.util.stream.Collectors;
+import org.joda.time.DateTime;
 
 
 public class EsperProcessor implements TickProcessor {

src/main/java/OANDAReader.java

@@ -9,6 +9,7 @@ import java.net.URLConnection;
 import java.net.URLEncoder;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import com.fasterxml.jackson.datatype.joda.JodaModule;
 
 import javax.net.ssl.HttpsURLConnection;
 
@@ -19,6 +20,7 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 
 public class OANDAReader implements TickStreamReader {
     final Logger log = LoggerFactory.getLogger(OANDAReader.class);
+    ObjectMapper mapper;
     AccountInfo accountInfo;
 	String[] instruments;
 
@@ -26,6 +28,9 @@ public class OANDAReader implements TickStreamReader {
 	public OANDAReader(AccountInfo accountInfo, String[] instruments) {
 		this.accountInfo = accountInfo;
 		this.instruments = instruments;
+
+		mapper = new ObjectMapper();
+		mapper.registerModule(new JodaModule());
 	}
 
     public void run(TickProcessor processor) {
@@ -74,8 +79,6 @@ public class OANDAReader implements TickStreamReader {
 		}
 	}
 
-	static ObjectMapper mapper = new ObjectMapper(); // create once, reuse
-
 	private void processLine(String line, TickProcessor processor) {
 		if (line.indexOf ("PRICE") > -1) {
 			OANDATickEvent tick;