RGB-loop opened a new pull request, #1079:
URL: https://github.com/apache/rocketmq-clients/pull/1079

   
   
   ### Which Issue(s) This PR Fixes
   
![20250821-160747](https://github.com/user-attachments/assets/bd73aa29-5b40-4626-b75f-0f857a0731a7)
   AttributeError during async simple consumer shutdown when pending futures 
exist
   Problem: When shutting down an async simple consumer with unprocessed 
futures, the code attempts to submit callbacks to a null 
__client_callback_executor, causing AttributeError: 'NoneType' object has no 
attribute 'submit'.
   
   ### Brief Description
   
   Add null check in _submit_callback to gracefully handle cases where external 
code attempts to submit callbacks after the client has been shut down and the 
callback executor is None.
   
   ### How Did You Test This Change?
   
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to