From f2bcae00f5a155774864fee83beb7997b8cab85b Mon Sep 17 00:00:00 2001
From: dongeforever <dongeforever@apache.org>
Date: Fri, 23 Nov 2018 15:48:37 +0800
Subject: [PATCH] fix

---
 .../java/org/apache/rocketmq/store/dleger/DLegerCommitLog.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/store/src/main/java/org/apache/rocketmq/store/dleger/DLegerCommitLog.java b/store/src/main/java/org/apache/rocketmq/store/dleger/DLegerCommitLog.java
index 3a5b78eb..2122211d 100644
--- a/store/src/main/java/org/apache/rocketmq/store/dleger/DLegerCommitLog.java
+++ b/store/src/main/java/org/apache/rocketmq/store/dleger/DLegerCommitLog.java
@@ -275,6 +275,7 @@ public class DLegerCommitLog extends CommitLog {
         return beginTimeInDlegerLock;
     }
 
+    @Override
     public PutMessageResult putMessage(final MessageExtBrokerInner msg) {
         // Set the storage time
         msg.setStoreTimestamp(System.currentTimeMillis());
@@ -415,6 +416,7 @@ public class DLegerCommitLog extends CommitLog {
 
     }
 
+    @Override
     public PutMessageResult putMessages(final MessageExtBatch messageExtBatch) {
         return new PutMessageResult(PutMessageStatus.MESSAGE_ILLEGAL, null);
     }
-- 
GitLab