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: 凌楚 <[email protected]> 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 {
