aop
aop copied to clipboard
[bug] Fix consumer subscribe problem for basic consume
Motivation
Currently, the async method consumer.handleFlow(DEFAULT_CONSUMER_PERMIT); in basic consume command operation doesn't handle in an async way, this may cause NPE problem in the subsequent process.
Modifications
Start handle flow after subscription adds consumer finished.
Does this pull request potentially affect one of the following parts:
If yes was chosen, please highlight the changes
- Dependencies (does it add or upgrade a dependency): (yes / no)
- The public API: (yes / no)
- The schema: (yes / no / don't know)
- The default values of configurations: (yes / no)
- The wire protocol: (yes / no)
- The rest endpoints: (yes / no)
- The admin cli options: (yes / no)
- Anything that affects deployment: (yes / no / don't know)
Documentation
Check the box below.
Need to update docs?
-
[ ]
doc-required(If you need help on updating docs, create a doc issue)
-
[x]
no-need-doc(Please explain why)
-
[ ]
doc(If this PR contains doc changes)