    @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);
        
    }