You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2022/07/15 03:28:05 UTC
[rocketmq-apis] 32/38: Remove Publishing#compress_body_threshold
This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a commit to branch java
in repository https://gitbox.apache.org/repos/asf/rocketmq-apis.git
commit c4b163835c44a1932e694d376026c7619aec6eaa
Author: 凌楚 <ya...@alibaba-inc.com>
AuthorDate: Mon Jul 11 11:29:05 2022 +0800
Remove Publishing#compress_body_threshold
---
src/main/java/apache/rocketmq/v2/MQService.java | 177 ++++++++++-----------
src/main/java/apache/rocketmq/v2/Publishing.java | 122 ++------------
.../apache/rocketmq/v2/PublishingOrBuilder.java | 17 +-
.../proto/apache/rocketmq/v2/service.proto | 11 +-
4 files changed, 107 insertions(+), 220 deletions(-)
diff --git a/src/main/java/apache/rocketmq/v2/MQService.java b/src/main/java/apache/rocketmq/v2/MQService.java
index 9434d98..e6d3a12 100644
--- a/src/main/java/apache/rocketmq/v2/MQService.java
+++ b/src/main/java/apache/rocketmq/v2/MQService.java
@@ -269,94 +269,93 @@ public final class MQService {
"7\n\rmessage_queue\030\001 \001(\0132 .apache.rocketmq" +
".v2.MessageQueue\022C\n\036orphaned_transaction" +
"al_message\030\002 \001(\0132\033.apache.rocketmq.v2.Me" +
- "ssage\022\026\n\016transaction_id\030\003 \001(\t\"\221\001\n\nPublis" +
- "hing\022,\n\006topics\030\001 \003(\0132\034.apache.rocketmq.v" +
- "2.Resource\022\037\n\027compress_body_threshold\030\002 " +
- "\001(\005\022\025\n\rmax_body_size\030\003 \001(\005\022\035\n\025validate_m" +
- "essage_type\030\004 \001(\010\"\263\002\n\014Subscription\0220\n\005gr" +
- "oup\030\001 \001(\0132\034.apache.rocketmq.v2.ResourceH" +
- "\000\210\001\001\022<\n\rsubscriptions\030\002 \003(\0132%.apache.roc" +
- "ketmq.v2.SubscriptionEntry\022\021\n\004fifo\030\003 \001(\010" +
- "H\001\210\001\001\022\037\n\022receive_batch_size\030\004 \001(\005H\002\210\001\001\022<" +
- "\n\024long_polling_timeout\030\005 \001(\0132\031.google.pr" +
- "otobuf.DurationH\003\210\001\001B\010\n\006_groupB\007\n\005_fifoB" +
- "\025\n\023_receive_batch_sizeB\027\n\025_long_polling_" +
- "timeout\"Y\n\006Metric\022\n\n\002on\030\001 \001(\010\0225\n\tendpoin" +
- "ts\030\002 \001(\0132\035.apache.rocketmq.v2.EndpointsH" +
- "\000\210\001\001B\014\n\n_endpoints\"\220\004\n\010Settings\0228\n\013clien" +
- "t_type\030\001 \001(\0162\036.apache.rocketmq.v2.Client" +
- "TypeH\001\210\001\001\0228\n\014access_point\030\002 \001(\0132\035.apache" +
- ".rocketmq.v2.EndpointsH\002\210\001\001\022<\n\016backoff_p" +
- "olicy\030\003 \001(\0132\037.apache.rocketmq.v2.RetryPo" +
- "licyH\003\210\001\001\0227\n\017request_timeout\030\004 \001(\0132\031.goo" +
- "gle.protobuf.DurationH\004\210\001\001\0224\n\npublishing" +
- "\030\005 \001(\0132\036.apache.rocketmq.v2.PublishingH\000" +
- "\0228\n\014subscription\030\006 \001(\0132 .apache.rocketmq" +
- ".v2.SubscriptionH\000\022*\n\nuser_agent\030\007 \001(\0132\026" +
- ".apache.rocketmq.v2.UA\022*\n\006metric\030\010 \001(\0132\032" +
- ".apache.rocketmq.v2.MetricB\t\n\007pub_subB\016\n" +
- "\014_client_typeB\017\n\r_access_pointB\021\n\017_backo" +
- "ff_policyB\022\n\020_request_timeout\"\252\004\n\020Teleme" +
- "tryCommand\022/\n\006status\030\001 \001(\0132\032.apache.rock" +
- "etmq.v2.StatusH\001\210\001\001\0220\n\010settings\030\002 \001(\0132\034." +
- "apache.rocketmq.v2.SettingsH\000\022B\n\022thread_" +
- "stack_trace\030\003 \001(\0132$.apache.rocketmq.v2.T" +
- "hreadStackTraceH\000\022H\n\025verify_message_resu" +
- "lt\030\004 \001(\0132\'.apache.rocketmq.v2.VerifyMess" +
- "ageResultH\000\022e\n$recover_orphaned_transact" +
- "ion_command\030\005 \001(\01325.apache.rocketmq.v2.R" +
- "ecoverOrphanedTransactionCommandH\000\022\\\n pr" +
- "int_thread_stack_trace_command\030\006 \001(\01320.a" +
- "pache.rocketmq.v2.PrintThreadStackTraceC" +
- "ommandH\000\022J\n\026verify_message_command\030\007 \001(\013" +
- "2(.apache.rocketmq.v2.VerifyMessageComma" +
- "ndH\000B\t\n\007commandB\t\n\007_status\"\\\n\036NotifyClie" +
- "ntTerminationRequest\0220\n\005group\030\001 \001(\0132\034.ap" +
- "ache.rocketmq.v2.ResourceH\000\210\001\001B\010\n\006_group" +
- "\"M\n\037NotifyClientTerminationResponse\022*\n\006s" +
- "tatus\030\001 \001(\0132\032.apache.rocketmq.v2.Status\"" +
- "\335\001\n\036ChangeInvisibleDurationRequest\022+\n\005gr" +
- "oup\030\001 \001(\0132\034.apache.rocketmq.v2.Resource\022" +
- "+\n\005topic\030\002 \001(\0132\034.apache.rocketmq.v2.Reso" +
- "urce\022\026\n\016receipt_handle\030\003 \001(\t\0225\n\022invisibl" +
- "e_duration\030\004 \001(\0132\031.google.protobuf.Durat" +
- "ion\022\022\n\nmessage_id\030\005 \001(\t\"e\n\037ChangeInvisib" +
- "leDurationResponse\022*\n\006status\030\001 \001(\0132\032.apa" +
- "che.rocketmq.v2.Status\022\026\n\016receipt_handle" +
- "\030\002 \001(\t2\340\t\n\020MessagingService\022]\n\nQueryRout" +
- "e\022%.apache.rocketmq.v2.QueryRouteRequest" +
- "\032&.apache.rocketmq.v2.QueryRouteResponse" +
- "\"\000\022Z\n\tHeartbeat\022$.apache.rocketmq.v2.Hea" +
- "rtbeatRequest\032%.apache.rocketmq.v2.Heart" +
- "beatResponse\"\000\022`\n\013SendMessage\022&.apache.r" +
- "ocketmq.v2.SendMessageRequest\032\'.apache.r" +
- "ocketmq.v2.SendMessageResponse\"\000\022l\n\017Quer" +
- "yAssignment\022*.apache.rocketmq.v2.QueryAs" +
- "signmentRequest\032+.apache.rocketmq.v2.Que" +
- "ryAssignmentResponse\"\000\022k\n\016ReceiveMessage" +
- "\022).apache.rocketmq.v2.ReceiveMessageRequ" +
- "est\032*.apache.rocketmq.v2.ReceiveMessageR" +
- "esponse\"\0000\001\022]\n\nAckMessage\022%.apache.rocke" +
- "tmq.v2.AckMessageRequest\032&.apache.rocket" +
- "mq.v2.AckMessageResponse\"\000\022\234\001\n\037ForwardMe" +
- "ssageToDeadLetterQueue\022:.apache.rocketmq" +
- ".v2.ForwardMessageToDeadLetterQueueReque" +
- "st\032;.apache.rocketmq.v2.ForwardMessageTo" +
- "DeadLetterQueueResponse\"\000\022i\n\016EndTransact" +
- "ion\022).apache.rocketmq.v2.EndTransactionR" +
- "equest\032*.apache.rocketmq.v2.EndTransacti" +
- "onResponse\"\000\022]\n\tTelemetry\022$.apache.rocke" +
- "tmq.v2.TelemetryCommand\032$.apache.rocketm" +
- "q.v2.TelemetryCommand\"\000(\0010\001\022\204\001\n\027NotifyCl" +
- "ientTermination\0222.apache.rocketmq.v2.Not" +
- "ifyClientTerminationRequest\0323.apache.roc" +
- "ketmq.v2.NotifyClientTerminationResponse" +
- "\"\000\022\204\001\n\027ChangeInvisibleDuration\0222.apache." +
- "rocketmq.v2.ChangeInvisibleDurationReque" +
- "st\0323.apache.rocketmq.v2.ChangeInvisibleD" +
- "urationResponse\"\000B<\n\022apache.rocketmq.v2B" +
- "\tMQServiceP\001\240\001\001\330\001\001\252\002\022Apache.Rocketmq.V2b" +
- "\006proto3"
+ "ssage\022\026\n\016transaction_id\030\003 \001(\t\"p\n\nPublish" +
+ "ing\022,\n\006topics\030\001 \003(\0132\034.apache.rocketmq.v2" +
+ ".Resource\022\025\n\rmax_body_size\030\002 \001(\005\022\035\n\025vali" +
+ "date_message_type\030\003 \001(\010\"\263\002\n\014Subscription" +
+ "\0220\n\005group\030\001 \001(\0132\034.apache.rocketmq.v2.Res" +
+ "ourceH\000\210\001\001\022<\n\rsubscriptions\030\002 \003(\0132%.apac" +
+ "he.rocketmq.v2.SubscriptionEntry\022\021\n\004fifo" +
+ "\030\003 \001(\010H\001\210\001\001\022\037\n\022receive_batch_size\030\004 \001(\005H" +
+ "\002\210\001\001\022<\n\024long_polling_timeout\030\005 \001(\0132\031.goo" +
+ "gle.protobuf.DurationH\003\210\001\001B\010\n\006_groupB\007\n\005" +
+ "_fifoB\025\n\023_receive_batch_sizeB\027\n\025_long_po" +
+ "lling_timeout\"Y\n\006Metric\022\n\n\002on\030\001 \001(\010\0225\n\te" +
+ "ndpoints\030\002 \001(\0132\035.apache.rocketmq.v2.Endp" +
+ "ointsH\000\210\001\001B\014\n\n_endpoints\"\220\004\n\010Settings\0228\n" +
+ "\013client_type\030\001 \001(\0162\036.apache.rocketmq.v2." +
+ "ClientTypeH\001\210\001\001\0228\n\014access_point\030\002 \001(\0132\035." +
+ "apache.rocketmq.v2.EndpointsH\002\210\001\001\022<\n\016bac" +
+ "koff_policy\030\003 \001(\0132\037.apache.rocketmq.v2.R" +
+ "etryPolicyH\003\210\001\001\0227\n\017request_timeout\030\004 \001(\013" +
+ "2\031.google.protobuf.DurationH\004\210\001\001\0224\n\npubl" +
+ "ishing\030\005 \001(\0132\036.apache.rocketmq.v2.Publis" +
+ "hingH\000\0228\n\014subscription\030\006 \001(\0132 .apache.ro" +
+ "cketmq.v2.SubscriptionH\000\022*\n\nuser_agent\030\007" +
+ " \001(\0132\026.apache.rocketmq.v2.UA\022*\n\006metric\030\010" +
+ " \001(\0132\032.apache.rocketmq.v2.MetricB\t\n\007pub_" +
+ "subB\016\n\014_client_typeB\017\n\r_access_pointB\021\n\017" +
+ "_backoff_policyB\022\n\020_request_timeout\"\252\004\n\020" +
+ "TelemetryCommand\022/\n\006status\030\001 \001(\0132\032.apach" +
+ "e.rocketmq.v2.StatusH\001\210\001\001\0220\n\010settings\030\002 " +
+ "\001(\0132\034.apache.rocketmq.v2.SettingsH\000\022B\n\022t" +
+ "hread_stack_trace\030\003 \001(\0132$.apache.rocketm" +
+ "q.v2.ThreadStackTraceH\000\022H\n\025verify_messag" +
+ "e_result\030\004 \001(\0132\'.apache.rocketmq.v2.Veri" +
+ "fyMessageResultH\000\022e\n$recover_orphaned_tr" +
+ "ansaction_command\030\005 \001(\01325.apache.rocketm" +
+ "q.v2.RecoverOrphanedTransactionCommandH\000" +
+ "\022\\\n print_thread_stack_trace_command\030\006 \001" +
+ "(\01320.apache.rocketmq.v2.PrintThreadStack" +
+ "TraceCommandH\000\022J\n\026verify_message_command" +
+ "\030\007 \001(\0132(.apache.rocketmq.v2.VerifyMessag" +
+ "eCommandH\000B\t\n\007commandB\t\n\007_status\"\\\n\036Noti" +
+ "fyClientTerminationRequest\0220\n\005group\030\001 \001(" +
+ "\0132\034.apache.rocketmq.v2.ResourceH\000\210\001\001B\010\n\006" +
+ "_group\"M\n\037NotifyClientTerminationRespons" +
+ "e\022*\n\006status\030\001 \001(\0132\032.apache.rocketmq.v2.S" +
+ "tatus\"\335\001\n\036ChangeInvisibleDurationRequest" +
+ "\022+\n\005group\030\001 \001(\0132\034.apache.rocketmq.v2.Res" +
+ "ource\022+\n\005topic\030\002 \001(\0132\034.apache.rocketmq.v" +
+ "2.Resource\022\026\n\016receipt_handle\030\003 \001(\t\0225\n\022in" +
+ "visible_duration\030\004 \001(\0132\031.google.protobuf" +
+ ".Duration\022\022\n\nmessage_id\030\005 \001(\t\"e\n\037ChangeI" +
+ "nvisibleDurationResponse\022*\n\006status\030\001 \001(\013" +
+ "2\032.apache.rocketmq.v2.Status\022\026\n\016receipt_" +
+ "handle\030\002 \001(\t2\340\t\n\020MessagingService\022]\n\nQue" +
+ "ryRoute\022%.apache.rocketmq.v2.QueryRouteR" +
+ "equest\032&.apache.rocketmq.v2.QueryRouteRe" +
+ "sponse\"\000\022Z\n\tHeartbeat\022$.apache.rocketmq." +
+ "v2.HeartbeatRequest\032%.apache.rocketmq.v2" +
+ ".HeartbeatResponse\"\000\022`\n\013SendMessage\022&.ap" +
+ "ache.rocketmq.v2.SendMessageRequest\032\'.ap" +
+ "ache.rocketmq.v2.SendMessageResponse\"\000\022l" +
+ "\n\017QueryAssignment\022*.apache.rocketmq.v2.Q" +
+ "ueryAssignmentRequest\032+.apache.rocketmq." +
+ "v2.QueryAssignmentResponse\"\000\022k\n\016ReceiveM" +
+ "essage\022).apache.rocketmq.v2.ReceiveMessa" +
+ "geRequest\032*.apache.rocketmq.v2.ReceiveMe" +
+ "ssageResponse\"\0000\001\022]\n\nAckMessage\022%.apache" +
+ ".rocketmq.v2.AckMessageRequest\032&.apache." +
+ "rocketmq.v2.AckMessageResponse\"\000\022\234\001\n\037For" +
+ "wardMessageToDeadLetterQueue\022:.apache.ro" +
+ "cketmq.v2.ForwardMessageToDeadLetterQueu" +
+ "eRequest\032;.apache.rocketmq.v2.ForwardMes" +
+ "sageToDeadLetterQueueResponse\"\000\022i\n\016EndTr" +
+ "ansaction\022).apache.rocketmq.v2.EndTransa" +
+ "ctionRequest\032*.apache.rocketmq.v2.EndTra" +
+ "nsactionResponse\"\000\022]\n\tTelemetry\022$.apache" +
+ ".rocketmq.v2.TelemetryCommand\032$.apache.r" +
+ "ocketmq.v2.TelemetryCommand\"\000(\0010\001\022\204\001\n\027No" +
+ "tifyClientTermination\0222.apache.rocketmq." +
+ "v2.NotifyClientTerminationRequest\0323.apac" +
+ "he.rocketmq.v2.NotifyClientTerminationRe" +
+ "sponse\"\000\022\204\001\n\027ChangeInvisibleDuration\0222.a" +
+ "pache.rocketmq.v2.ChangeInvisibleDuratio" +
+ "nRequest\0323.apache.rocketmq.v2.ChangeInvi" +
+ "sibleDurationResponse\"\000B<\n\022apache.rocket" +
+ "mq.v2B\tMQServiceP\001\240\001\001\330\001\001\252\002\022Apache.Rocket" +
+ "mq.V2b\006proto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,
@@ -514,7 +513,7 @@ public final class MQService {
internal_static_apache_rocketmq_v2_Publishing_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_Publishing_descriptor,
- new java.lang.String[] { "Topics", "CompressBodyThreshold", "MaxBodySize", "ValidateMessageType", });
+ new java.lang.String[] { "Topics", "MaxBodySize", "ValidateMessageType", });
internal_static_apache_rocketmq_v2_Subscription_descriptor =
getDescriptor().getMessageTypes().get(25);
internal_static_apache_rocketmq_v2_Subscription_fieldAccessorTable = new
diff --git a/src/main/java/apache/rocketmq/v2/Publishing.java b/src/main/java/apache/rocketmq/v2/Publishing.java
index ce31284..bea77d1 100644
--- a/src/main/java/apache/rocketmq/v2/Publishing.java
+++ b/src/main/java/apache/rocketmq/v2/Publishing.java
@@ -61,15 +61,10 @@ private static final long serialVersionUID = 0L;
}
case 16: {
- compressBodyThreshold_ = input.readInt32();
- break;
- }
- case 24: {
-
maxBodySize_ = input.readInt32();
break;
}
- case 32: {
+ case 24: {
validateMessageType_ = input.readBool();
break;
@@ -179,25 +174,7 @@ private static final long serialVersionUID = 0L;
return topics_.get(index);
}
- public static final int COMPRESS_BODY_THRESHOLD_FIELD_NUMBER = 2;
- private int compressBodyThreshold_;
- /**
- * <pre>
- * Publishing settings below here are from server, it is essential for
- * server to push.
- * Body of message will be deflated if its size in bytes exceeds the
- * threshold.
- * </pre>
- *
- * <code>int32 compress_body_threshold = 2;</code>
- * @return The compressBodyThreshold.
- */
- @java.lang.Override
- public int getCompressBodyThreshold() {
- return compressBodyThreshold_;
- }
-
- public static final int MAX_BODY_SIZE_FIELD_NUMBER = 3;
+ public static final int MAX_BODY_SIZE_FIELD_NUMBER = 2;
private int maxBodySize_;
/**
* <pre>
@@ -206,7 +183,7 @@ private static final long serialVersionUID = 0L;
* client-side check validation.
* </pre>
*
- * <code>int32 max_body_size = 3;</code>
+ * <code>int32 max_body_size = 2;</code>
* @return The maxBodySize.
*/
@java.lang.Override
@@ -214,7 +191,7 @@ private static final long serialVersionUID = 0L;
return maxBodySize_;
}
- public static final int VALIDATE_MESSAGE_TYPE_FIELD_NUMBER = 4;
+ public static final int VALIDATE_MESSAGE_TYPE_FIELD_NUMBER = 3;
private boolean validateMessageType_;
/**
* <pre>
@@ -222,7 +199,7 @@ private static final long serialVersionUID = 0L;
* with messageQueue's `accept_message_types` before publising.
* </pre>
*
- * <code>bool validate_message_type = 4;</code>
+ * <code>bool validate_message_type = 3;</code>
* @return The validateMessageType.
*/
@java.lang.Override
@@ -247,14 +224,11 @@ private static final long serialVersionUID = 0L;
for (int i = 0; i < topics_.size(); i++) {
output.writeMessage(1, topics_.get(i));
}
- if (compressBodyThreshold_ != 0) {
- output.writeInt32(2, compressBodyThreshold_);
- }
if (maxBodySize_ != 0) {
- output.writeInt32(3, maxBodySize_);
+ output.writeInt32(2, maxBodySize_);
}
if (validateMessageType_ != false) {
- output.writeBool(4, validateMessageType_);
+ output.writeBool(3, validateMessageType_);
}
unknownFields.writeTo(output);
}
@@ -269,17 +243,13 @@ private static final long serialVersionUID = 0L;
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(1, topics_.get(i));
}
- if (compressBodyThreshold_ != 0) {
- size += com.google.protobuf.CodedOutputStream
- .computeInt32Size(2, compressBodyThreshold_);
- }
if (maxBodySize_ != 0) {
size += com.google.protobuf.CodedOutputStream
- .computeInt32Size(3, maxBodySize_);
+ .computeInt32Size(2, maxBodySize_);
}
if (validateMessageType_ != false) {
size += com.google.protobuf.CodedOutputStream
- .computeBoolSize(4, validateMessageType_);
+ .computeBoolSize(3, validateMessageType_);
}
size += unknownFields.getSerializedSize();
memoizedSize = size;
@@ -298,8 +268,6 @@ private static final long serialVersionUID = 0L;
if (!getTopicsList()
.equals(other.getTopicsList())) return false;
- if (getCompressBodyThreshold()
- != other.getCompressBodyThreshold()) return false;
if (getMaxBodySize()
!= other.getMaxBodySize()) return false;
if (getValidateMessageType()
@@ -319,8 +287,6 @@ private static final long serialVersionUID = 0L;
hash = (37 * hash) + TOPICS_FIELD_NUMBER;
hash = (53 * hash) + getTopicsList().hashCode();
}
- hash = (37 * hash) + COMPRESS_BODY_THRESHOLD_FIELD_NUMBER;
- hash = (53 * hash) + getCompressBodyThreshold();
hash = (37 * hash) + MAX_BODY_SIZE_FIELD_NUMBER;
hash = (53 * hash) + getMaxBodySize();
hash = (37 * hash) + VALIDATE_MESSAGE_TYPE_FIELD_NUMBER;
@@ -466,8 +432,6 @@ private static final long serialVersionUID = 0L;
} else {
topicsBuilder_.clear();
}
- compressBodyThreshold_ = 0;
-
maxBodySize_ = 0;
validateMessageType_ = false;
@@ -508,7 +472,6 @@ private static final long serialVersionUID = 0L;
} else {
result.topics_ = topicsBuilder_.build();
}
- result.compressBodyThreshold_ = compressBodyThreshold_;
result.maxBodySize_ = maxBodySize_;
result.validateMessageType_ = validateMessageType_;
onBuilt();
@@ -585,9 +548,6 @@ private static final long serialVersionUID = 0L;
}
}
}
- if (other.getCompressBodyThreshold() != 0) {
- setCompressBodyThreshold(other.getCompressBodyThreshold());
- }
if (other.getMaxBodySize() != 0) {
setMaxBodySize(other.getMaxBodySize());
}
@@ -972,58 +932,6 @@ private static final long serialVersionUID = 0L;
return topicsBuilder_;
}
- private int compressBodyThreshold_ ;
- /**
- * <pre>
- * Publishing settings below here are from server, it is essential for
- * server to push.
- * Body of message will be deflated if its size in bytes exceeds the
- * threshold.
- * </pre>
- *
- * <code>int32 compress_body_threshold = 2;</code>
- * @return The compressBodyThreshold.
- */
- @java.lang.Override
- public int getCompressBodyThreshold() {
- return compressBodyThreshold_;
- }
- /**
- * <pre>
- * Publishing settings below here are from server, it is essential for
- * server to push.
- * Body of message will be deflated if its size in bytes exceeds the
- * threshold.
- * </pre>
- *
- * <code>int32 compress_body_threshold = 2;</code>
- * @param value The compressBodyThreshold to set.
- * @return This builder for chaining.
- */
- public Builder setCompressBodyThreshold(int value) {
-
- compressBodyThreshold_ = value;
- onChanged();
- return this;
- }
- /**
- * <pre>
- * Publishing settings below here are from server, it is essential for
- * server to push.
- * Body of message will be deflated if its size in bytes exceeds the
- * threshold.
- * </pre>
- *
- * <code>int32 compress_body_threshold = 2;</code>
- * @return This builder for chaining.
- */
- public Builder clearCompressBodyThreshold() {
-
- compressBodyThreshold_ = 0;
- onChanged();
- return this;
- }
-
private int maxBodySize_ ;
/**
* <pre>
@@ -1032,7 +940,7 @@ private static final long serialVersionUID = 0L;
* client-side check validation.
* </pre>
*
- * <code>int32 max_body_size = 3;</code>
+ * <code>int32 max_body_size = 2;</code>
* @return The maxBodySize.
*/
@java.lang.Override
@@ -1046,7 +954,7 @@ private static final long serialVersionUID = 0L;
* client-side check validation.
* </pre>
*
- * <code>int32 max_body_size = 3;</code>
+ * <code>int32 max_body_size = 2;</code>
* @param value The maxBodySize to set.
* @return This builder for chaining.
*/
@@ -1063,7 +971,7 @@ private static final long serialVersionUID = 0L;
* client-side check validation.
* </pre>
*
- * <code>int32 max_body_size = 3;</code>
+ * <code>int32 max_body_size = 2;</code>
* @return This builder for chaining.
*/
public Builder clearMaxBodySize() {
@@ -1080,7 +988,7 @@ private static final long serialVersionUID = 0L;
* with messageQueue's `accept_message_types` before publising.
* </pre>
*
- * <code>bool validate_message_type = 4;</code>
+ * <code>bool validate_message_type = 3;</code>
* @return The validateMessageType.
*/
@java.lang.Override
@@ -1093,7 +1001,7 @@ private static final long serialVersionUID = 0L;
* with messageQueue's `accept_message_types` before publising.
* </pre>
*
- * <code>bool validate_message_type = 4;</code>
+ * <code>bool validate_message_type = 3;</code>
* @param value The validateMessageType to set.
* @return This builder for chaining.
*/
@@ -1109,7 +1017,7 @@ private static final long serialVersionUID = 0L;
* with messageQueue's `accept_message_types` before publising.
* </pre>
*
- * <code>bool validate_message_type = 4;</code>
+ * <code>bool validate_message_type = 3;</code>
* @return This builder for chaining.
*/
public Builder clearValidateMessageType() {
diff --git a/src/main/java/apache/rocketmq/v2/PublishingOrBuilder.java b/src/main/java/apache/rocketmq/v2/PublishingOrBuilder.java
index 2d5b297..4e1dc32 100644
--- a/src/main/java/apache/rocketmq/v2/PublishingOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/PublishingOrBuilder.java
@@ -61,19 +61,6 @@ public interface PublishingOrBuilder extends
apache.rocketmq.v2.ResourceOrBuilder getTopicsOrBuilder(
int index);
- /**
- * <pre>
- * Publishing settings below here are from server, it is essential for
- * server to push.
- * Body of message will be deflated if its size in bytes exceeds the
- * threshold.
- * </pre>
- *
- * <code>int32 compress_body_threshold = 2;</code>
- * @return The compressBodyThreshold.
- */
- int getCompressBodyThreshold();
-
/**
* <pre>
* If the message body size exceeds `max_body_size`, broker servers would
@@ -81,7 +68,7 @@ public interface PublishingOrBuilder extends
* client-side check validation.
* </pre>
*
- * <code>int32 max_body_size = 3;</code>
+ * <code>int32 max_body_size = 2;</code>
* @return The maxBodySize.
*/
int getMaxBodySize();
@@ -92,7 +79,7 @@ public interface PublishingOrBuilder extends
* with messageQueue's `accept_message_types` before publising.
* </pre>
*
- * <code>bool validate_message_type = 4;</code>
+ * <code>bool validate_message_type = 3;</code>
* @return The validateMessageType.
*/
boolean getValidateMessageType();
diff --git a/src/main/resources/proto/apache/rocketmq/v2/service.proto b/src/main/resources/proto/apache/rocketmq/v2/service.proto
index 1624654..598c70c 100644
--- a/src/main/resources/proto/apache/rocketmq/v2/service.proto
+++ b/src/main/resources/proto/apache/rocketmq/v2/service.proto
@@ -195,21 +195,14 @@ message Publishing {
// List of topics to which messages will publish to.
repeated Resource topics = 1;
- // Publishing settings below here are from server, it is essential for
- // server to push.
- //
- // Body of message will be deflated if its size in bytes exceeds the
- // threshold.
- int32 compress_body_threshold = 2;
-
// If the message body size exceeds `max_body_size`, broker servers would
// reject the request. As a result, it is advisable that Producer performs
// client-side check validation.
- int32 max_body_size = 3;
+ int32 max_body_size = 2;
// When `validate_message_type` flag set `false`, no need to validate message's type
// with messageQueue's `accept_message_types` before publising.
- bool validate_message_type = 4;
+ bool validate_message_type = 3;
}
message Subscription {