add OHLCValueEvent

src/main/java/EsperProcessor.java

@@ -1,6 +1,7 @@
 import ats.plugin.OHLCPlugInViewFactory;
 import ats.plugin.OHLCUpdateListener;
 import ats.plugin.OHLCEvent;
+import ats.plugin.OHLCValueEvent;
 import com.espertech.esper.client.Configuration;
 import com.espertech.esper.client.EPServiceProvider;
 import com.espertech.esper.client.EPServiceProviderManager;
@@ -34,6 +35,7 @@ public class EsperProcessor implements TickProcessor {
         config.addEventType(LongEntryEvent.class);
         //config.addVariable("FOO", int.class, 12);
         config.addEventType(OHLCEvent.class);
+        config.addEventType(OHLCValueEvent.class);
 
         config.addPlugInView("ATS", "OHLC", OHLCPlugInViewFactory.class.getName());
 

src/main/java/ats/plugin/OHLCValueEvent.java

@@ -0,0 +1,42 @@
+package ats.plugin;
+
+import org.joda.time.DateTime;
+
+/**
+ * OHLCValueEvent stores one bar of OHLC info.
+ */
+public class OHLCValueEvent extends OHLCEvent {
+    private double value;
+
+
+    public OHLCValueEvent() {
+        this(null, 0, 0, 0, 0, 0);
+    }
+
+    public OHLCValueEvent(DateTime time,
+                          double open, double high,
+                          double low, double close,
+                          double value)
+    {
+        super(time, open, high, low, close);
+        this.value = value;
+    }
+
+    public static OHLCValueEvent make(DateTime time,
+                                      double open, double high,
+                                      double low, double close,
+                                      double value)
+    {
+        return new OHLCValueEvent(time, open, high, low, close, value);
+    }
+
+    public Double getValue() { return value; }
+
+    /**
+     * Return a human readable representation of this event.
+     */
+    public String toString() {
+        return String.format("OHLCValueEvent[%s, open=%.3f, high=%.3f, low=%.3f, close=%.3f, value=%.3f]",
+                             getTime(), getOpen(), getHigh(), getLow(), getClose(), value);
+    }
+}