Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[ISSUE #8963] Fix code36 request sent to ns #8964

Merged
merged 2 commits into from
Nov 27, 2024
Merged

Conversation

yx9o
Copy link
Contributor

@yx9o yx9o commented Nov 20, 2024

Fixes #8963 .

@codecov-commenter
Copy link

codecov-commenter commented Nov 20, 2024

Codecov Report

Attention: Patch coverage is 50.00000% with 2 lines in your changes missing coverage. Please review.

Project coverage is 47.66%. Comparing base (9202de3) to head (ef8deed).
Report is 8 commits behind head on develop.

Files with missing lines Patch % Lines
...lient/impl/consumer/DefaultMQPullConsumerImpl.java 0.00% 2 Missing ⚠️
Additional details and impacted files
@@              Coverage Diff              @@
##             develop    #8964      +/-   ##
=============================================
- Coverage      47.73%   47.66%   -0.08%     
+ Complexity     11774    11769       -5     
=============================================
  Files           1304     1304              
  Lines          91118    91201      +83     
  Branches       11692    11717      +25     
=============================================
- Hits           43495    43470      -25     
- Misses         42264    42345      +81     
- Partials        5359     5386      +27     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

yuz10
yuz10 previously approved these changes Nov 21, 2024
RongtongJin
RongtongJin previously approved these changes Nov 22, 2024
@@ -767,6 +767,9 @@ private void sendMessageBack(MessageExt msg, int delayLevel, final String broker
} else {
String brokerAddr = (null != brokerName) ? this.mQClientFactory.findBrokerAddressInPublish(brokerName)
: RemotingHelper.parseSocketAddressAddr(msg.getStoreHost());
if (UtilAll.isBlank(brokerAddr)) {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Will this code have the same issue ?

String brokerAddr = (null != destBrokerName) ? this.mQClientFactory.findBrokerAddressInPublish(destBrokerName)
: RemotingHelper.parseSocketAddressAddr(msg.getStoreHost());

Copy link
Contributor Author

@yx9o yx9o Nov 25, 2024

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Logically, it is the same as push and will have this problem, but notice that it has been marked as @Deprecated. Does it need to be modified?

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

IMO, maybe someone still using this, it would be better to modify.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

OK, I will change it together.

@yx9o yx9o dismissed stale reviews from RongtongJin and yuz10 via ef8deed November 26, 2024 14:08
@yuz10 yuz10 merged commit cd5071b into apache:develop Nov 27, 2024
11 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

[Bug] CONSUMER_SEND_MSG_BACK request may be sent to ns
6 participants