rename to tmpLogicsMsgTimestamp

Change-Id: Ia65ca06751f765bdc2bf053c58e08789f4b2fb22

Author: guyinyou

store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java

@@ -709,7 +709,7 @@ public void putMessagePositionInfoWrapper(DispatchRequest request) {
                     this.messageStore.getMessageStoreConfig().isEnableDLegerCommitLog()) {
                     this.messageStore.getStoreCheckpoint().setPhysicMsgTimestamp(request.getStoreTimestamp());
                 }
-                this.messageStore.getStoreCheckpoint().setLogicsMsgTempTimestamp(request.getStoreTimestamp());
+                this.messageStore.getStoreCheckpoint().setTmpLogicsMsgTimestamp(request.getStoreTimestamp());
                 if (MultiDispatchUtils.checkMultiDispatchQueue(this.messageStore.getMessageStoreConfig(), request)) {
                     multiDispatchLmqQueue(request, maxRetries);
                 }

store/src/main/java/org/apache/rocketmq/store/StoreCheckpoint.java

@@ -33,7 +33,7 @@ public class StoreCheckpoint {
     private final RandomAccessFile randomAccessFile;
     private final FileChannel fileChannel;
     private final MappedByteBuffer mappedByteBuffer;
-    private volatile long logicsMsgTempTimestamp = 0;
+    private volatile long tmpLogicsMsgTimestamp = 0;
     private volatile long physicMsgTimestamp = 0;
     private volatile long logicsMsgTimestamp = 0;
     private volatile long indexMsgTimestamp = 0;
@@ -113,12 +113,12 @@ public void setLogicsMsgTimestamp(long logicsMsgTimestamp) {
         this.logicsMsgTimestamp = logicsMsgTimestamp;
     }
 
-    public long getLogicsMsgTempTimestamp() {
-        return logicsMsgTempTimestamp;
+    public long getTmpLogicsMsgTimestamp() {
+        return tmpLogicsMsgTimestamp;
     }
 
-    public void setLogicsMsgTempTimestamp(long logicsMsgTempTimestamp) {
-        this.logicsMsgTempTimestamp = logicsMsgTempTimestamp;
+    public void setTmpLogicsMsgTimestamp(long tmpLogicsMsgTimestamp) {
+        this.tmpLogicsMsgTimestamp = tmpLogicsMsgTimestamp;
     }
 
     public long getConfirmPhyOffset() {

store/src/main/java/org/apache/rocketmq/store/queue/BatchConsumeQueue.java

@@ -536,7 +536,7 @@ public void putMessagePositionInfoWrapper(DispatchRequest request) {
                 if (BrokerRole.SLAVE == this.messageStore.getMessageStoreConfig().getBrokerRole()) {
                     this.messageStore.getStoreCheckpoint().setPhysicMsgTimestamp(request.getStoreTimestamp());
                 }
-                this.messageStore.getStoreCheckpoint().setLogicsMsgTempTimestamp(request.getStoreTimestamp());
+                this.messageStore.getStoreCheckpoint().setTmpLogicsMsgTimestamp(request.getStoreTimestamp());
                 return;
             } else {
                 // XXX: warn and notify me

store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java

@@ -648,7 +648,7 @@ private void doFlush(int retryTimes) {
             if (currentTimeMillis >= (this.lastFlushTimestamp + flushConsumeQueueThoroughInterval)) {
                 this.lastFlushTimestamp = currentTimeMillis;
                 flushConsumeQueueLeastPages = 0;
-                logicsMsgTimestamp = messageStore.getStoreCheckpoint().getLogicsMsgTempTimestamp();
+                logicsMsgTimestamp = messageStore.getStoreCheckpoint().getTmpLogicsMsgTimestamp();
             }
 
             boolean flushOK = true;