aluomaidi opened a new issue #285: About a REJECTREQUEST Question URL: https://github.com/apache/rocketmq/issues/285 A error occured while send a message,the following request will be rejected by server and throw an exception:[REJECTREQUEST]system busy, start flow control for a while. - I saw the source code and find the error occured in mappedFile.appendMessage() within commitLog.putMessage() - commitLog.putMessage() exit without reset the member variable beginTimeInLock,so DefaultMessageStore.isOSPageCacheBusy() will return true - the method NettyRemotingAbstract.processRequestCommand() will revoke SendMessageProcessor.rejectRequest() and return true - the method NettyRemotingAbstract.processRequestCommand() retur nresponse with "[REJECTREQUEST]system busy, start flow control for a while" SO, I think it is a bug.The member variable beginTimeInLock should be reset to be 0 at finally block.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
