@@ -0,0 +1,661 @@
+package tap.sample;%0A%0Aimport tap.*;%0Aimport quantbench.Candle;%0A%0Apublic class Subscribe extends Tap %7B%0A    public static main(String%5B%5D args) throws Exception %7B%0A        Tap tap = new Tap();%0A        tap.startTime(%222011-01-03 10:40:00.000%22);%0A        tap.endTime(%222011-01-03 10:50:00.000%22);%0A        Pipe%3CCandle%3E candles = tap.subscribe(%22//cta/candle/1min%5BAAPL%5D%22);%0A        while (candles.more()) %7B%0A            Candle m = candles.get();%0A            Date time = Tap.newDate(m.getStartTime());%0A            System.out.println(time.toString + %22 symbol %22 + m.getSymbol() + %0A                               %22 open %22 + m.getOpen() + %22 volume %22 + m.getVolume());%0A        %7D%0A    %7D%0A%7D

add tap pahse 2 samples