Repository: incubator-rocketmq Updated Branches: refs/heads/develop 72897cb92 -> d545f86f6
[ROCKETMQ-111] Fix possible MQClientException when query message before today, closes apache/incubator-rocketmq#69 Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/d545f86f Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/d545f86f Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/d545f86f Branch: refs/heads/develop Commit: d545f86f66e51bf87f837d707feeb7cabc76de8d Parents: 72897cb Author: yilingfeng <[email protected]> Authored: Tue Feb 28 19:22:00 2017 +0800 Committer: yukon <[email protected]> Committed: Tue Feb 28 19:22:00 2017 +0800 ---------------------------------------------------------------------- .../apache/rocketmq/common/message/MessageClientIDSetter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d545f86f/common/src/main/java/org/apache/rocketmq/common/message/MessageClientIDSetter.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/message/MessageClientIDSetter.java b/common/src/main/java/org/apache/rocketmq/common/message/MessageClientIDSetter.java index fe83cdd..a1d3ede 100644 --- a/common/src/main/java/org/apache/rocketmq/common/message/MessageClientIDSetter.java +++ b/common/src/main/java/org/apache/rocketmq/common/message/MessageClientIDSetter.java @@ -52,7 +52,7 @@ public class MessageClientIDSetter { Calendar cal = Calendar.getInstance(); cal.setTimeInMillis(millis); 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.SECOND, 0); cal.set(Calendar.MILLISECOND, 0); @@ -74,7 +74,7 @@ public class MessageClientIDSetter { Calendar cal = Calendar.getInstance(); long now = cal.getTimeInMillis(); 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.SECOND, 0); cal.set(Calendar.MILLISECOND, 0);
