@Test
public void testWriteScheduleMsg() throws Exception {

    long totalMsgs = 60000;
    QUEUE_TOTAL = 10;
    MessageBody = StoreMessage.getBytes();
    for (long i = 0; i < totalMsgs; i++) {
    		MessageExtBrokerInner msgInner=buildScheduleMessage(i);
        messageStore.putMessage(msgInner);
    }
    System.err.println(System.currentTimeMillis());
    Thread.sleep(200000);
    
}