@Test
public void testReadScheduleMsg() throws Exception {

    System.err.println(System.currentTimeMillis());
    long totalMsgs = 6000;
    QUEUE_TOTAL = 10;
    MessageBody = StoreMessage.getBytes();
    int offset=0;
    for (long i = 0; i < totalMsgs; i++) {
        Thread.sleep(1000);
        GetMessageResult result = messageStore.getMessage("GROUP_B", "FooBar",
        		0, offset, 
        		1024 * 1024, null);
        //System.err.println(System.currentTimeMillis());
        System.err.println(offset);
        offset+=result.getMessageCount();
        List<ByteBuffer> ll=result.getMessageBufferList();
        if(ll!=null) {
        		
        }
        result.release();
    }
    //verifyThatMasterIsFunctional(totalMsgs, messageStore);
}