未验证 提交 fa935e83 编写于 作者: S Silverados 提交者: GitHub

fix document mistake (#3304)

message.getBody() return byte[], so change to length.
上级 9013cc5f
......@@ -57,7 +57,7 @@ public class ListSplitter implements Iterator<List<Message>> {
return currIndex;
}
private int calcMessageSize(Message message) {
int tmpSize = message.getTopic().length() + message.getBody().length();
int tmpSize = message.getTopic().length() + message.getBody().length;
Map<String, String> properties = message.getProperties();
for (Map.Entry<String, String> entry : properties.entrySet()) {
tmpSize += entry.getKey().length() + entry.getValue().length();
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册