aluomaidi opened a new issue #303: send message always failed
URL: https://github.com/apache/rocketmq/issues/303
 
 
   **BUG REPORT**
   
   1. A error happend 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:
   
   - Set a domain which is dynamically generated for brokerIP1, and the domain 
doesn't parse successfully immediately.
   
   - The first few send requests failed due to domain parse error which result 
in a NullPointException when invoke method msgInner.getStoreHostBytes,then the 
following messages will send successfully while the domain can use in the end.
   
   - The send request always failed although domain is normal. CommitLog's 
member variable beginTimeInLock which is always reset to zero after append a 
message to commit log successful doesn't reset to zero as the 
NullPointException,  so the server think page cache is busy and reject all send 
request.
   
   2. rocketmq:4.2, java:1.8.
   
   3. I think beginTimeInLock = 0 should stay with putMessageLock.unlock() in 
finally statement int CommitLog's putMessage() method.
   

----------------------------------------------------------------
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:
[email protected]


With regards,
Apache Git Services

Reply via email to