import java.io.*; import java.net.MalformedURLException; import java.net.SocketTimeoutException; import java.net.URL; import java.net.URLConnection; import javax.net.ssl.HttpsURLConnection; import com.espertech.esper.client.EPServiceProvider; import com.espertech.esper.client.EPServiceProviderManager; import com.fasterxml.jackson.core.JsonParseException; import com.fasterxml.jackson.databind.JsonMappingException; import com.fasterxml.jackson.databind.MappingIterator; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectReader; import com.fasterxml.jackson.dataformat.csv.CsvMapper; import com.fasterxml.jackson.dataformat.csv.CsvSchema; public class App { public static void main(String[] args) { //EPServiceProvider esper = EPServiceProviderManager.getDefaultProvider(); File f = new File("/home/alx/Nextcloud/projects/ATS_Esper/EURUSD-2017-01-small.csv"); // new CSVReader(f).run(new DebugProcessor()); AccountInfo acctInfo = new AccountInfo(); String[] instruments = new String[] { "USD_CAD", "EUR_USD", "USD_JPY" }; new OANDAReader(acctInfo, instruments).run(new DebugProcessor()); } }