We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
Message
1 parent f120645 commit aa908ceCopy full SHA for aa908ce
common/src/main/java/org/apache/rocketmq/common/message/Message.java
@@ -128,14 +128,10 @@ public String getKeys() {
128
return this.getProperty(MessageConst.PROPERTY_KEYS);
129
}
130
131
- public void setKeys(Collection<String> keys) {
132
- StringBuilder sb = new StringBuilder();
133
- for (String k : keys) {
134
- sb.append(k);
135
- sb.append(MessageConst.KEY_SEPARATOR);
136
- }
+ public void setKeys(Collection<String> keyCollection) {
+ String keys = String.join(MessageConst.KEY_SEPARATOR, keyCollection);
137
138
- this.setKeys(sb.toString().trim());
+ this.setKeys(keys);
139
140
141
public int getDelayTimeLevel() {
0 commit comments