[GitHub] incubator-rocketmq pull request #143: [ROCKETMQ-256] Clean commit log files ...

[dongeforever]

Github user dongeforever commented on a diff in the pull request:

    https://github.com/apache/incubator-rocketmq/pull/143#discussion_r140139119
  
    --- Diff: 
broker/src/main/java/org/apache/rocketmq/broker/plugin/AbstractPluginMessageStore.java
 ---
    @@ -246,4 +247,14 @@ public void setConfirmOffset(long phyOffset) {
         public ConsumeQueue getConsumeQueue(String topic, int queueId) {
             return next.getConsumeQueue(topic, queueId);
         }
    +
    +    @Override
    +    public PutMessageResult putMessages(MessageExtBatch messageExtBatch) {
    +        return null;
    +    }
    --- End diff --
    
    why return null  but not next.putMessages(messageExtBatch)


---