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:27:40 UTC
[rocketmq-apis] 07/38: Remove redundant fields
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 9480b9666c56e8b934c5a4098c00f5f87f5394ac
Author: 凌楚 <ya...@alibaba-inc.com>
AuthorDate: Tue Apr 12 14:22:37 2022 +0800
Remove redundant fields
---
src/main/java/apache/rocketmq/v2/MQService.java | 312 ++++++-----
.../apache/rocketmq/v2/ReceiveMessageRequest.java | 590 ++++-----------------
.../v2/ReceiveMessageRequestOrBuilder.java | 56 +-
.../proto/apache/rocketmq/v2/service.proto | 8 +-
4 files changed, 278 insertions(+), 688 deletions(-)
diff --git a/src/main/java/apache/rocketmq/v2/MQService.java b/src/main/java/apache/rocketmq/v2/MQService.java
index f52724d..387d1dc 100644
--- a/src/main/java/apache/rocketmq/v2/MQService.java
+++ b/src/main/java/apache/rocketmq/v2/MQService.java
@@ -218,168 +218,166 @@ public final class MQService {
"pache.rocketmq.v2.Resource\"z\n\027QueryAssig" +
"nmentResponse\022*\n\006status\030\001 \001(\0132\032.apache.r" +
"ocketmq.v2.Status\0223\n\013assignments\030\002 \003(\0132\036" +
- ".apache.rocketmq.v2.Assignment\"\210\003\n\025Recei" +
+ ".apache.rocketmq.v2.Assignment\"\245\002\n\025Recei" +
"veMessageRequest\022+\n\005group\030\001 \001(\0132\034.apache" +
".rocketmq.v2.Resource\0227\n\rmessage_queue\030\002" +
" \001(\0132 .apache.rocketmq.v2.MessageQueue\022?" +
"\n\021filter_expression\030\003 \001(\0132$.apache.rocke" +
- "tmq.v2.FilterExpression\022<\n\030initializatio" +
- "n_timestamp\030\004 \001(\0132\032.google.protobuf.Time" +
- "stamp\022\022\n\nbatch_size\030\005 \001(\005\0225\n\022invisible_d" +
- "uration\030\006 \001(\0132\031.google.protobuf.Duration" +
- "\0221\n\016await_duration\030\007 \001(\0132\031.google.protob" +
- "uf.Duration\022\014\n\004fifo\030\010 \001(\010\"\342\001\n\026ReceiveMes" +
- "sageResponse\022*\n\006status\030\001 \001(\0132\032.apache.ro" +
- "cketmq.v2.Status\022-\n\010messages\030\002 \003(\0132\033.apa" +
- "che.rocketmq.v2.Message\0226\n\022delivery_time" +
- "stamp\030\003 \001(\0132\032.google.protobuf.Timestamp\022" +
- "5\n\022invisible_duration\030\004 \001(\0132\031.google.pro" +
- "tobuf.Duration\"\231\001\n\021AckMessageRequest\022+\n\005" +
- "group\030\001 \001(\0132\034.apache.rocketmq.v2.Resourc" +
- "e\022+\n\005topic\030\002 \001(\0132\034.apache.rocketmq.v2.Re" +
- "source\022\026\n\016receipt_handle\030\003 \001(\t\022\022\n\nmessag" +
- "e_id\030\004 \001(\t\"@\n\022AckMessageResponse\022*\n\006stat" +
- "us\030\001 \001(\0132\032.apache.rocketmq.v2.Status\"\264\001\n" +
- "\022NackMessageRequest\022+\n\005group\030\001 \001(\0132\034.apa" +
- "che.rocketmq.v2.Resource\022+\n\005topic\030\002 \001(\0132" +
- "\034.apache.rocketmq.v2.Resource\022\026\n\016receipt" +
- "_handle\030\003 \001(\t\022\022\n\nmessage_id\030\004 \001(\t\022\030\n\020del" +
- "ivery_attempt\030\005 \001(\005\"A\n\023NackMessageRespon" +
- "se\022*\n\006status\030\001 \001(\0132\032.apache.rocketmq.v2." +
- "Status\"\347\001\n&ForwardMessageToDeadLetterQue" +
- "ueRequest\022+\n\005group\030\001 \001(\0132\034.apache.rocket" +
+ "tmq.v2.FilterExpression\022\022\n\nbatch_size\030\004 " +
+ "\001(\005\022:\n\022invisible_duration\030\005 \001(\0132\031.google" +
+ ".protobuf.DurationH\000\210\001\001B\025\n\023_invisible_du" +
+ "ration\"\342\001\n\026ReceiveMessageResponse\022*\n\006sta" +
+ "tus\030\001 \001(\0132\032.apache.rocketmq.v2.Status\022-\n" +
+ "\010messages\030\002 \003(\0132\033.apache.rocketmq.v2.Mes" +
+ "sage\0226\n\022delivery_timestamp\030\003 \001(\0132\032.googl" +
+ "e.protobuf.Timestamp\0225\n\022invisible_durati" +
+ "on\030\004 \001(\0132\031.google.protobuf.Duration\"\231\001\n\021" +
+ "AckMessageRequest\022+\n\005group\030\001 \001(\0132\034.apach" +
+ "e.rocketmq.v2.Resource\022+\n\005topic\030\002 \001(\0132\034." +
+ "apache.rocketmq.v2.Resource\022\026\n\016receipt_h" +
+ "andle\030\003 \001(\t\022\022\n\nmessage_id\030\004 \001(\t\"@\n\022AckMe" +
+ "ssageResponse\022*\n\006status\030\001 \001(\0132\032.apache.r" +
+ "ocketmq.v2.Status\"\264\001\n\022NackMessageRequest" +
+ "\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\022\022\n\nme" +
+ "ssage_id\030\004 \001(\t\022\030\n\020delivery_attempt\030\005 \001(\005" +
+ "\"A\n\023NackMessageResponse\022*\n\006status\030\001 \001(\0132" +
+ "\032.apache.rocketmq.v2.Status\"\347\001\n&ForwardM" +
+ "essageToDeadLetterQueueRequest\022+\n\005group\030" +
+ "\001 \001(\0132\034.apache.rocketmq.v2.Resource\022+\n\005t" +
+ "opic\030\002 \001(\0132\034.apache.rocketmq.v2.Resource" +
+ "\022\026\n\016receipt_handle\030\003 \001(\t\022\022\n\nmessage_id\030\004" +
+ " \001(\t\022\030\n\020delivery_attempt\030\005 \001(\005\022\035\n\025max_de" +
+ "livery_attempts\030\006 \001(\005\"U\n\'ForwardMessageT" +
+ "oDeadLetterQueueResponse\022*\n\006status\030\001 \001(\013" +
+ "2\032.apache.rocketmq.v2.Status\"N\n\020Heartbea" +
+ "tRequest\0220\n\005group\030\001 \001(\0132\034.apache.rocketm" +
+ "q.v2.ResourceH\000\210\001\001B\010\n\006_group\"?\n\021Heartbea" +
+ "tResponse\022*\n\006status\030\001 \001(\0132\032.apache.rocke" +
+ "tmq.v2.Status\"\375\001\n\025EndTransactionRequest\022" +
+ "+\n\005topic\030\001 \001(\0132\034.apache.rocketmq.v2.Reso" +
+ "urce\022\022\n\nmessage_id\030\002 \001(\t\022\026\n\016transaction_" +
+ "id\030\003 \001(\t\022=\n\nresolution\030\004 \001(\0162).apache.ro" +
+ "cketmq.v2.TransactionResolution\0225\n\006sourc" +
+ "e\030\005 \001(\0162%.apache.rocketmq.v2.Transaction" +
+ "Source\022\025\n\rtrace_context\030\006 \001(\t\"D\n\026EndTran" +
+ "sactionResponse\022*\n\006status\030\001 \001(\0132\032.apache" +
+ ".rocketmq.v2.Status\"\264\001\n\022QueryOffsetReque" +
+ "st\0227\n\rmessage_queue\030\001 \001(\0132 .apache.rocke" +
+ "tmq.v2.MessageQueue\0225\n\006policy\030\002 \001(\0162%.ap" +
+ "ache.rocketmq.v2.QueryOffsetPolicy\022.\n\nti" +
+ "me_point\030\003 \001(\0132\032.google.protobuf.Timesta" +
+ "mp\"Q\n\023QueryOffsetResponse\022*\n\006status\030\001 \001(" +
+ "\0132\032.apache.rocketmq.v2.Status\022\016\n\006offset\030" +
+ "\002 \001(\003\"\216\002\n\022PullMessageRequest\022+\n\005group\030\001 " +
+ "\001(\0132\034.apache.rocketmq.v2.Resource\0227\n\rmes" +
+ "sage_queue\030\002 \001(\0132 .apache.rocketmq.v2.Me" +
+ "ssageQueue\022\016\n\006offset\030\003 \001(\003\022\022\n\nbatch_size" +
+ "\030\004 \001(\005\022-\n\nawait_time\030\005 \001(\0132\031.google.prot" +
+ "obuf.Duration\022?\n\021filter_expression\030\006 \001(\013" +
+ "2$.apache.rocketmq.v2.FilterExpression\"\255" +
+ "\001\n\023PullMessageResponse\022*\n\006status\030\001 \001(\0132\032" +
+ ".apache.rocketmq.v2.Status\022\022\n\nmin_offset" +
+ "\030\002 \001(\003\022\023\n\013next_offset\030\003 \001(\003\022\022\n\nmax_offse" +
+ "t\030\004 \001(\003\022-\n\010messages\030\005 \003(\0132\033.apache.rocke" +
+ "tmq.v2.Message\"-\n\034PrintThreadStackTraceC" +
+ "ommand\022\r\n\005nonce\030\001 \001(\t\"\205\001\n\020ThreadStackTra" +
+ "ce\022\r\n\005nonce\030\001 \001(\t\022*\n\006status\030\002 \001(\0132\032.apac" +
+ "he.rocketmq.v2.Status\022\037\n\022thread_stack_tr" +
+ "ace\030\003 \001(\tH\000\210\001\001B\025\n\023_thread_stack_trace\"S\n" +
+ "\024VerifyMessageCommand\022\r\n\005nonce\030\001 \001(\t\022,\n\007" +
+ "message\030\002 \001(\0132\033.apache.rocketmq.v2.Messa" +
+ "ge\"P\n\023VerifyMessageResult\022\r\n\005nonce\030\001 \001(\t" +
+ "\022*\n\006status\030\002 \001(\0132\032.apache.rocketmq.v2.St" +
+ "atus\"\200\001\n!RecoverOrphanedTransactionComma" +
+ "nd\022C\n\036orphaned_transactional_message\030\001 \001" +
+ "(\0132\033.apache.rocketmq.v2.Message\022\026\n\016trans" +
+ "action_id\030\002 \001(\t\"\316\001\n\010Settings\0227\n\npublishi" +
+ "ng\030\001 \001(\0132\036.apache.rocketmq.v2.Publishing" +
+ "H\000\210\001\001\022;\n\014subscription\030\002 \001(\0132 .apache.roc" +
+ "ketmq.v2.SubscriptionH\001\210\001\001\022,\n\007tracing\030\003 " +
+ "\001(\0132\033.apache.rocketmq.v2.TracingB\r\n\013_pub" +
+ "lishingB\017\n\r_subscription\"\353\001\n\016ClientSetti" +
+ "ngs\022\r\n\005nonce\030\001 \001(\t\0220\n\tdirection\030\002 \001(\0162\035." +
+ "apache.rocketmq.v2.Direction\0223\n\013client_t" +
+ "ype\030\003 \001(\0162\036.apache.rocketmq.v2.ClientTyp" +
+ "e\0223\n\014access_point\030\004 \001(\0132\035.apache.rocketm" +
+ "q.v2.Endpoints\022.\n\010settings\030\005 \001(\0132\034.apach" +
+ "e.rocketmq.v2.Settings\"\214\001\n\031ClientOverwri" +
+ "ttenSettings\022\r\n\005nonce\030\001 \001(\t\0220\n\tdirection" +
+ "\030\002 \001(\0162\035.apache.rocketmq.v2.Direction\022.\n" +
+ "\010settings\030\003 \001(\0132\034.apache.rocketmq.v2.Set" +
+ "tings\"\321\004\n\020TelemetryCommand\022=\n\017client_set" +
+ "tings\030\001 \001(\0132\".apache.rocketmq.v2.ClientS" +
+ "ettingsH\000\022B\n\022thread_stack_trace\030\002 \001(\0132$." +
+ "apache.rocketmq.v2.ThreadStackTraceH\000\022H\n" +
+ "\025verify_message_result\030\003 \001(\0132\'.apache.ro" +
+ "cketmq.v2.VerifyMessageResultH\000\022T\n\033clien" +
+ "t_overwritten_settings\030\004 \001(\0132-.apache.ro" +
+ "cketmq.v2.ClientOverwrittenSettingsH\000\022e\n" +
+ "$recover_orphaned_transaction_command\030\005 " +
+ "\001(\01325.apache.rocketmq.v2.RecoverOrphaned" +
+ "TransactionCommandH\000\022\\\n print_thread_sta" +
+ "ck_trace_command\030\006 \001(\01320.apache.rocketmq" +
+ ".v2.PrintThreadStackTraceCommandH\000\022J\n\026ve" +
+ "rify_message_command\030\007 \001(\0132(.apache.rock" +
+ "etmq.v2.VerifyMessageCommandH\000B\t\n\007comman" +
+ "d\"\\\n\036NotifyClientTerminationRequest\0220\n\005g" +
+ "roup\030\001 \001(\0132\034.apache.rocketmq.v2.Resource" +
+ "H\000\210\001\001B\010\n\006_group\"M\n\037NotifyClientTerminati" +
+ "onResponse\022*\n\006status\030\001 \001(\0132\032.apache.rock" +
+ "etmq.v2.Status\"\311\001\n\036ChangeInvisibleDurati" +
+ "onRequest\022+\n\005group\030\001 \001(\0132\034.apache.rocket" +
"mq.v2.Resource\022+\n\005topic\030\002 \001(\0132\034.apache.r" +
"ocketmq.v2.Resource\022\026\n\016receipt_handle\030\003 " +
- "\001(\t\022\022\n\nmessage_id\030\004 \001(\t\022\030\n\020delivery_atte" +
- "mpt\030\005 \001(\005\022\035\n\025max_delivery_attempts\030\006 \001(\005" +
- "\"U\n\'ForwardMessageToDeadLetterQueueRespo" +
- "nse\022*\n\006status\030\001 \001(\0132\032.apache.rocketmq.v2" +
- ".Status\"N\n\020HeartbeatRequest\0220\n\005group\030\001 \001" +
- "(\0132\034.apache.rocketmq.v2.ResourceH\000\210\001\001B\010\n" +
- "\006_group\"?\n\021HeartbeatResponse\022*\n\006status\030\001" +
- " \001(\0132\032.apache.rocketmq.v2.Status\"\375\001\n\025End" +
- "TransactionRequest\022+\n\005topic\030\001 \001(\0132\034.apac" +
- "he.rocketmq.v2.Resource\022\022\n\nmessage_id\030\002 " +
- "\001(\t\022\026\n\016transaction_id\030\003 \001(\t\022=\n\nresolutio" +
- "n\030\004 \001(\0162).apache.rocketmq.v2.Transaction" +
- "Resolution\0225\n\006source\030\005 \001(\0162%.apache.rock" +
- "etmq.v2.TransactionSource\022\025\n\rtrace_conte" +
- "xt\030\006 \001(\t\"D\n\026EndTransactionResponse\022*\n\006st" +
- "atus\030\001 \001(\0132\032.apache.rocketmq.v2.Status\"\264" +
- "\001\n\022QueryOffsetRequest\0227\n\rmessage_queue\030\001" +
- " \001(\0132 .apache.rocketmq.v2.MessageQueue\0225" +
- "\n\006policy\030\002 \001(\0162%.apache.rocketmq.v2.Quer" +
- "yOffsetPolicy\022.\n\ntime_point\030\003 \001(\0132\032.goog" +
- "le.protobuf.Timestamp\"Q\n\023QueryOffsetResp" +
- "onse\022*\n\006status\030\001 \001(\0132\032.apache.rocketmq.v" +
- "2.Status\022\016\n\006offset\030\002 \001(\003\"\216\002\n\022PullMessage" +
- "Request\022+\n\005group\030\001 \001(\0132\034.apache.rocketmq" +
- ".v2.Resource\0227\n\rmessage_queue\030\002 \001(\0132 .ap" +
- "ache.rocketmq.v2.MessageQueue\022\016\n\006offset\030" +
- "\003 \001(\003\022\022\n\nbatch_size\030\004 \001(\005\022-\n\nawait_time\030" +
- "\005 \001(\0132\031.google.protobuf.Duration\022?\n\021filt" +
- "er_expression\030\006 \001(\0132$.apache.rocketmq.v2" +
- ".FilterExpression\"\255\001\n\023PullMessageRespons" +
- "e\022*\n\006status\030\001 \001(\0132\032.apache.rocketmq.v2.S" +
- "tatus\022\022\n\nmin_offset\030\002 \001(\003\022\023\n\013next_offset" +
- "\030\003 \001(\003\022\022\n\nmax_offset\030\004 \001(\003\022-\n\010messages\030\005" +
- " \003(\0132\033.apache.rocketmq.v2.Message\"-\n\034Pri" +
- "ntThreadStackTraceCommand\022\r\n\005nonce\030\001 \001(\t" +
- "\"\205\001\n\020ThreadStackTrace\022\r\n\005nonce\030\001 \001(\t\022*\n\006" +
- "status\030\002 \001(\0132\032.apache.rocketmq.v2.Status" +
- "\022\037\n\022thread_stack_trace\030\003 \001(\tH\000\210\001\001B\025\n\023_th" +
- "read_stack_trace\"S\n\024VerifyMessageCommand" +
- "\022\r\n\005nonce\030\001 \001(\t\022,\n\007message\030\002 \001(\0132\033.apach" +
- "e.rocketmq.v2.Message\"P\n\023VerifyMessageRe" +
- "sult\022\r\n\005nonce\030\001 \001(\t\022*\n\006status\030\002 \001(\0132\032.ap" +
- "ache.rocketmq.v2.Status\"\200\001\n!RecoverOrpha" +
- "nedTransactionCommand\022C\n\036orphaned_transa" +
- "ctional_message\030\001 \001(\0132\033.apache.rocketmq." +
- "v2.Message\022\026\n\016transaction_id\030\002 \001(\t\"\316\001\n\010S" +
- "ettings\0227\n\npublishing\030\001 \001(\0132\036.apache.roc" +
- "ketmq.v2.PublishingH\000\210\001\001\022;\n\014subscription" +
- "\030\002 \001(\0132 .apache.rocketmq.v2.Subscription" +
- "H\001\210\001\001\022,\n\007tracing\030\003 \001(\0132\033.apache.rocketmq" +
- ".v2.TracingB\r\n\013_publishingB\017\n\r_subscript" +
- "ion\"\353\001\n\016ClientSettings\022\r\n\005nonce\030\001 \001(\t\0220\n" +
- "\tdirection\030\002 \001(\0162\035.apache.rocketmq.v2.Di" +
- "rection\0223\n\013client_type\030\003 \001(\0162\036.apache.ro" +
- "cketmq.v2.ClientType\0223\n\014access_point\030\004 \001" +
- "(\0132\035.apache.rocketmq.v2.Endpoints\022.\n\010set" +
- "tings\030\005 \001(\0132\034.apache.rocketmq.v2.Setting" +
- "s\"\214\001\n\031ClientOverwrittenSettings\022\r\n\005nonce" +
- "\030\001 \001(\t\0220\n\tdirection\030\002 \001(\0162\035.apache.rocke" +
- "tmq.v2.Direction\022.\n\010settings\030\003 \001(\0132\034.apa" +
- "che.rocketmq.v2.Settings\"\321\004\n\020TelemetryCo" +
- "mmand\022=\n\017client_settings\030\001 \001(\0132\".apache." +
- "rocketmq.v2.ClientSettingsH\000\022B\n\022thread_s" +
- "tack_trace\030\002 \001(\0132$.apache.rocketmq.v2.Th" +
- "readStackTraceH\000\022H\n\025verify_message_resul" +
- "t\030\003 \001(\0132\'.apache.rocketmq.v2.VerifyMessa" +
- "geResultH\000\022T\n\033client_overwritten_setting" +
- "s\030\004 \001(\0132-.apache.rocketmq.v2.ClientOverw" +
- "rittenSettingsH\000\022e\n$recover_orphaned_tra" +
- "nsaction_command\030\005 \001(\01325.apache.rocketmq" +
- ".v2.RecoverOrphanedTransactionCommandH\000\022" +
- "\\\n print_thread_stack_trace_command\030\006 \001(" +
- "\01320.apache.rocketmq.v2.PrintThreadStackT" +
- "raceCommandH\000\022J\n\026verify_message_command\030" +
- "\007 \001(\0132(.apache.rocketmq.v2.VerifyMessage" +
- "CommandH\000B\t\n\007command\"\\\n\036NotifyClientTerm" +
- "inationRequest\0220\n\005group\030\001 \001(\0132\034.apache.r" +
- "ocketmq.v2.ResourceH\000\210\001\001B\010\n\006_group\"M\n\037No" +
- "tifyClientTerminationResponse\022*\n\006status\030" +
- "\001 \001(\0132\032.apache.rocketmq.v2.Status\"\311\001\n\036Ch" +
- "angeInvisibleDurationRequest\022+\n\005group\030\001 " +
- "\001(\0132\034.apache.rocketmq.v2.Resource\022+\n\005top" +
- "ic\030\002 \001(\0132\034.apache.rocketmq.v2.Resource\022\026" +
- "\n\016receipt_handle\030\003 \001(\t\0225\n\022invisible_dura" +
- "tion\030\004 \001(\0132\031.google.protobuf.Duration\"e\n" +
- "\037ChangeInvisibleDurationResponse\022*\n\006stat" +
- "us\030\001 \001(\0132\032.apache.rocketmq.v2.Status\022\026\n\016" +
- "receipt_handle\030\002 \001(\t*A\n\tDirection\022\031\n\025DIR" +
- "ECTION_UNSPECIFIED\020\000\022\013\n\007REQUEST\020\001\022\014\n\010RES" +
- "PONSE\020\0022\204\014\n\020MessagingService\022]\n\nQueryRou" +
- "te\022%.apache.rocketmq.v2.QueryRouteReques" +
- "t\032&.apache.rocketmq.v2.QueryRouteRespons" +
- "e\"\000\022Z\n\tHeartbeat\022$.apache.rocketmq.v2.He" +
- "artbeatRequest\032%.apache.rocketmq.v2.Hear" +
- "tbeatResponse\"\000\022`\n\013SendMessage\022&.apache." +
- "rocketmq.v2.SendMessageRequest\032\'.apache." +
- "rocketmq.v2.SendMessageResponse\"\000\022l\n\017Que" +
- "ryAssignment\022*.apache.rocketmq.v2.QueryA" +
- "ssignmentRequest\032+.apache.rocketmq.v2.Qu" +
- "eryAssignmentResponse\"\000\022i\n\016ReceiveMessag" +
- "e\022).apache.rocketmq.v2.ReceiveMessageReq" +
- "uest\032*.apache.rocketmq.v2.ReceiveMessage" +
- "Response\"\000\022]\n\nAckMessage\022%.apache.rocket" +
- "mq.v2.AckMessageRequest\032&.apache.rocketm" +
- "q.v2.AckMessageResponse\"\000\022`\n\013NackMessage" +
- "\022&.apache.rocketmq.v2.NackMessageRequest" +
- "\032\'.apache.rocketmq.v2.NackMessageRespons" +
- "e\"\000\022\234\001\n\037ForwardMessageToDeadLetterQueue\022" +
- ":.apache.rocketmq.v2.ForwardMessageToDea" +
- "dLetterQueueRequest\032;.apache.rocketmq.v2" +
- ".ForwardMessageToDeadLetterQueueResponse" +
- "\"\000\022i\n\016EndTransaction\022).apache.rocketmq.v" +
- "2.EndTransactionRequest\032*.apache.rocketm" +
- "q.v2.EndTransactionResponse\"\000\022`\n\013QueryOf" +
- "fset\022&.apache.rocketmq.v2.QueryOffsetReq" +
- "uest\032\'.apache.rocketmq.v2.QueryOffsetRes" +
- "ponse\"\000\022`\n\013PullMessage\022&.apache.rocketmq" +
- ".v2.PullMessageRequest\032\'.apache.rocketmq" +
- ".v2.PullMessageResponse\"\000\022]\n\tTelemetry\022$" +
- ".apache.rocketmq.v2.TelemetryCommand\032$.a" +
- "pache.rocketmq.v2.TelemetryCommand\"\000(\0010\001" +
- "\022\204\001\n\027NotifyClientTermination\0222.apache.ro" +
- "cketmq.v2.NotifyClientTerminationRequest" +
- "\0323.apache.rocketmq.v2.NotifyClientTermin" +
- "ationResponse\"\000\022\204\001\n\027ChangeInvisibleDurat" +
- "ion\0222.apache.rocketmq.v2.ChangeInvisible" +
- "DurationRequest\0323.apache.rocketmq.v2.Cha" +
- "ngeInvisibleDurationResponse\"\000B<\n\022apache" +
- ".rocketmq.v2B\tMQServiceP\001\240\001\001\330\001\001\252\002\022Apache" +
- ".Rocketmq.V2b\006proto3"
+ "\001(\t\0225\n\022invisible_duration\030\004 \001(\0132\031.google" +
+ ".protobuf.Duration\"e\n\037ChangeInvisibleDur" +
+ "ationResponse\022*\n\006status\030\001 \001(\0132\032.apache.r" +
+ "ocketmq.v2.Status\022\026\n\016receipt_handle\030\002 \001(" +
+ "\t*A\n\tDirection\022\031\n\025DIRECTION_UNSPECIFIED\020" +
+ "\000\022\013\n\007REQUEST\020\001\022\014\n\010RESPONSE\020\0022\204\014\n\020Messagi" +
+ "ngService\022]\n\nQueryRoute\022%.apache.rocketm" +
+ "q.v2.QueryRouteRequest\032&.apache.rocketmq" +
+ ".v2.QueryRouteResponse\"\000\022Z\n\tHeartbeat\022$." +
+ "apache.rocketmq.v2.HeartbeatRequest\032%.ap" +
+ "ache.rocketmq.v2.HeartbeatResponse\"\000\022`\n\013" +
+ "SendMessage\022&.apache.rocketmq.v2.SendMes" +
+ "sageRequest\032\'.apache.rocketmq.v2.SendMes" +
+ "sageResponse\"\000\022l\n\017QueryAssignment\022*.apac" +
+ "he.rocketmq.v2.QueryAssignmentRequest\032+." +
+ "apache.rocketmq.v2.QueryAssignmentRespon" +
+ "se\"\000\022i\n\016ReceiveMessage\022).apache.rocketmq" +
+ ".v2.ReceiveMessageRequest\032*.apache.rocke" +
+ "tmq.v2.ReceiveMessageResponse\"\000\022]\n\nAckMe" +
+ "ssage\022%.apache.rocketmq.v2.AckMessageReq" +
+ "uest\032&.apache.rocketmq.v2.AckMessageResp" +
+ "onse\"\000\022`\n\013NackMessage\022&.apache.rocketmq." +
+ "v2.NackMessageRequest\032\'.apache.rocketmq." +
+ "v2.NackMessageResponse\"\000\022\234\001\n\037ForwardMess" +
+ "ageToDeadLetterQueue\022:.apache.rocketmq.v" +
+ "2.ForwardMessageToDeadLetterQueueRequest" +
+ "\032;.apache.rocketmq.v2.ForwardMessageToDe" +
+ "adLetterQueueResponse\"\000\022i\n\016EndTransactio" +
+ "n\022).apache.rocketmq.v2.EndTransactionReq" +
+ "uest\032*.apache.rocketmq.v2.EndTransaction" +
+ "Response\"\000\022`\n\013QueryOffset\022&.apache.rocke" +
+ "tmq.v2.QueryOffsetRequest\032\'.apache.rocke" +
+ "tmq.v2.QueryOffsetResponse\"\000\022`\n\013PullMess" +
+ "age\022&.apache.rocketmq.v2.PullMessageRequ" +
+ "est\032\'.apache.rocketmq.v2.PullMessageResp" +
+ "onse\"\000\022]\n\tTelemetry\022$.apache.rocketmq.v2" +
+ ".TelemetryCommand\032$.apache.rocketmq.v2.T" +
+ "elemetryCommand\"\000(\0010\001\022\204\001\n\027NotifyClientTe" +
+ "rmination\0222.apache.rocketmq.v2.NotifyCli" +
+ "entTerminationRequest\0323.apache.rocketmq." +
+ "v2.NotifyClientTerminationResponse\"\000\022\204\001\n" +
+ "\027ChangeInvisibleDuration\0222.apache.rocket" +
+ "mq.v2.ChangeInvisibleDurationRequest\0323.a" +
+ "pache.rocketmq.v2.ChangeInvisibleDuratio" +
+ "nResponse\"\000B<\n\022apache.rocketmq.v2B\tMQSer" +
+ "viceP\001\240\001\001\330\001\001\252\002\022Apache.Rocketmq.V2b\006proto" +
+ "3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,
@@ -429,7 +427,7 @@ public final class MQService {
internal_static_apache_rocketmq_v2_ReceiveMessageRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_ReceiveMessageRequest_descriptor,
- new java.lang.String[] { "Group", "MessageQueue", "FilterExpression", "InitializationTimestamp", "BatchSize", "InvisibleDuration", "AwaitDuration", "Fifo", });
+ new java.lang.String[] { "Group", "MessageQueue", "FilterExpression", "BatchSize", "InvisibleDuration", "InvisibleDuration", });
internal_static_apache_rocketmq_v2_ReceiveMessageResponse_descriptor =
getDescriptor().getMessageTypes().get(7);
internal_static_apache_rocketmq_v2_ReceiveMessageResponse_fieldAccessorTable = new
diff --git a/src/main/java/apache/rocketmq/v2/ReceiveMessageRequest.java b/src/main/java/apache/rocketmq/v2/ReceiveMessageRequest.java
index 187cbb3..3122e1c 100644
--- a/src/main/java/apache/rocketmq/v2/ReceiveMessageRequest.java
+++ b/src/main/java/apache/rocketmq/v2/ReceiveMessageRequest.java
@@ -38,6 +38,7 @@ private static final long serialVersionUID = 0L;
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
+ int mutable_bitField0_ = 0;
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder();
try {
@@ -87,27 +88,14 @@ private static final long serialVersionUID = 0L;
break;
}
- case 34: {
- com.google.protobuf.Timestamp.Builder subBuilder = null;
- if (initializationTimestamp_ != null) {
- subBuilder = initializationTimestamp_.toBuilder();
- }
- initializationTimestamp_ = input.readMessage(com.google.protobuf.Timestamp.parser(), extensionRegistry);
- if (subBuilder != null) {
- subBuilder.mergeFrom(initializationTimestamp_);
- initializationTimestamp_ = subBuilder.buildPartial();
- }
-
- break;
- }
- case 40: {
+ case 32: {
batchSize_ = input.readInt32();
break;
}
- case 50: {
+ case 42: {
com.google.protobuf.Duration.Builder subBuilder = null;
- if (invisibleDuration_ != null) {
+ if (((bitField0_ & 0x00000001) != 0)) {
subBuilder = invisibleDuration_.toBuilder();
}
invisibleDuration_ = input.readMessage(com.google.protobuf.Duration.parser(), extensionRegistry);
@@ -115,25 +103,7 @@ private static final long serialVersionUID = 0L;
subBuilder.mergeFrom(invisibleDuration_);
invisibleDuration_ = subBuilder.buildPartial();
}
-
- break;
- }
- case 58: {
- com.google.protobuf.Duration.Builder subBuilder = null;
- if (awaitDuration_ != null) {
- subBuilder = awaitDuration_.toBuilder();
- }
- awaitDuration_ = input.readMessage(com.google.protobuf.Duration.parser(), extensionRegistry);
- if (subBuilder != null) {
- subBuilder.mergeFrom(awaitDuration_);
- awaitDuration_ = subBuilder.buildPartial();
- }
-
- break;
- }
- case 64: {
-
- fifo_ = input.readBool();
+ bitField0_ |= 0x00000001;
break;
}
default: {
@@ -168,6 +138,7 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.ReceiveMessageRequest.class, apache.rocketmq.v2.ReceiveMessageRequest.Builder.class);
}
+ private int bitField0_;
public static final int GROUP_FIELD_NUMBER = 1;
private apache.rocketmq.v2.Resource group_;
/**
@@ -246,36 +217,10 @@ private static final long serialVersionUID = 0L;
return getFilterExpression();
}
- public static final int INITIALIZATION_TIMESTAMP_FIELD_NUMBER = 4;
- private com.google.protobuf.Timestamp initializationTimestamp_;
- /**
- * <code>.google.protobuf.Timestamp initialization_timestamp = 4;</code>
- * @return Whether the initializationTimestamp field is set.
- */
- @java.lang.Override
- public boolean hasInitializationTimestamp() {
- return initializationTimestamp_ != null;
- }
- /**
- * <code>.google.protobuf.Timestamp initialization_timestamp = 4;</code>
- * @return The initializationTimestamp.
- */
- @java.lang.Override
- public com.google.protobuf.Timestamp getInitializationTimestamp() {
- return initializationTimestamp_ == null ? com.google.protobuf.Timestamp.getDefaultInstance() : initializationTimestamp_;
- }
- /**
- * <code>.google.protobuf.Timestamp initialization_timestamp = 4;</code>
- */
- @java.lang.Override
- public com.google.protobuf.TimestampOrBuilder getInitializationTimestampOrBuilder() {
- return getInitializationTimestamp();
- }
-
- public static final int BATCH_SIZE_FIELD_NUMBER = 5;
+ public static final int BATCH_SIZE_FIELD_NUMBER = 4;
private int batchSize_;
/**
- * <code>int32 batch_size = 5;</code>
+ * <code>int32 batch_size = 4;</code>
* @return The batchSize.
*/
@java.lang.Override
@@ -283,18 +228,26 @@ private static final long serialVersionUID = 0L;
return batchSize_;
}
- public static final int INVISIBLE_DURATION_FIELD_NUMBER = 6;
+ public static final int INVISIBLE_DURATION_FIELD_NUMBER = 5;
private com.google.protobuf.Duration invisibleDuration_;
/**
- * <code>.google.protobuf.Duration invisible_duration = 6;</code>
+ * <pre>
+ * Required if client type is simple consumer.
+ * </pre>
+ *
+ * <code>optional .google.protobuf.Duration invisible_duration = 5;</code>
* @return Whether the invisibleDuration field is set.
*/
@java.lang.Override
public boolean hasInvisibleDuration() {
- return invisibleDuration_ != null;
+ return ((bitField0_ & 0x00000001) != 0);
}
/**
- * <code>.google.protobuf.Duration invisible_duration = 6;</code>
+ * <pre>
+ * Required if client type is simple consumer.
+ * </pre>
+ *
+ * <code>optional .google.protobuf.Duration invisible_duration = 5;</code>
* @return The invisibleDuration.
*/
@java.lang.Override
@@ -302,48 +255,15 @@ private static final long serialVersionUID = 0L;
return invisibleDuration_ == null ? com.google.protobuf.Duration.getDefaultInstance() : invisibleDuration_;
}
/**
- * <code>.google.protobuf.Duration invisible_duration = 6;</code>
+ * <pre>
+ * Required if client type is simple consumer.
+ * </pre>
+ *
+ * <code>optional .google.protobuf.Duration invisible_duration = 5;</code>
*/
@java.lang.Override
public com.google.protobuf.DurationOrBuilder getInvisibleDurationOrBuilder() {
- return getInvisibleDuration();
- }
-
- public static final int AWAIT_DURATION_FIELD_NUMBER = 7;
- private com.google.protobuf.Duration awaitDuration_;
- /**
- * <code>.google.protobuf.Duration await_duration = 7;</code>
- * @return Whether the awaitDuration field is set.
- */
- @java.lang.Override
- public boolean hasAwaitDuration() {
- return awaitDuration_ != null;
- }
- /**
- * <code>.google.protobuf.Duration await_duration = 7;</code>
- * @return The awaitDuration.
- */
- @java.lang.Override
- public com.google.protobuf.Duration getAwaitDuration() {
- return awaitDuration_ == null ? com.google.protobuf.Duration.getDefaultInstance() : awaitDuration_;
- }
- /**
- * <code>.google.protobuf.Duration await_duration = 7;</code>
- */
- @java.lang.Override
- public com.google.protobuf.DurationOrBuilder getAwaitDurationOrBuilder() {
- return getAwaitDuration();
- }
-
- public static final int FIFO_FIELD_NUMBER = 8;
- private boolean fifo_;
- /**
- * <code>bool fifo = 8;</code>
- * @return The fifo.
- */
- @java.lang.Override
- public boolean getFifo() {
- return fifo_;
+ return invisibleDuration_ == null ? com.google.protobuf.Duration.getDefaultInstance() : invisibleDuration_;
}
private byte memoizedIsInitialized = -1;
@@ -369,20 +289,11 @@ private static final long serialVersionUID = 0L;
if (filterExpression_ != null) {
output.writeMessage(3, getFilterExpression());
}
- if (initializationTimestamp_ != null) {
- output.writeMessage(4, getInitializationTimestamp());
- }
if (batchSize_ != 0) {
- output.writeInt32(5, batchSize_);
- }
- if (invisibleDuration_ != null) {
- output.writeMessage(6, getInvisibleDuration());
- }
- if (awaitDuration_ != null) {
- output.writeMessage(7, getAwaitDuration());
+ output.writeInt32(4, batchSize_);
}
- if (fifo_ != false) {
- output.writeBool(8, fifo_);
+ if (((bitField0_ & 0x00000001) != 0)) {
+ output.writeMessage(5, getInvisibleDuration());
}
unknownFields.writeTo(output);
}
@@ -405,25 +316,13 @@ private static final long serialVersionUID = 0L;
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(3, getFilterExpression());
}
- if (initializationTimestamp_ != null) {
- size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(4, getInitializationTimestamp());
- }
if (batchSize_ != 0) {
size += com.google.protobuf.CodedOutputStream
- .computeInt32Size(5, batchSize_);
- }
- if (invisibleDuration_ != null) {
- size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(6, getInvisibleDuration());
+ .computeInt32Size(4, batchSize_);
}
- if (awaitDuration_ != null) {
+ if (((bitField0_ & 0x00000001) != 0)) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(7, getAwaitDuration());
- }
- if (fifo_ != false) {
- size += com.google.protobuf.CodedOutputStream
- .computeBoolSize(8, fifo_);
+ .computeMessageSize(5, getInvisibleDuration());
}
size += unknownFields.getSerializedSize();
memoizedSize = size;
@@ -455,11 +354,6 @@ private static final long serialVersionUID = 0L;
if (!getFilterExpression()
.equals(other.getFilterExpression())) return false;
}
- if (hasInitializationTimestamp() != other.hasInitializationTimestamp()) return false;
- if (hasInitializationTimestamp()) {
- if (!getInitializationTimestamp()
- .equals(other.getInitializationTimestamp())) return false;
- }
if (getBatchSize()
!= other.getBatchSize()) return false;
if (hasInvisibleDuration() != other.hasInvisibleDuration()) return false;
@@ -467,13 +361,6 @@ private static final long serialVersionUID = 0L;
if (!getInvisibleDuration()
.equals(other.getInvisibleDuration())) return false;
}
- if (hasAwaitDuration() != other.hasAwaitDuration()) return false;
- if (hasAwaitDuration()) {
- if (!getAwaitDuration()
- .equals(other.getAwaitDuration())) return false;
- }
- if (getFifo()
- != other.getFifo()) return false;
if (!unknownFields.equals(other.unknownFields)) return false;
return true;
}
@@ -497,23 +384,12 @@ private static final long serialVersionUID = 0L;
hash = (37 * hash) + FILTER_EXPRESSION_FIELD_NUMBER;
hash = (53 * hash) + getFilterExpression().hashCode();
}
- if (hasInitializationTimestamp()) {
- hash = (37 * hash) + INITIALIZATION_TIMESTAMP_FIELD_NUMBER;
- hash = (53 * hash) + getInitializationTimestamp().hashCode();
- }
hash = (37 * hash) + BATCH_SIZE_FIELD_NUMBER;
hash = (53 * hash) + getBatchSize();
if (hasInvisibleDuration()) {
hash = (37 * hash) + INVISIBLE_DURATION_FIELD_NUMBER;
hash = (53 * hash) + getInvisibleDuration().hashCode();
}
- if (hasAwaitDuration()) {
- hash = (37 * hash) + AWAIT_DURATION_FIELD_NUMBER;
- hash = (53 * hash) + getAwaitDuration().hashCode();
- }
- hash = (37 * hash) + FIFO_FIELD_NUMBER;
- hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(
- getFifo());
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
return hash;
@@ -642,6 +518,7 @@ private static final long serialVersionUID = 0L;
private void maybeForceBuilderInitialization() {
if (com.google.protobuf.GeneratedMessageV3
.alwaysUseFieldBuilders) {
+ getInvisibleDurationFieldBuilder();
}
}
@java.lang.Override
@@ -665,28 +542,14 @@ private static final long serialVersionUID = 0L;
filterExpression_ = null;
filterExpressionBuilder_ = null;
}
- if (initializationTimestampBuilder_ == null) {
- initializationTimestamp_ = null;
- } else {
- initializationTimestamp_ = null;
- initializationTimestampBuilder_ = null;
- }
batchSize_ = 0;
if (invisibleDurationBuilder_ == null) {
invisibleDuration_ = null;
} else {
- invisibleDuration_ = null;
- invisibleDurationBuilder_ = null;
- }
- if (awaitDurationBuilder_ == null) {
- awaitDuration_ = null;
- } else {
- awaitDuration_ = null;
- awaitDurationBuilder_ = null;
+ invisibleDurationBuilder_.clear();
}
- fifo_ = false;
-
+ bitField0_ = (bitField0_ & ~0x00000001);
return this;
}
@@ -713,6 +576,8 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public apache.rocketmq.v2.ReceiveMessageRequest buildPartial() {
apache.rocketmq.v2.ReceiveMessageRequest result = new apache.rocketmq.v2.ReceiveMessageRequest(this);
+ int from_bitField0_ = bitField0_;
+ int to_bitField0_ = 0;
if (groupBuilder_ == null) {
result.group_ = group_;
} else {
@@ -728,23 +593,16 @@ private static final long serialVersionUID = 0L;
} else {
result.filterExpression_ = filterExpressionBuilder_.build();
}
- if (initializationTimestampBuilder_ == null) {
- result.initializationTimestamp_ = initializationTimestamp_;
- } else {
- result.initializationTimestamp_ = initializationTimestampBuilder_.build();
- }
result.batchSize_ = batchSize_;
- if (invisibleDurationBuilder_ == null) {
- result.invisibleDuration_ = invisibleDuration_;
- } else {
- result.invisibleDuration_ = invisibleDurationBuilder_.build();
- }
- if (awaitDurationBuilder_ == null) {
- result.awaitDuration_ = awaitDuration_;
- } else {
- result.awaitDuration_ = awaitDurationBuilder_.build();
+ if (((from_bitField0_ & 0x00000001) != 0)) {
+ if (invisibleDurationBuilder_ == null) {
+ result.invisibleDuration_ = invisibleDuration_;
+ } else {
+ result.invisibleDuration_ = invisibleDurationBuilder_.build();
+ }
+ to_bitField0_ |= 0x00000001;
}
- result.fifo_ = fifo_;
+ result.bitField0_ = to_bitField0_;
onBuilt();
return result;
}
@@ -802,21 +660,12 @@ private static final long serialVersionUID = 0L;
if (other.hasFilterExpression()) {
mergeFilterExpression(other.getFilterExpression());
}
- if (other.hasInitializationTimestamp()) {
- mergeInitializationTimestamp(other.getInitializationTimestamp());
- }
if (other.getBatchSize() != 0) {
setBatchSize(other.getBatchSize());
}
if (other.hasInvisibleDuration()) {
mergeInvisibleDuration(other.getInvisibleDuration());
}
- if (other.hasAwaitDuration()) {
- mergeAwaitDuration(other.getAwaitDuration());
- }
- if (other.getFifo() != false) {
- setFifo(other.getFifo());
- }
this.mergeUnknownFields(other.unknownFields);
onChanged();
return this;
@@ -845,6 +694,7 @@ private static final long serialVersionUID = 0L;
}
return this;
}
+ private int bitField0_;
private apache.rocketmq.v2.Resource group_;
private com.google.protobuf.SingleFieldBuilderV3<
@@ -1203,128 +1053,9 @@ private static final long serialVersionUID = 0L;
return filterExpressionBuilder_;
}
- private com.google.protobuf.Timestamp initializationTimestamp_;
- private com.google.protobuf.SingleFieldBuilderV3<
- com.google.protobuf.Timestamp, com.google.protobuf.Timestamp.Builder, com.google.protobuf.TimestampOrBuilder> initializationTimestampBuilder_;
- /**
- * <code>.google.protobuf.Timestamp initialization_timestamp = 4;</code>
- * @return Whether the initializationTimestamp field is set.
- */
- public boolean hasInitializationTimestamp() {
- return initializationTimestampBuilder_ != null || initializationTimestamp_ != null;
- }
- /**
- * <code>.google.protobuf.Timestamp initialization_timestamp = 4;</code>
- * @return The initializationTimestamp.
- */
- public com.google.protobuf.Timestamp getInitializationTimestamp() {
- if (initializationTimestampBuilder_ == null) {
- return initializationTimestamp_ == null ? com.google.protobuf.Timestamp.getDefaultInstance() : initializationTimestamp_;
- } else {
- return initializationTimestampBuilder_.getMessage();
- }
- }
- /**
- * <code>.google.protobuf.Timestamp initialization_timestamp = 4;</code>
- */
- public Builder setInitializationTimestamp(com.google.protobuf.Timestamp value) {
- if (initializationTimestampBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- initializationTimestamp_ = value;
- onChanged();
- } else {
- initializationTimestampBuilder_.setMessage(value);
- }
-
- return this;
- }
- /**
- * <code>.google.protobuf.Timestamp initialization_timestamp = 4;</code>
- */
- public Builder setInitializationTimestamp(
- com.google.protobuf.Timestamp.Builder builderForValue) {
- if (initializationTimestampBuilder_ == null) {
- initializationTimestamp_ = builderForValue.build();
- onChanged();
- } else {
- initializationTimestampBuilder_.setMessage(builderForValue.build());
- }
-
- return this;
- }
- /**
- * <code>.google.protobuf.Timestamp initialization_timestamp = 4;</code>
- */
- public Builder mergeInitializationTimestamp(com.google.protobuf.Timestamp value) {
- if (initializationTimestampBuilder_ == null) {
- if (initializationTimestamp_ != null) {
- initializationTimestamp_ =
- com.google.protobuf.Timestamp.newBuilder(initializationTimestamp_).mergeFrom(value).buildPartial();
- } else {
- initializationTimestamp_ = value;
- }
- onChanged();
- } else {
- initializationTimestampBuilder_.mergeFrom(value);
- }
-
- return this;
- }
- /**
- * <code>.google.protobuf.Timestamp initialization_timestamp = 4;</code>
- */
- public Builder clearInitializationTimestamp() {
- if (initializationTimestampBuilder_ == null) {
- initializationTimestamp_ = null;
- onChanged();
- } else {
- initializationTimestamp_ = null;
- initializationTimestampBuilder_ = null;
- }
-
- return this;
- }
- /**
- * <code>.google.protobuf.Timestamp initialization_timestamp = 4;</code>
- */
- public com.google.protobuf.Timestamp.Builder getInitializationTimestampBuilder() {
-
- onChanged();
- return getInitializationTimestampFieldBuilder().getBuilder();
- }
- /**
- * <code>.google.protobuf.Timestamp initialization_timestamp = 4;</code>
- */
- public com.google.protobuf.TimestampOrBuilder getInitializationTimestampOrBuilder() {
- if (initializationTimestampBuilder_ != null) {
- return initializationTimestampBuilder_.getMessageOrBuilder();
- } else {
- return initializationTimestamp_ == null ?
- com.google.protobuf.Timestamp.getDefaultInstance() : initializationTimestamp_;
- }
- }
- /**
- * <code>.google.protobuf.Timestamp initialization_timestamp = 4;</code>
- */
- private com.google.protobuf.SingleFieldBuilderV3<
- com.google.protobuf.Timestamp, com.google.protobuf.Timestamp.Builder, com.google.protobuf.TimestampOrBuilder>
- getInitializationTimestampFieldBuilder() {
- if (initializationTimestampBuilder_ == null) {
- initializationTimestampBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- com.google.protobuf.Timestamp, com.google.protobuf.Timestamp.Builder, com.google.protobuf.TimestampOrBuilder>(
- getInitializationTimestamp(),
- getParentForChildren(),
- isClean());
- initializationTimestamp_ = null;
- }
- return initializationTimestampBuilder_;
- }
-
private int batchSize_ ;
/**
- * <code>int32 batch_size = 5;</code>
+ * <code>int32 batch_size = 4;</code>
* @return The batchSize.
*/
@java.lang.Override
@@ -1332,7 +1063,7 @@ private static final long serialVersionUID = 0L;
return batchSize_;
}
/**
- * <code>int32 batch_size = 5;</code>
+ * <code>int32 batch_size = 4;</code>
* @param value The batchSize to set.
* @return This builder for chaining.
*/
@@ -1343,7 +1074,7 @@ private static final long serialVersionUID = 0L;
return this;
}
/**
- * <code>int32 batch_size = 5;</code>
+ * <code>int32 batch_size = 4;</code>
* @return This builder for chaining.
*/
public Builder clearBatchSize() {
@@ -1357,14 +1088,22 @@ private static final long serialVersionUID = 0L;
private com.google.protobuf.SingleFieldBuilderV3<
com.google.protobuf.Duration, com.google.protobuf.Duration.Builder, com.google.protobuf.DurationOrBuilder> invisibleDurationBuilder_;
/**
- * <code>.google.protobuf.Duration invisible_duration = 6;</code>
+ * <pre>
+ * Required if client type is simple consumer.
+ * </pre>
+ *
+ * <code>optional .google.protobuf.Duration invisible_duration = 5;</code>
* @return Whether the invisibleDuration field is set.
*/
public boolean hasInvisibleDuration() {
- return invisibleDurationBuilder_ != null || invisibleDuration_ != null;
+ return ((bitField0_ & 0x00000001) != 0);
}
/**
- * <code>.google.protobuf.Duration invisible_duration = 6;</code>
+ * <pre>
+ * Required if client type is simple consumer.
+ * </pre>
+ *
+ * <code>optional .google.protobuf.Duration invisible_duration = 5;</code>
* @return The invisibleDuration.
*/
public com.google.protobuf.Duration getInvisibleDuration() {
@@ -1375,7 +1114,11 @@ private static final long serialVersionUID = 0L;
}
}
/**
- * <code>.google.protobuf.Duration invisible_duration = 6;</code>
+ * <pre>
+ * Required if client type is simple consumer.
+ * </pre>
+ *
+ * <code>optional .google.protobuf.Duration invisible_duration = 5;</code>
*/
public Builder setInvisibleDuration(com.google.protobuf.Duration value) {
if (invisibleDurationBuilder_ == null) {
@@ -1387,11 +1130,15 @@ private static final long serialVersionUID = 0L;
} else {
invisibleDurationBuilder_.setMessage(value);
}
-
+ bitField0_ |= 0x00000001;
return this;
}
/**
- * <code>.google.protobuf.Duration invisible_duration = 6;</code>
+ * <pre>
+ * Required if client type is simple consumer.
+ * </pre>
+ *
+ * <code>optional .google.protobuf.Duration invisible_duration = 5;</code>
*/
public Builder setInvisibleDuration(
com.google.protobuf.Duration.Builder builderForValue) {
@@ -1401,15 +1148,21 @@ private static final long serialVersionUID = 0L;
} else {
invisibleDurationBuilder_.setMessage(builderForValue.build());
}
-
+ bitField0_ |= 0x00000001;
return this;
}
/**
- * <code>.google.protobuf.Duration invisible_duration = 6;</code>
+ * <pre>
+ * Required if client type is simple consumer.
+ * </pre>
+ *
+ * <code>optional .google.protobuf.Duration invisible_duration = 5;</code>
*/
public Builder mergeInvisibleDuration(com.google.protobuf.Duration value) {
if (invisibleDurationBuilder_ == null) {
- if (invisibleDuration_ != null) {
+ if (((bitField0_ & 0x00000001) != 0) &&
+ invisibleDuration_ != null &&
+ invisibleDuration_ != com.google.protobuf.Duration.getDefaultInstance()) {
invisibleDuration_ =
com.google.protobuf.Duration.newBuilder(invisibleDuration_).mergeFrom(value).buildPartial();
} else {
@@ -1419,33 +1172,44 @@ private static final long serialVersionUID = 0L;
} else {
invisibleDurationBuilder_.mergeFrom(value);
}
-
+ bitField0_ |= 0x00000001;
return this;
}
/**
- * <code>.google.protobuf.Duration invisible_duration = 6;</code>
+ * <pre>
+ * Required if client type is simple consumer.
+ * </pre>
+ *
+ * <code>optional .google.protobuf.Duration invisible_duration = 5;</code>
*/
public Builder clearInvisibleDuration() {
if (invisibleDurationBuilder_ == null) {
invisibleDuration_ = null;
onChanged();
} else {
- invisibleDuration_ = null;
- invisibleDurationBuilder_ = null;
+ invisibleDurationBuilder_.clear();
}
-
+ bitField0_ = (bitField0_ & ~0x00000001);
return this;
}
/**
- * <code>.google.protobuf.Duration invisible_duration = 6;</code>
+ * <pre>
+ * Required if client type is simple consumer.
+ * </pre>
+ *
+ * <code>optional .google.protobuf.Duration invisible_duration = 5;</code>
*/
public com.google.protobuf.Duration.Builder getInvisibleDurationBuilder() {
-
+ bitField0_ |= 0x00000001;
onChanged();
return getInvisibleDurationFieldBuilder().getBuilder();
}
/**
- * <code>.google.protobuf.Duration invisible_duration = 6;</code>
+ * <pre>
+ * Required if client type is simple consumer.
+ * </pre>
+ *
+ * <code>optional .google.protobuf.Duration invisible_duration = 5;</code>
*/
public com.google.protobuf.DurationOrBuilder getInvisibleDurationOrBuilder() {
if (invisibleDurationBuilder_ != null) {
@@ -1456,7 +1220,11 @@ private static final long serialVersionUID = 0L;
}
}
/**
- * <code>.google.protobuf.Duration invisible_duration = 6;</code>
+ * <pre>
+ * Required if client type is simple consumer.
+ * </pre>
+ *
+ * <code>optional .google.protobuf.Duration invisible_duration = 5;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
com.google.protobuf.Duration, com.google.protobuf.Duration.Builder, com.google.protobuf.DurationOrBuilder>
@@ -1471,156 +1239,6 @@ private static final long serialVersionUID = 0L;
}
return invisibleDurationBuilder_;
}
-
- private com.google.protobuf.Duration awaitDuration_;
- private com.google.protobuf.SingleFieldBuilderV3<
- com.google.protobuf.Duration, com.google.protobuf.Duration.Builder, com.google.protobuf.DurationOrBuilder> awaitDurationBuilder_;
- /**
- * <code>.google.protobuf.Duration await_duration = 7;</code>
- * @return Whether the awaitDuration field is set.
- */
- public boolean hasAwaitDuration() {
- return awaitDurationBuilder_ != null || awaitDuration_ != null;
- }
- /**
- * <code>.google.protobuf.Duration await_duration = 7;</code>
- * @return The awaitDuration.
- */
- public com.google.protobuf.Duration getAwaitDuration() {
- if (awaitDurationBuilder_ == null) {
- return awaitDuration_ == null ? com.google.protobuf.Duration.getDefaultInstance() : awaitDuration_;
- } else {
- return awaitDurationBuilder_.getMessage();
- }
- }
- /**
- * <code>.google.protobuf.Duration await_duration = 7;</code>
- */
- public Builder setAwaitDuration(com.google.protobuf.Duration value) {
- if (awaitDurationBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- awaitDuration_ = value;
- onChanged();
- } else {
- awaitDurationBuilder_.setMessage(value);
- }
-
- return this;
- }
- /**
- * <code>.google.protobuf.Duration await_duration = 7;</code>
- */
- public Builder setAwaitDuration(
- com.google.protobuf.Duration.Builder builderForValue) {
- if (awaitDurationBuilder_ == null) {
- awaitDuration_ = builderForValue.build();
- onChanged();
- } else {
- awaitDurationBuilder_.setMessage(builderForValue.build());
- }
-
- return this;
- }
- /**
- * <code>.google.protobuf.Duration await_duration = 7;</code>
- */
- public Builder mergeAwaitDuration(com.google.protobuf.Duration value) {
- if (awaitDurationBuilder_ == null) {
- if (awaitDuration_ != null) {
- awaitDuration_ =
- com.google.protobuf.Duration.newBuilder(awaitDuration_).mergeFrom(value).buildPartial();
- } else {
- awaitDuration_ = value;
- }
- onChanged();
- } else {
- awaitDurationBuilder_.mergeFrom(value);
- }
-
- return this;
- }
- /**
- * <code>.google.protobuf.Duration await_duration = 7;</code>
- */
- public Builder clearAwaitDuration() {
- if (awaitDurationBuilder_ == null) {
- awaitDuration_ = null;
- onChanged();
- } else {
- awaitDuration_ = null;
- awaitDurationBuilder_ = null;
- }
-
- return this;
- }
- /**
- * <code>.google.protobuf.Duration await_duration = 7;</code>
- */
- public com.google.protobuf.Duration.Builder getAwaitDurationBuilder() {
-
- onChanged();
- return getAwaitDurationFieldBuilder().getBuilder();
- }
- /**
- * <code>.google.protobuf.Duration await_duration = 7;</code>
- */
- public com.google.protobuf.DurationOrBuilder getAwaitDurationOrBuilder() {
- if (awaitDurationBuilder_ != null) {
- return awaitDurationBuilder_.getMessageOrBuilder();
- } else {
- return awaitDuration_ == null ?
- com.google.protobuf.Duration.getDefaultInstance() : awaitDuration_;
- }
- }
- /**
- * <code>.google.protobuf.Duration await_duration = 7;</code>
- */
- private com.google.protobuf.SingleFieldBuilderV3<
- com.google.protobuf.Duration, com.google.protobuf.Duration.Builder, com.google.protobuf.DurationOrBuilder>
- getAwaitDurationFieldBuilder() {
- if (awaitDurationBuilder_ == null) {
- awaitDurationBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- com.google.protobuf.Duration, com.google.protobuf.Duration.Builder, com.google.protobuf.DurationOrBuilder>(
- getAwaitDuration(),
- getParentForChildren(),
- isClean());
- awaitDuration_ = null;
- }
- return awaitDurationBuilder_;
- }
-
- private boolean fifo_ ;
- /**
- * <code>bool fifo = 8;</code>
- * @return The fifo.
- */
- @java.lang.Override
- public boolean getFifo() {
- return fifo_;
- }
- /**
- * <code>bool fifo = 8;</code>
- * @param value The fifo to set.
- * @return This builder for chaining.
- */
- public Builder setFifo(boolean value) {
-
- fifo_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>bool fifo = 8;</code>
- * @return This builder for chaining.
- */
- public Builder clearFifo() {
-
- fifo_ = false;
- onChanged();
- return this;
- }
@java.lang.Override
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
diff --git a/src/main/java/apache/rocketmq/v2/ReceiveMessageRequestOrBuilder.java b/src/main/java/apache/rocketmq/v2/ReceiveMessageRequestOrBuilder.java
index 766b228..2a43b5e 100644
--- a/src/main/java/apache/rocketmq/v2/ReceiveMessageRequestOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/ReceiveMessageRequestOrBuilder.java
@@ -53,59 +53,35 @@ public interface ReceiveMessageRequestOrBuilder extends
apache.rocketmq.v2.FilterExpressionOrBuilder getFilterExpressionOrBuilder();
/**
- * <code>.google.protobuf.Timestamp initialization_timestamp = 4;</code>
- * @return Whether the initializationTimestamp field is set.
- */
- boolean hasInitializationTimestamp();
- /**
- * <code>.google.protobuf.Timestamp initialization_timestamp = 4;</code>
- * @return The initializationTimestamp.
- */
- com.google.protobuf.Timestamp getInitializationTimestamp();
- /**
- * <code>.google.protobuf.Timestamp initialization_timestamp = 4;</code>
- */
- com.google.protobuf.TimestampOrBuilder getInitializationTimestampOrBuilder();
-
- /**
- * <code>int32 batch_size = 5;</code>
+ * <code>int32 batch_size = 4;</code>
* @return The batchSize.
*/
int getBatchSize();
/**
- * <code>.google.protobuf.Duration invisible_duration = 6;</code>
+ * <pre>
+ * Required if client type is simple consumer.
+ * </pre>
+ *
+ * <code>optional .google.protobuf.Duration invisible_duration = 5;</code>
* @return Whether the invisibleDuration field is set.
*/
boolean hasInvisibleDuration();
/**
- * <code>.google.protobuf.Duration invisible_duration = 6;</code>
+ * <pre>
+ * Required if client type is simple consumer.
+ * </pre>
+ *
+ * <code>optional .google.protobuf.Duration invisible_duration = 5;</code>
* @return The invisibleDuration.
*/
com.google.protobuf.Duration getInvisibleDuration();
/**
- * <code>.google.protobuf.Duration invisible_duration = 6;</code>
+ * <pre>
+ * Required if client type is simple consumer.
+ * </pre>
+ *
+ * <code>optional .google.protobuf.Duration invisible_duration = 5;</code>
*/
com.google.protobuf.DurationOrBuilder getInvisibleDurationOrBuilder();
-
- /**
- * <code>.google.protobuf.Duration await_duration = 7;</code>
- * @return Whether the awaitDuration field is set.
- */
- boolean hasAwaitDuration();
- /**
- * <code>.google.protobuf.Duration await_duration = 7;</code>
- * @return The awaitDuration.
- */
- com.google.protobuf.Duration getAwaitDuration();
- /**
- * <code>.google.protobuf.Duration await_duration = 7;</code>
- */
- com.google.protobuf.DurationOrBuilder getAwaitDurationOrBuilder();
-
- /**
- * <code>bool fifo = 8;</code>
- * @return The fifo.
- */
- boolean getFifo();
}
diff --git a/src/main/resources/proto/apache/rocketmq/v2/service.proto b/src/main/resources/proto/apache/rocketmq/v2/service.proto
index 53126f3..81d5d4f 100644
--- a/src/main/resources/proto/apache/rocketmq/v2/service.proto
+++ b/src/main/resources/proto/apache/rocketmq/v2/service.proto
@@ -80,11 +80,9 @@ message ReceiveMessageRequest {
Resource group = 1;
MessageQueue message_queue = 2;
FilterExpression filter_expression = 3;
- google.protobuf.Timestamp initialization_timestamp = 4;
- int32 batch_size = 5;
- google.protobuf.Duration invisible_duration = 6;
- google.protobuf.Duration await_duration = 7;
- bool fifo = 8;
+ int32 batch_size = 4;
+ // Required if client type is simple consumer.
+ optional google.protobuf.Duration invisible_duration = 5;
}
message ReceiveMessageResponse {