提交 f2bcae00 编写于 作者: D dongeforever

fix

上级 7b429097
...@@ -275,6 +275,7 @@ public class DLegerCommitLog extends CommitLog { ...@@ -275,6 +275,7 @@ public class DLegerCommitLog extends CommitLog {
return beginTimeInDlegerLock; return beginTimeInDlegerLock;
} }
@Override
public PutMessageResult putMessage(final MessageExtBrokerInner msg) { public PutMessageResult putMessage(final MessageExtBrokerInner msg) {
// Set the storage time // Set the storage time
msg.setStoreTimestamp(System.currentTimeMillis()); msg.setStoreTimestamp(System.currentTimeMillis());
...@@ -415,6 +416,7 @@ public class DLegerCommitLog extends CommitLog { ...@@ -415,6 +416,7 @@ public class DLegerCommitLog extends CommitLog {
} }
@Override
public PutMessageResult putMessages(final MessageExtBatch messageExtBatch) { public PutMessageResult putMessages(final MessageExtBatch messageExtBatch) {
return new PutMessageResult(PutMessageStatus.MESSAGE_ILLEGAL, null); return new PutMessageResult(PutMessageStatus.MESSAGE_ILLEGAL, null);
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册