@@ -0,0 +1,993 @@
+package com.alibaba.rocketmq.client.consumer.cacheable;%0A%0Aimport com.alibaba.rocketmq.common.consumer.ConsumeFromWhere;%0Aimport com.alibaba.rocketmq.common.message.MessageExt;%0Aimport com.alibaba.rocketmq.common.protocol.heartbeat.MessageModel;%0Aimport org.junit.Test;%0A%0Apublic class CacheableConsumerTest %7B%0A%0A    CacheableConsumer cacheableConsumer = new CacheableConsumer(%22CG_QuickStart%22);%0A%0A    @Test%0A    public void testCacheable() throws Exception %7B%0A%0A        cacheableConsumer.setMessageModel(MessageModel.CLUSTERING);%0A        cacheableConsumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET);%0A        MessageHandler messageHandler = new MessageHandler() %7B%0A            @Override%0A            public int handle(MessageExt message) %7B%0A                return 5000;%0A            %7D%0A        %7D;%0A        messageHandler.setTopic(%22T_QuickStart%22);%0A        cacheableConsumer.registerMessageHandler(messageHandler);%0A        cacheableConsumer.start();%0A%0A        Thread.sleep(1000*60*50);%0A%0A%0A    %7D%0A%0A%7D

add a unit test for cacheable consumer