@@ -0,0 +1,775 @@
+package tap.core;%0A%0A%0Aimport static org.junit.Assert.*;%0A%0Aimport java.io.ByteArrayOutputStream;%0Aimport java.io.File;%0Aimport java.io.PrintStream;%0Aimport java.util.Date;%0Aimport java.util.StringTokenizer;%0A%0Aimport org.joda.time.*;%0Aimport org.junit.Assert;%0Aimport org.junit.Before;%0Aimport org.junit.Test;%0A%0Aimport tap.CommandOptions;%0Aimport tap.Phase;%0Aimport tap.Pipe;%0Aimport tap.Tap;%0Aimport tap.TapMapper;%0Aimport tap.TapReducer;%0Aimport tap.formats.tapproto.Testmsg;%0A%0Apublic class SubscribeTests %7B%0A%0A%09@Test%0A%09%0A%09public void Test1()%0A%09%7B%0A%09%09String a%5B%5D = %7B%7D;%0A%09%09CommandOptions o = new CommandOptions(a);%0A%09%09Tap tap = new Tap(o);%0A%09%09Pipe%3CTestmsg.TestRecord%3E pipe = tap.subscribe(%22share/test_data.tapproto%22);%0A%09%09for(Testmsg.TestRecord  r : pipe)%0A%09%09%7B%0A%09%09%09//System.out.println(r.getExtra());%0A%09%09%7D%0A%09%7D%0A%7D%0A

add test unit case for subscribe