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