|
60 | 60 | import java.util.HashSet; |
61 | 61 | import java.util.Iterator; |
62 | 62 | import java.util.List; |
63 | | -import java.util.Objects; |
64 | 63 | import java.util.Set; |
65 | 64 | import java.util.concurrent.TimeUnit; |
66 | 65 | import java.util.concurrent.atomic.AtomicLong; |
@@ -106,15 +105,15 @@ public RemotingCommand processRequest(final ChannelHandlerContext ctx, RemotingC |
106 | 105 |
|
107 | 106 | final long beginTimeMills = brokerController.getMessageStore().now(); |
108 | 107 | Channel channel = ctx.channel(); |
109 | | - request.addExtFieldIfNotExist(BORN_TIME, String.valueOf(System.currentTimeMillis())); |
110 | | - if (Objects.equals(request.getExtFields().get(BORN_TIME), "0")) { |
111 | | - request.addExtField(BORN_TIME, String.valueOf(System.currentTimeMillis())); |
112 | | - } |
113 | 108 | RemotingCommand response = RemotingCommand.createResponseCommand(PopLiteMessageResponseHeader.class); |
114 | 109 | response.setOpaque(request.getOpaque()); |
115 | 110 |
|
116 | 111 | final PopLiteMessageRequestHeader requestHeader = |
117 | 112 | request.decodeCommandCustomHeader(PopLiteMessageRequestHeader.class, true); |
| 113 | + if (requestHeader.getBornTime() == 0) { |
| 114 | + request.addExtField(BORN_TIME, String.valueOf(beginTimeMills)); |
| 115 | + requestHeader.setBornTime(beginTimeMills); |
| 116 | + } |
118 | 117 | final PopLiteMessageResponseHeader responseHeader = (PopLiteMessageResponseHeader) response.readCustomHeader(); |
119 | 118 | RemotingCommand preCheckResponse = preCheck(ctx, requestHeader, response); |
120 | 119 | if (preCheckResponse != null) { |
|
0 commit comments