[rocketmq-clients] branch master updated: Do not check body size in MessageBuilderImpl#setBody (#64)

[aa...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new 8202ef8  Do not check body size in MessageBuilderImpl#setBody (#64)
8202ef8 is described below

commit 8202ef89972ea7a57d5dafe1d7839b5bb6cac4b7
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Wed Jul 20 14:01:17 2022 +0800

    Do not check body size in MessageBuilderImpl#setBody (#64)
---
 .../org/apache/rocketmq/client/java/message/MessageBuilderImpl.java    | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageBuilderImpl.java b/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageBuilderImpl.java
index b53f20d..d83d8c8 100644
--- a/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageBuilderImpl.java
+++ b/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageBuilderImpl.java
@@ -33,7 +33,6 @@ import org.apache.rocketmq.client.apis.message.MessageBuilder;
 
 public class MessageBuilderImpl implements MessageBuilder {
     public static final Pattern TOPIC_PATTERN = Pattern.compile("^[%a-zA-Z0-9_-]+$");
-    private static final int MESSAGE_BODY_LENGTH_THRESHOLD = 1024 * 1024 * 4;
 
     private String topic = null;
     private byte[] body = null;
@@ -65,8 +64,6 @@ public class MessageBuilderImpl implements MessageBuilder {
     @Override
     public MessageBuilder setBody(byte[] body) {
         checkNotNull(body, "body should not be null");
-        checkArgument(body.length <= MESSAGE_BODY_LENGTH_THRESHOLD, "message body length exceeds the threshold " +
-            "[threshold=%s bytes]", MESSAGE_BODY_LENGTH_THRESHOLD);
         this.body = body.clone();
         return this;
     }