-
Notifications
You must be signed in to change notification settings - Fork 11.8k
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 #7699] Add namespace v2 in client #7700
Conversation
dfb26ae
to
710d3bc
Compare
Codecov ReportAttention:
Additional details and impacted files@@ Coverage Diff @@
## develop #7700 +/- ##
=============================================
- Coverage 43.17% 43.15% -0.02%
- Complexity 9797 9820 +23
=============================================
Files 1165 1167 +2
Lines 84477 84595 +118
Branches 10966 10984 +18
=============================================
+ Hits 36474 36509 +35
- Misses 43473 43551 +78
- Partials 4530 4535 +5 ☔ View full report in Codecov by Sentry. |
@@ -1377,7 +1377,7 @@ public CompletableFuture<PullResult> pullMessageFromSpecificBrokerAsync(String b | |||
requestHeader.setSubVersion(System.currentTimeMillis()); | |||
requestHeader.setMaxMsgBytes(Integer.MAX_VALUE); | |||
requestHeader.setExpressionType(ExpressionType.TAG); | |||
requestHeader.setBname(brokerName); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This shall result in a backward compatible issue.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Only the function signature has been modified here, without changes to the internal fields. The field name remains 'bname', so there should be no compatibility issues.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
See
rocketmq/remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcRequestHeader.java
Lines 43 to 49 in 710d3bc
public String getBrokerName() { | |
return bname; | |
} | |
public void setBrokerName(String brokerName) { | |
this.bname = brokerName; | |
} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
lgtm
Which Issue(s) This PR Fixes
Fixes #7699
Brief Description
Add namespace v2 in client
How Did You Test This Change?