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)
---
