提交 d545f86f 编写于 作者: Y yilingfeng 提交者: yukon

[ROCKETMQ-111] Fix possible MQClientException when query message before today,...

[ROCKETMQ-111] Fix possible MQClientException when query message before today, closes apache/incubator-rocketmq#69
上级 72897cb9
...@@ -52,7 +52,7 @@ public class MessageClientIDSetter { ...@@ -52,7 +52,7 @@ public class MessageClientIDSetter {
Calendar cal = Calendar.getInstance(); Calendar cal = Calendar.getInstance();
cal.setTimeInMillis(millis); cal.setTimeInMillis(millis);
cal.set(Calendar.DAY_OF_MONTH, 1); cal.set(Calendar.DAY_OF_MONTH, 1);
cal.set(Calendar.HOUR, 0); cal.set(Calendar.HOUR_OF_DAY, 0);
cal.set(Calendar.MINUTE, 0); cal.set(Calendar.MINUTE, 0);
cal.set(Calendar.SECOND, 0); cal.set(Calendar.SECOND, 0);
cal.set(Calendar.MILLISECOND, 0); cal.set(Calendar.MILLISECOND, 0);
...@@ -74,7 +74,7 @@ public class MessageClientIDSetter { ...@@ -74,7 +74,7 @@ public class MessageClientIDSetter {
Calendar cal = Calendar.getInstance(); Calendar cal = Calendar.getInstance();
long now = cal.getTimeInMillis(); long now = cal.getTimeInMillis();
cal.set(Calendar.DAY_OF_MONTH, 1); cal.set(Calendar.DAY_OF_MONTH, 1);
cal.set(Calendar.HOUR, 0); cal.set(Calendar.HOUR_OF_DAY, 0);
cal.set(Calendar.MINUTE, 0); cal.set(Calendar.MINUTE, 0);
cal.set(Calendar.SECOND, 0); cal.set(Calendar.SECOND, 0);
cal.set(Calendar.MILLISECOND, 0); cal.set(Calendar.MILLISECOND, 0);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册