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 64a75c518804216c76f2336663b877f6e74687de Author: 凌楚 <[email protected]> AuthorDate: Thu Apr 28 14:37:12 2022 +0800 Apply IDL update --- .../v2/ChangeInvisibleDurationRequest.java | 166 +++++++++++ .../ChangeInvisibleDurationRequestOrBuilder.java | 20 ++ src/main/java/apache/rocketmq/v2/MQService.java | 326 +++++++++++---------- .../apache/rocketmq/v2/QueryAssignmentRequest.java | 188 ++++++++++++ .../v2/QueryAssignmentRequestOrBuilder.java | 15 + .../java/apache/rocketmq/v2/QueryRouteRequest.java | 188 ++++++++++++ .../rocketmq/v2/QueryRouteRequestOrBuilder.java | 15 + .../apache/rocketmq/v2/ReceiveMessageRequest.java | 81 +++++ .../v2/ReceiveMessageRequestOrBuilder.java | 10 + src/main/java/apache/rocketmq/v2/Settings.java | 101 ++++--- .../java/apache/rocketmq/v2/SettingsOrBuilder.java | 6 +- .../proto/apache/rocketmq/v2/service.proto | 13 +- 12 files changed, 915 insertions(+), 214 deletions(-) diff --git a/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationRequest.java b/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationRequest.java index 1c67443..281e50d 100644 --- a/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationRequest.java +++ b/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationRequest.java @@ -17,6 +17,7 @@ private static final long serialVersionUID = 0L; } private ChangeInvisibleDurationRequest() { receiptHandle_ = ""; + messageId_ = ""; } @java.lang.Override @@ -94,6 +95,12 @@ private static final long serialVersionUID = 0L; break; } + case 42: { + java.lang.String s = input.readStringRequireUtf8(); + + messageId_ = s; + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -262,6 +269,52 @@ private static final long serialVersionUID = 0L; return getInvisibleDuration(); } + public static final int MESSAGE_ID_FIELD_NUMBER = 5; + private volatile java.lang.Object messageId_; + /** + * <pre> + * For message tracing + * </pre> + * + * <code>string message_id = 5;</code> + * @return The messageId. + */ + @java.lang.Override + public java.lang.String getMessageId() { + java.lang.Object ref = messageId_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + messageId_ = s; + return s; + } + } + /** + * <pre> + * For message tracing + * </pre> + * + * <code>string message_id = 5;</code> + * @return The bytes for messageId. + */ + @java.lang.Override + public com.google.protobuf.ByteString + getMessageIdBytes() { + java.lang.Object ref = messageId_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + messageId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -288,6 +341,9 @@ private static final long serialVersionUID = 0L; if (invisibleDuration_ != null) { output.writeMessage(4, getInvisibleDuration()); } + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(messageId_)) { + com.google.protobuf.GeneratedMessageV3.writeString(output, 5, messageId_); + } unknownFields.writeTo(output); } @@ -312,6 +368,9 @@ private static final long serialVersionUID = 0L; size += com.google.protobuf.CodedOutputStream .computeMessageSize(4, getInvisibleDuration()); } + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(messageId_)) { + size += com.google.protobuf.GeneratedMessageV3.computeStringSize(5, messageId_); + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -344,6 +403,8 @@ private static final long serialVersionUID = 0L; if (!getInvisibleDuration() .equals(other.getInvisibleDuration())) return false; } + if (!getMessageId() + .equals(other.getMessageId())) return false; if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -369,6 +430,8 @@ private static final long serialVersionUID = 0L; hash = (37 * hash) + INVISIBLE_DURATION_FIELD_NUMBER; hash = (53 * hash) + getInvisibleDuration().hashCode(); } + hash = (37 * hash) + MESSAGE_ID_FIELD_NUMBER; + hash = (53 * hash) + getMessageId().hashCode(); hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -522,6 +585,8 @@ private static final long serialVersionUID = 0L; invisibleDuration_ = null; invisibleDurationBuilder_ = null; } + messageId_ = ""; + return this; } @@ -564,6 +629,7 @@ private static final long serialVersionUID = 0L; } else { result.invisibleDuration_ = invisibleDurationBuilder_.build(); } + result.messageId_ = messageId_; onBuilt(); return result; } @@ -625,6 +691,10 @@ private static final long serialVersionUID = 0L; if (other.hasInvisibleDuration()) { mergeInvisibleDuration(other.getInvisibleDuration()); } + if (!other.getMessageId().isEmpty()) { + messageId_ = other.messageId_; + onChanged(); + } this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -1142,6 +1212,102 @@ private static final long serialVersionUID = 0L; } return invisibleDurationBuilder_; } + + private java.lang.Object messageId_ = ""; + /** + * <pre> + * For message tracing + * </pre> + * + * <code>string message_id = 5;</code> + * @return The messageId. + */ + public java.lang.String getMessageId() { + java.lang.Object ref = messageId_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + messageId_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <pre> + * For message tracing + * </pre> + * + * <code>string message_id = 5;</code> + * @return The bytes for messageId. + */ + public com.google.protobuf.ByteString + getMessageIdBytes() { + java.lang.Object ref = messageId_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + messageId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <pre> + * For message tracing + * </pre> + * + * <code>string message_id = 5;</code> + * @param value The messageId to set. + * @return This builder for chaining. + */ + public Builder setMessageId( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + messageId_ = value; + onChanged(); + return this; + } + /** + * <pre> + * For message tracing + * </pre> + * + * <code>string message_id = 5;</code> + * @return This builder for chaining. + */ + public Builder clearMessageId() { + + messageId_ = getDefaultInstance().getMessageId(); + onChanged(); + return this; + } + /** + * <pre> + * For message tracing + * </pre> + * + * <code>string message_id = 5;</code> + * @param value The bytes for messageId to set. + * @return This builder for chaining. + */ + public Builder setMessageIdBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + checkByteStringIsUtf8(value); + + messageId_ = value; + 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/ChangeInvisibleDurationRequestOrBuilder.java b/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationRequestOrBuilder.java index 452ae1f..93999e4 100644 --- a/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationRequestOrBuilder.java +++ b/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationRequestOrBuilder.java @@ -83,4 +83,24 @@ public interface ChangeInvisibleDurationRequestOrBuilder extends * <code>.google.protobuf.Duration invisible_duration = 4;</code> */ com.google.protobuf.DurationOrBuilder getInvisibleDurationOrBuilder(); + + /** + * <pre> + * For message tracing + * </pre> + * + * <code>string message_id = 5;</code> + * @return The messageId. + */ + java.lang.String getMessageId(); + /** + * <pre> + * For message tracing + * </pre> + * + * <code>string message_id = 5;</code> + * @return The bytes for messageId. + */ + com.google.protobuf.ByteString + getMessageIdBytes(); } diff --git a/src/main/java/apache/rocketmq/v2/MQService.java b/src/main/java/apache/rocketmq/v2/MQService.java index 1a2c012..f20ced7 100644 --- a/src/main/java/apache/rocketmq/v2/MQService.java +++ b/src/main/java/apache/rocketmq/v2/MQService.java @@ -191,164 +191,168 @@ public final class MQService { "\n apache/rocketmq/v2/service.proto\022\022apac" + "he.rocketmq.v2\032\036google/protobuf/duration" + ".proto\032\037google/protobuf/timestamp.proto\032" + - "#apache/rocketmq/v2/definition.proto\"@\n\021" + + "#apache/rocketmq/v2/definition.proto\"r\n\021" + "QueryRouteRequest\022+\n\005topic\030\001 \001(\0132\034.apach" + - "e.rocketmq.v2.Resource\"z\n\022QueryRouteResp" + - "onse\022*\n\006status\030\001 \001(\0132\032.apache.rocketmq.v" + - "2.Status\0228\n\016message_queues\030\002 \003(\0132 .apach" + - "e.rocketmq.v2.MessageQueue\"C\n\022SendMessag" + - "eRequest\022-\n\010messages\030\001 \003(\0132\033.apache.rock" + - "etmq.v2.Message\"t\n\023SendMessageResponse\022*" + - "\n\006status\030\001 \001(\0132\032.apache.rocketmq.v2.Stat" + - "us\0221\n\010receipts\030\002 \003(\0132\037.apache.rocketmq.v" + - "2.SendReceipt\"r\n\026QueryAssignmentRequest\022" + - "+\n\005topic\030\001 \001(\0132\034.apache.rocketmq.v2.Reso" + - "urce\022+\n\005group\030\002 \001(\0132\034.apache.rocketmq.v2" + - ".Resource\"z\n\027QueryAssignmentResponse\022*\n\006" + + "e.rocketmq.v2.Resource\0220\n\tendpoints\030\002 \001(" + + "\0132\035.apache.rocketmq.v2.Endpoints\"z\n\022Quer" + + "yRouteResponse\022*\n\006status\030\001 \001(\0132\032.apache." + + "rocketmq.v2.Status\0228\n\016message_queues\030\002 \003" + + "(\0132 .apache.rocketmq.v2.MessageQueue\"C\n\022" + + "SendMessageRequest\022-\n\010messages\030\001 \003(\0132\033.a" + + "pache.rocketmq.v2.Message\"t\n\023SendMessage" + + "Response\022*\n\006status\030\001 \001(\0132\032.apache.rocket" + + "mq.v2.Status\0221\n\010receipts\030\002 \003(\0132\037.apache." + + "rocketmq.v2.SendReceipt\"\244\001\n\026QueryAssignm" + + "entRequest\022+\n\005topic\030\001 \001(\0132\034.apache.rocke" + + "tmq.v2.Resource\022+\n\005group\030\002 \001(\0132\034.apache." + + "rocketmq.v2.Resource\0220\n\tendpoints\030\003 \001(\0132" + + "\035.apache.rocketmq.v2.Endpoints\"z\n\027QueryA" + + "ssignmentResponse\022*\n\006status\030\001 \001(\0132\032.apac" + + "he.rocketmq.v2.Status\0223\n\013assignments\030\002 \003" + + "(\0132\036.apache.rocketmq.v2.Assignment\"\271\002\n\025R" + + "eceiveMessageRequest\022+\n\005group\030\001 \001(\0132\034.ap" + + "ache.rocketmq.v2.Resource\0227\n\rmessage_que" + + "ue\030\002 \001(\0132 .apache.rocketmq.v2.MessageQue" + + "ue\022?\n\021filter_expression\030\003 \001(\0132$.apache.r" + + "ocketmq.v2.FilterExpression\022\022\n\nbatch_siz" + + "e\030\004 \001(\005\022:\n\022invisible_duration\030\005 \001(\0132\031.go" + + "ogle.protobuf.DurationH\000\210\001\001\022\022\n\nauto_rene" + + "w\030\006 \001(\010B\025\n\023_invisible_duration\"\201\001\n\026Recei" + + "veMessageResponse\022,\n\006status\030\001 \001(\0132\032.apac" + + "he.rocketmq.v2.StatusH\000\022.\n\007message\030\002 \001(\013" + + "2\033.apache.rocketmq.v2.MessageH\000B\t\n\007conte" + + "nt\"=\n\017AckMessageEntry\022\022\n\nmessage_id\030\001 \001(" + + "\t\022\026\n\016receipt_handle\030\002 \001(\t\"\243\001\n\021AckMessage" + + "Request\022+\n\005group\030\001 \001(\0132\034.apache.rocketmq" + + ".v2.Resource\022+\n\005topic\030\002 \001(\0132\034.apache.roc" + + "ketmq.v2.Resource\0224\n\007entries\030\003 \003(\0132#.apa" + + "che.rocketmq.v2.AckMessageEntry\"o\n\025AckMe" + + "ssageResultEntry\022\022\n\nmessage_id\030\001 \001(\t\022\026\n\016" + + "receipt_handle\030\002 \001(\t\022*\n\006status\030\003 \001(\0132\032.a" + + "pache.rocketmq.v2.Status\"|\n\022AckMessageRe" + + "sponse\022*\n\006status\030\001 \001(\0132\032.apache.rocketmq" + + ".v2.Status\022:\n\007entries\030\002 \003(\0132).apache.roc" + + "ketmq.v2.AckMessageResultEntry\"\264\001\n\022NackM" + + "essageRequest\022+\n\005group\030\001 \001(\0132\034.apache.ro" + + "cketmq.v2.Resource\022+\n\005topic\030\002 \001(\0132\034.apac" + + "he.rocketmq.v2.Resource\022\026\n\016receipt_handl" + + "e\030\003 \001(\t\022\022\n\nmessage_id\030\004 \001(\t\022\030\n\020delivery_" + + "attempt\030\005 \001(\005\"A\n\023NackMessageResponse\022*\n\006" + "status\030\001 \001(\0132\032.apache.rocketmq.v2.Status" + - "\0223\n\013assignments\030\002 \003(\0132\036.apache.rocketmq." + - "v2.Assignment\"\245\002\n\025ReceiveMessageRequest\022" + - "+\n\005group\030\001 \001(\0132\034.apache.rocketmq.v2.Reso" + - "urce\0227\n\rmessage_queue\030\002 \001(\0132 .apache.roc" + - "ketmq.v2.MessageQueue\022?\n\021filter_expressi" + - "on\030\003 \001(\0132$.apache.rocketmq.v2.FilterExpr" + - "ession\022\022\n\nbatch_size\030\004 \001(\005\022:\n\022invisible_" + - "duration\030\005 \001(\0132\031.google.protobuf.Duratio" + - "nH\000\210\001\001B\025\n\023_invisible_duration\"\201\001\n\026Receiv" + - "eMessageResponse\022,\n\006status\030\001 \001(\0132\032.apach" + - "e.rocketmq.v2.StatusH\000\022.\n\007message\030\002 \001(\0132" + - "\033.apache.rocketmq.v2.MessageH\000B\t\n\007conten" + - "t\"=\n\017AckMessageEntry\022\022\n\nmessage_id\030\001 \001(\t" + - "\022\026\n\016receipt_handle\030\002 \001(\t\"\243\001\n\021AckMessageR" + - "equest\022+\n\005group\030\001 \001(\0132\034.apache.rocketmq." + - "v2.Resource\022+\n\005topic\030\002 \001(\0132\034.apache.rock" + - "etmq.v2.Resource\0224\n\007entries\030\003 \003(\0132#.apac" + - "he.rocketmq.v2.AckMessageEntry\"o\n\025AckMes" + - "sageResultEntry\022\022\n\nmessage_id\030\001 \001(\t\022\026\n\016r" + - "eceipt_handle\030\002 \001(\t\022*\n\006status\030\003 \001(\0132\032.ap" + - "ache.rocketmq.v2.Status\"|\n\022AckMessageRes" + - "ponse\022*\n\006status\030\001 \001(\0132\032.apache.rocketmq." + - "v2.Status\022:\n\007entries\030\002 \003(\0132).apache.rock" + - "etmq.v2.AckMessageResultEntry\"\264\001\n\022NackMe" + - "ssageRequest\022+\n\005group\030\001 \001(\0132\034.apache.roc" + - "ketmq.v2.Resource\022+\n\005topic\030\002 \001(\0132\034.apach" + - "e.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_a" + - "ttempt\030\005 \001(\005\"A\n\023NackMessageResponse\022*\n\006s" + - "tatus\030\001 \001(\0132\032.apache.rocketmq.v2.Status\"" + - "\347\001\n&ForwardMessageToDeadLetterQueueReque" + - "st\022+\n\005group\030\001 \001(\0132\034.apache.rocketmq.v2.R" + - "esource\022+\n\005topic\030\002 \001(\0132\034.apache.rocketmq" + - ".v2.Resource\022\026\n\016receipt_handle\030\003 \001(\t\022\022\n\n" + - "message_id\030\004 \001(\t\022\030\n\020delivery_attempt\030\005 \001" + - "(\005\022\035\n\025max_delivery_attempts\030\006 \001(\005\"U\n\'For" + - "wardMessageToDeadLetterQueueResponse\022*\n\006" + - "status\030\001 \001(\0132\032.apache.rocketmq.v2.Status" + - "\"N\n\020HeartbeatRequest\0220\n\005group\030\001 \001(\0132\034.ap" + - "ache.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\025EndTransac" + - "tionRequest\022+\n\005topic\030\001 \001(\0132\034.apache.rock" + - "etmq.v2.Resource\022\022\n\nmessage_id\030\002 \001(\t\022\026\n\016" + - "transaction_id\030\003 \001(\t\022=\n\nresolution\030\004 \001(\016" + - "2).apache.rocketmq.v2.TransactionResolut" + - "ion\0225\n\006source\030\005 \001(\0162%.apache.rocketmq.v2" + - ".TransactionSource\022\025\n\rtrace_context\030\006 \001(" + - "\t\"D\n\026EndTransactionResponse\022*\n\006status\030\001 " + - "\001(\0132\032.apache.rocketmq.v2.Status\"-\n\034Print" + - "ThreadStackTraceCommand\022\r\n\005nonce\030\001 \001(\t\"\205" + - "\001\n\020ThreadStackTrace\022\r\n\005nonce\030\001 \001(\t\022*\n\006st" + - "atus\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_thre" + - "ad_stack_trace\"S\n\024VerifyMessageCommand\022\r" + - "\n\005nonce\030\001 \001(\t\022,\n\007message\030\002 \001(\0132\033.apache." + - "rocketmq.v2.Message\"P\n\023VerifyMessageResu" + - "lt\022\r\n\005nonce\030\001 \001(\t\022*\n\006status\030\002 \001(\0132\032.apac" + - "he.rocketmq.v2.Status\"\200\001\n!RecoverOrphane" + - "dTransactionCommand\022C\n\036orphaned_transact" + - "ional_message\030\001 \001(\0132\033.apache.rocketmq.v2" + - ".Message\022\026\n\016transaction_id\030\002 \001(\t\"r\n\nPubl" + - "ishing\022,\n\006topics\030\001 \003(\0132\034.apache.rocketmq" + - ".v2.Resource\022\037\n\027compress_body_threshold\030" + - "\002 \001(\005\022\025\n\rmax_body_size\030\003 \001(\005\"\263\002\n\014Subscri" + - "ption\0220\n\005group\030\001 \001(\0132\034.apache.rocketmq.v" + - "2.ResourceH\000\210\001\001\022<\n\rsubscriptions\030\002 \003(\0132%" + - ".apache.rocketmq.v2.SubscriptionEntry\022\021\n" + - "\004fifo\030\003 \001(\010H\001\210\001\001\022\037\n\022receive_batch_size\030\004" + - " \001(\005H\002\210\001\001\022<\n\024long_polling_timeout\030\005 \001(\0132" + - "\031.google.protobuf.DurationH\003\210\001\001B\010\n\006_grou" + - "pB\007\n\005_fifoB\025\n\023_receive_batch_sizeB\027\n\025_lo" + - "ng_polling_timeout\"\240\003\n\010Settings\0228\n\013clien" + - "t_type\030\001 \001(\0162\036.apache.rocketmq.v2.Client" + - "TypeH\001\210\001\001\0228\n\014access_point\030\002 \001(\0132\035.apache" + - ".rocketmq.v2.EndpointsH\002\210\001\001\0227\n\016backoff_p" + - "olicy\030\003 \001(\0132\037.apache.rocketmq.v2.RetryPo" + - "licy\0227\n\017request_timeout\030\004 \001(\0132\031.google.p" + - "rotobuf.DurationH\003\210\001\001\0224\n\npublishing\030\005 \001(" + - "\0132\036.apache.rocketmq.v2.PublishingH\000\0228\n\014s" + - "ubscription\030\006 \001(\0132 .apache.rocketmq.v2.S" + - "ubscriptionH\000B\t\n\007pub_subB\016\n\014_client_type" + - "B\017\n\r_access_pointB\022\n\020_request_timeout\"\356\003" + - "\n\020TelemetryCommand\0220\n\010settings\030\001 \001(\0132\034.a" + - "pache.rocketmq.v2.SettingsH\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\022e\n$recover_orphaned_transacti" + - "on_command\030\004 \001(\01325.apache.rocketmq.v2.Re" + - "coverOrphanedTransactionCommandH\000\022\\\n pri" + - "nt_thread_stack_trace_command\030\005 \001(\01320.ap" + - "ache.rocketmq.v2.PrintThreadStackTraceCo" + - "mmandH\000\022J\n\026verify_message_command\030\006 \001(\0132" + - "(.apache.rocketmq.v2.VerifyMessageComman" + - "dH\000B\t\n\007command\"\\\n\036NotifyClientTerminatio" + - "nRequest\0220\n\005group\030\001 \001(\0132\034.apache.rocketm" + - "q.v2.ResourceH\000\210\001\001B\010\n\006_group\"M\n\037NotifyCl" + - "ientTerminationResponse\022*\n\006status\030\001 \001(\0132" + - "\032.apache.rocketmq.v2.Status\"\311\001\n\036ChangeIn" + - "visibleDurationRequest\022+\n\005group\030\001 \001(\0132\034." + - "apache.rocketmq.v2.Resource\022+\n\005topic\030\002 \001" + - "(\0132\034.apache.rocketmq.v2.Resource\022\026\n\016rece" + - "ipt_handle\030\003 \001(\t\0225\n\022invisible_duration\030\004" + - " \001(\0132\031.google.protobuf.Duration\"e\n\037Chang" + - "eInvisibleDurationResponse\022*\n\006status\030\001 \001" + - "(\0132\032.apache.rocketmq.v2.Status\022\026\n\016receip" + - "t_handle\030\002 \001(\t2\302\n\n\020MessagingService\022]\n\nQ" + - "ueryRoute\022%.apache.rocketmq.v2.QueryRout" + - "eRequest\032&.apache.rocketmq.v2.QueryRoute" + - "Response\"\000\022Z\n\tHeartbeat\022$.apache.rocketm" + - "q.v2.HeartbeatRequest\032%.apache.rocketmq." + - "v2.HeartbeatResponse\"\000\022`\n\013SendMessage\022&." + - "apache.rocketmq.v2.SendMessageRequest\032\'." + - "apache.rocketmq.v2.SendMessageResponse\"\000" + - "\022l\n\017QueryAssignment\022*.apache.rocketmq.v2" + - ".QueryAssignmentRequest\032+.apache.rocketm" + - "q.v2.QueryAssignmentResponse\"\000\022k\n\016Receiv" + - "eMessage\022).apache.rocketmq.v2.ReceiveMes" + - "sageRequest\032*.apache.rocketmq.v2.Receive" + - "MessageResponse\"\0000\001\022]\n\nAckMessage\022%.apac" + - "he.rocketmq.v2.AckMessageRequest\032&.apach" + - "e.rocketmq.v2.AckMessageResponse\"\000\022`\n\013Na" + - "ckMessage\022&.apache.rocketmq.v2.NackMessa" + - "geRequest\032\'.apache.rocketmq.v2.NackMessa" + - "geResponse\"\000\022\234\001\n\037ForwardMessageToDeadLet" + - "terQueue\022:.apache.rocketmq.v2.ForwardMes" + - "sageToDeadLetterQueueRequest\032;.apache.ro" + - "cketmq.v2.ForwardMessageToDeadLetterQueu" + - "eResponse\"\000\022i\n\016EndTransaction\022).apache.r" + - "ocketmq.v2.EndTransactionRequest\032*.apach" + - "e.rocketmq.v2.EndTransactionResponse\"\000\022]" + - "\n\tTelemetry\022$.apache.rocketmq.v2.Telemet" + - "ryCommand\032$.apache.rocketmq.v2.Telemetry" + - "Command\"\000(\0010\001\022\204\001\n\027NotifyClientTerminatio" + - "n\0222.apache.rocketmq.v2.NotifyClientTermi" + - "nationRequest\0323.apache.rocketmq.v2.Notif" + - "yClientTerminationResponse\"\000\022\204\001\n\027ChangeI" + - "nvisibleDuration\0222.apache.rocketmq.v2.Ch" + - "angeInvisibleDurationRequest\0323.apache.ro" + - "cketmq.v2.ChangeInvisibleDurationRespons" + - "e\"\000B<\n\022apache.rocketmq.v2B\tMQServiceP\001\240\001" + - "\001\330\001\001\252\002\022Apache.Rocketmq.V2b\006proto3" + "\"\347\001\n&ForwardMessageToDeadLetterQueueRequ" + + "est\022+\n\005group\030\001 \001(\0132\034.apache.rocketmq.v2." + + "Resource\022+\n\005topic\030\002 \001(\0132\034.apache.rocketm" + + "q.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_delivery_attempts\030\006 \001(\005\"U\n\'Fo" + + "rwardMessageToDeadLetterQueueResponse\022*\n" + + "\006status\030\001 \001(\0132\032.apache.rocketmq.v2.Statu" + + "s\"N\n\020HeartbeatRequest\0220\n\005group\030\001 \001(\0132\034.a" + + "pache.rocketmq.v2.ResourceH\000\210\001\001B\010\n\006_grou" + + "p\"?\n\021HeartbeatResponse\022*\n\006status\030\001 \001(\0132\032" + + ".apache.rocketmq.v2.Status\"\375\001\n\025EndTransa" + + "ctionRequest\022+\n\005topic\030\001 \001(\0132\034.apache.roc" + + "ketmq.v2.Resource\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.rocketmq.v2.TransactionResolu" + + "tion\0225\n\006source\030\005 \001(\0162%.apache.rocketmq.v" + + "2.TransactionSource\022\025\n\rtrace_context\030\006 \001" + + "(\t\"D\n\026EndTransactionResponse\022*\n\006status\030\001" + + " \001(\0132\032.apache.rocketmq.v2.Status\"-\n\034Prin" + + "tThreadStackTraceCommand\022\r\n\005nonce\030\001 \001(\t\"" + + "\205\001\n\020ThreadStackTrace\022\r\n\005nonce\030\001 \001(\t\022*\n\006s" + + "tatus\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_thr" + + "ead_stack_trace\"S\n\024VerifyMessageCommand\022" + + "\r\n\005nonce\030\001 \001(\t\022,\n\007message\030\002 \001(\0132\033.apache" + + ".rocketmq.v2.Message\"P\n\023VerifyMessageRes" + + "ult\022\r\n\005nonce\030\001 \001(\t\022*\n\006status\030\002 \001(\0132\032.apa" + + "che.rocketmq.v2.Status\"\200\001\n!RecoverOrphan" + + "edTransactionCommand\022C\n\036orphaned_transac" + + "tional_message\030\001 \001(\0132\033.apache.rocketmq.v" + + "2.Message\022\026\n\016transaction_id\030\002 \001(\t\"r\n\nPub" + + "lishing\022,\n\006topics\030\001 \003(\0132\034.apache.rocketm" + + "q.v2.Resource\022\037\n\027compress_body_threshold" + + "\030\002 \001(\005\022\025\n\rmax_body_size\030\003 \001(\005\"\263\002\n\014Subscr" + + "iption\0220\n\005group\030\001 \001(\0132\034.apache.rocketmq." + + "v2.ResourceH\000\210\001\001\022<\n\rsubscriptions\030\002 \003(\0132" + + "%.apache.rocketmq.v2.SubscriptionEntry\022\021" + + "\n\004fifo\030\003 \001(\010H\001\210\001\001\022\037\n\022receive_batch_size\030" + + "\004 \001(\005H\002\210\001\001\022<\n\024long_polling_timeout\030\005 \001(\013" + + "2\031.google.protobuf.DurationH\003\210\001\001B\010\n\006_gro" + + "upB\007\n\005_fifoB\025\n\023_receive_batch_sizeB\027\n\025_l" + + "ong_polling_timeout\"\270\003\n\010Settings\0228\n\013clie" + + "nt_type\030\001 \001(\0162\036.apache.rocketmq.v2.Clien" + + "tTypeH\001\210\001\001\0228\n\014access_point\030\002 \001(\0132\035.apach" + + "e.rocketmq.v2.EndpointsH\002\210\001\001\022<\n\016backoff_" + + "policy\030\003 \001(\0132\037.apache.rocketmq.v2.RetryP" + + "olicyH\003\210\001\001\0227\n\017request_timeout\030\004 \001(\0132\031.go" + + "ogle.protobuf.DurationH\004\210\001\001\0224\n\npublishin" + + "g\030\005 \001(\0132\036.apache.rocketmq.v2.PublishingH" + + "\000\0228\n\014subscription\030\006 \001(\0132 .apache.rocketm" + + "q.v2.SubscriptionH\000B\t\n\007pub_subB\016\n\014_clien" + + "t_typeB\017\n\r_access_pointB\021\n\017_backoff_poli" + + "cyB\022\n\020_request_timeout\"\356\003\n\020TelemetryComm" + + "and\0220\n\010settings\030\001 \001(\0132\034.apache.rocketmq." + + "v2.SettingsH\000\022B\n\022thread_stack_trace\030\002 \001(" + + "\0132$.apache.rocketmq.v2.ThreadStackTraceH" + + "\000\022H\n\025verify_message_result\030\003 \001(\0132\'.apach" + + "e.rocketmq.v2.VerifyMessageResultH\000\022e\n$r" + + "ecover_orphaned_transaction_command\030\004 \001(" + + "\01325.apache.rocketmq.v2.RecoverOrphanedTr" + + "ansactionCommandH\000\022\\\n print_thread_stack" + + "_trace_command\030\005 \001(\01320.apache.rocketmq.v" + + "2.PrintThreadStackTraceCommandH\000\022J\n\026veri" + + "fy_message_command\030\006 \001(\0132(.apache.rocket" + + "mq.v2.VerifyMessageCommandH\000B\t\n\007command\"" + + "\\\n\036NotifyClientTerminationRequest\0220\n\005gro" + + "up\030\001 \001(\0132\034.apache.rocketmq.v2.ResourceH\000" + + "\210\001\001B\010\n\006_group\"M\n\037NotifyClientTermination" + + "Response\022*\n\006status\030\001 \001(\0132\032.apache.rocket" + + "mq.v2.Status\"\335\001\n\036ChangeInvisibleDuration" + + "Request\022+\n\005group\030\001 \001(\0132\034.apache.rocketmq" + + ".v2.Resource\022+\n\005topic\030\002 \001(\0132\034.apache.roc" + + "ketmq.v2.Resource\022\026\n\016receipt_handle\030\003 \001(" + + "\t\0225\n\022invisible_duration\030\004 \001(\0132\031.google.p" + + "rotobuf.Duration\022\022\n\nmessage_id\030\005 \001(\t\"e\n\037" + + "ChangeInvisibleDurationResponse\022*\n\006statu" + + "s\030\001 \001(\0132\032.apache.rocketmq.v2.Status\022\026\n\016r" + + "eceipt_handle\030\002 \001(\t2\302\n\n\020MessagingService" + + "\022]\n\nQueryRoute\022%.apache.rocketmq.v2.Quer" + + "yRouteRequest\032&.apache.rocketmq.v2.Query" + + "RouteResponse\"\000\022Z\n\tHeartbeat\022$.apache.ro" + + "cketmq.v2.HeartbeatRequest\032%.apache.rock" + + "etmq.v2.HeartbeatResponse\"\000\022`\n\013SendMessa" + + "ge\022&.apache.rocketmq.v2.SendMessageReque" + + "st\032\'.apache.rocketmq.v2.SendMessageRespo" + + "nse\"\000\022l\n\017QueryAssignment\022*.apache.rocket" + + "mq.v2.QueryAssignmentRequest\032+.apache.ro" + + "cketmq.v2.QueryAssignmentResponse\"\000\022k\n\016R" + + "eceiveMessage\022).apache.rocketmq.v2.Recei" + + "veMessageRequest\032*.apache.rocketmq.v2.Re" + + "ceiveMessageResponse\"\0000\001\022]\n\nAckMessage\022%" + + ".apache.rocketmq.v2.AckMessageRequest\032&." + + "apache.rocketmq.v2.AckMessageResponse\"\000\022" + + "`\n\013NackMessage\022&.apache.rocketmq.v2.Nack" + + "MessageRequest\032\'.apache.rocketmq.v2.Nack" + + "MessageResponse\"\000\022\234\001\n\037ForwardMessageToDe" + + "adLetterQueue\022:.apache.rocketmq.v2.Forwa" + + "rdMessageToDeadLetterQueueRequest\032;.apac" + + "he.rocketmq.v2.ForwardMessageToDeadLette" + + "rQueueResponse\"\000\022i\n\016EndTransaction\022).apa" + + "che.rocketmq.v2.EndTransactionRequest\032*." + + "apache.rocketmq.v2.EndTransactionRespons" + + "e\"\000\022]\n\tTelemetry\022$.apache.rocketmq.v2.Te" + + "lemetryCommand\032$.apache.rocketmq.v2.Tele" + + "metryCommand\"\000(\0010\001\022\204\001\n\027NotifyClientTermi" + + "nation\0222.apache.rocketmq.v2.NotifyClient" + + "TerminationRequest\0323.apache.rocketmq.v2." + + "NotifyClientTerminationResponse\"\000\022\204\001\n\027Ch" + + "angeInvisibleDuration\0222.apache.rocketmq." + + "v2.ChangeInvisibleDurationRequest\0323.apac" + + "he.rocketmq.v2.ChangeInvisibleDurationRe" + + "sponse\"\000B<\n\022apache.rocketmq.v2B\tMQServic" + + "eP\001\240\001\001\330\001\001\252\002\022Apache.Rocketmq.V2b\006proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor .internalBuildGeneratedFileFrom(descriptorData, @@ -362,7 +366,7 @@ public final class MQService { internal_static_apache_rocketmq_v2_QueryRouteRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_apache_rocketmq_v2_QueryRouteRequest_descriptor, - new java.lang.String[] { "Topic", }); + new java.lang.String[] { "Topic", "Endpoints", }); internal_static_apache_rocketmq_v2_QueryRouteResponse_descriptor = getDescriptor().getMessageTypes().get(1); internal_static_apache_rocketmq_v2_QueryRouteResponse_fieldAccessorTable = new @@ -386,7 +390,7 @@ public final class MQService { internal_static_apache_rocketmq_v2_QueryAssignmentRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_apache_rocketmq_v2_QueryAssignmentRequest_descriptor, - new java.lang.String[] { "Topic", "Group", }); + new java.lang.String[] { "Topic", "Group", "Endpoints", }); internal_static_apache_rocketmq_v2_QueryAssignmentResponse_descriptor = getDescriptor().getMessageTypes().get(5); internal_static_apache_rocketmq_v2_QueryAssignmentResponse_fieldAccessorTable = new @@ -398,7 +402,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", "BatchSize", "InvisibleDuration", "InvisibleDuration", }); + new java.lang.String[] { "Group", "MessageQueue", "FilterExpression", "BatchSize", "InvisibleDuration", "AutoRenew", "InvisibleDuration", }); internal_static_apache_rocketmq_v2_ReceiveMessageResponse_descriptor = getDescriptor().getMessageTypes().get(7); internal_static_apache_rocketmq_v2_ReceiveMessageResponse_fieldAccessorTable = new @@ -524,7 +528,7 @@ public final class MQService { internal_static_apache_rocketmq_v2_Settings_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_apache_rocketmq_v2_Settings_descriptor, - new java.lang.String[] { "ClientType", "AccessPoint", "BackoffPolicy", "RequestTimeout", "Publishing", "Subscription", "PubSub", "ClientType", "AccessPoint", "RequestTimeout", }); + new java.lang.String[] { "ClientType", "AccessPoint", "BackoffPolicy", "RequestTimeout", "Publishing", "Subscription", "PubSub", "ClientType", "AccessPoint", "BackoffPolicy", "RequestTimeout", }); internal_static_apache_rocketmq_v2_TelemetryCommand_descriptor = getDescriptor().getMessageTypes().get(28); internal_static_apache_rocketmq_v2_TelemetryCommand_fieldAccessorTable = new @@ -548,7 +552,7 @@ public final class MQService { internal_static_apache_rocketmq_v2_ChangeInvisibleDurationRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_apache_rocketmq_v2_ChangeInvisibleDurationRequest_descriptor, - new java.lang.String[] { "Group", "Topic", "ReceiptHandle", "InvisibleDuration", }); + new java.lang.String[] { "Group", "Topic", "ReceiptHandle", "InvisibleDuration", "MessageId", }); internal_static_apache_rocketmq_v2_ChangeInvisibleDurationResponse_descriptor = getDescriptor().getMessageTypes().get(32); internal_static_apache_rocketmq_v2_ChangeInvisibleDurationResponse_fieldAccessorTable = new diff --git a/src/main/java/apache/rocketmq/v2/QueryAssignmentRequest.java b/src/main/java/apache/rocketmq/v2/QueryAssignmentRequest.java index 70aa918..0ae071f 100644 --- a/src/main/java/apache/rocketmq/v2/QueryAssignmentRequest.java +++ b/src/main/java/apache/rocketmq/v2/QueryAssignmentRequest.java @@ -74,6 +74,19 @@ private static final long serialVersionUID = 0L; break; } + case 26: { + apache.rocketmq.v2.Endpoints.Builder subBuilder = null; + if (endpoints_ != null) { + subBuilder = endpoints_.toBuilder(); + } + endpoints_ = input.readMessage(apache.rocketmq.v2.Endpoints.parser(), extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(endpoints_); + endpoints_ = subBuilder.buildPartial(); + } + + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -158,6 +171,32 @@ private static final long serialVersionUID = 0L; return getGroup(); } + public static final int ENDPOINTS_FIELD_NUMBER = 3; + private apache.rocketmq.v2.Endpoints endpoints_; + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 3;</code> + * @return Whether the endpoints field is set. + */ + @java.lang.Override + public boolean hasEndpoints() { + return endpoints_ != null; + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 3;</code> + * @return The endpoints. + */ + @java.lang.Override + public apache.rocketmq.v2.Endpoints getEndpoints() { + return endpoints_ == null ? apache.rocketmq.v2.Endpoints.getDefaultInstance() : endpoints_; + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 3;</code> + */ + @java.lang.Override + public apache.rocketmq.v2.EndpointsOrBuilder getEndpointsOrBuilder() { + return getEndpoints(); + } + private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -178,6 +217,9 @@ private static final long serialVersionUID = 0L; if (group_ != null) { output.writeMessage(2, getGroup()); } + if (endpoints_ != null) { + output.writeMessage(3, getEndpoints()); + } unknownFields.writeTo(output); } @@ -195,6 +237,10 @@ private static final long serialVersionUID = 0L; size += com.google.protobuf.CodedOutputStream .computeMessageSize(2, getGroup()); } + if (endpoints_ != null) { + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(3, getEndpoints()); + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -220,6 +266,11 @@ private static final long serialVersionUID = 0L; if (!getGroup() .equals(other.getGroup())) return false; } + if (hasEndpoints() != other.hasEndpoints()) return false; + if (hasEndpoints()) { + if (!getEndpoints() + .equals(other.getEndpoints())) return false; + } if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -239,6 +290,10 @@ private static final long serialVersionUID = 0L; hash = (37 * hash) + GROUP_FIELD_NUMBER; hash = (53 * hash) + getGroup().hashCode(); } + if (hasEndpoints()) { + hash = (37 * hash) + ENDPOINTS_FIELD_NUMBER; + hash = (53 * hash) + getEndpoints().hashCode(); + } hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -384,6 +439,12 @@ private static final long serialVersionUID = 0L; group_ = null; groupBuilder_ = null; } + if (endpointsBuilder_ == null) { + endpoints_ = null; + } else { + endpoints_ = null; + endpointsBuilder_ = null; + } return this; } @@ -420,6 +481,11 @@ private static final long serialVersionUID = 0L; } else { result.group_ = groupBuilder_.build(); } + if (endpointsBuilder_ == null) { + result.endpoints_ = endpoints_; + } else { + result.endpoints_ = endpointsBuilder_.build(); + } onBuilt(); return result; } @@ -474,6 +540,9 @@ private static final long serialVersionUID = 0L; if (other.hasGroup()) { mergeGroup(other.getGroup()); } + if (other.hasEndpoints()) { + mergeEndpoints(other.getEndpoints()); + } this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -740,6 +809,125 @@ private static final long serialVersionUID = 0L; } return groupBuilder_; } + + private apache.rocketmq.v2.Endpoints endpoints_; + private com.google.protobuf.SingleFieldBuilderV3< + apache.rocketmq.v2.Endpoints, apache.rocketmq.v2.Endpoints.Builder, apache.rocketmq.v2.EndpointsOrBuilder> endpointsBuilder_; + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 3;</code> + * @return Whether the endpoints field is set. + */ + public boolean hasEndpoints() { + return endpointsBuilder_ != null || endpoints_ != null; + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 3;</code> + * @return The endpoints. + */ + public apache.rocketmq.v2.Endpoints getEndpoints() { + if (endpointsBuilder_ == null) { + return endpoints_ == null ? apache.rocketmq.v2.Endpoints.getDefaultInstance() : endpoints_; + } else { + return endpointsBuilder_.getMessage(); + } + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 3;</code> + */ + public Builder setEndpoints(apache.rocketmq.v2.Endpoints value) { + if (endpointsBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + endpoints_ = value; + onChanged(); + } else { + endpointsBuilder_.setMessage(value); + } + + return this; + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 3;</code> + */ + public Builder setEndpoints( + apache.rocketmq.v2.Endpoints.Builder builderForValue) { + if (endpointsBuilder_ == null) { + endpoints_ = builderForValue.build(); + onChanged(); + } else { + endpointsBuilder_.setMessage(builderForValue.build()); + } + + return this; + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 3;</code> + */ + public Builder mergeEndpoints(apache.rocketmq.v2.Endpoints value) { + if (endpointsBuilder_ == null) { + if (endpoints_ != null) { + endpoints_ = + apache.rocketmq.v2.Endpoints.newBuilder(endpoints_).mergeFrom(value).buildPartial(); + } else { + endpoints_ = value; + } + onChanged(); + } else { + endpointsBuilder_.mergeFrom(value); + } + + return this; + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 3;</code> + */ + public Builder clearEndpoints() { + if (endpointsBuilder_ == null) { + endpoints_ = null; + onChanged(); + } else { + endpoints_ = null; + endpointsBuilder_ = null; + } + + return this; + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 3;</code> + */ + public apache.rocketmq.v2.Endpoints.Builder getEndpointsBuilder() { + + onChanged(); + return getEndpointsFieldBuilder().getBuilder(); + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 3;</code> + */ + public apache.rocketmq.v2.EndpointsOrBuilder getEndpointsOrBuilder() { + if (endpointsBuilder_ != null) { + return endpointsBuilder_.getMessageOrBuilder(); + } else { + return endpoints_ == null ? + apache.rocketmq.v2.Endpoints.getDefaultInstance() : endpoints_; + } + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 3;</code> + */ + private com.google.protobuf.SingleFieldBuilderV3< + apache.rocketmq.v2.Endpoints, apache.rocketmq.v2.Endpoints.Builder, apache.rocketmq.v2.EndpointsOrBuilder> + getEndpointsFieldBuilder() { + if (endpointsBuilder_ == null) { + endpointsBuilder_ = new com.google.protobuf.SingleFieldBuilderV3< + apache.rocketmq.v2.Endpoints, apache.rocketmq.v2.Endpoints.Builder, apache.rocketmq.v2.EndpointsOrBuilder>( + getEndpoints(), + getParentForChildren(), + isClean()); + endpoints_ = null; + } + return endpointsBuilder_; + } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { diff --git a/src/main/java/apache/rocketmq/v2/QueryAssignmentRequestOrBuilder.java b/src/main/java/apache/rocketmq/v2/QueryAssignmentRequestOrBuilder.java index 8ce2dfc..270eaf4 100644 --- a/src/main/java/apache/rocketmq/v2/QueryAssignmentRequestOrBuilder.java +++ b/src/main/java/apache/rocketmq/v2/QueryAssignmentRequestOrBuilder.java @@ -36,4 +36,19 @@ public interface QueryAssignmentRequestOrBuilder extends * <code>.apache.rocketmq.v2.Resource group = 2;</code> */ apache.rocketmq.v2.ResourceOrBuilder getGroupOrBuilder(); + + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 3;</code> + * @return Whether the endpoints field is set. + */ + boolean hasEndpoints(); + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 3;</code> + * @return The endpoints. + */ + apache.rocketmq.v2.Endpoints getEndpoints(); + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 3;</code> + */ + apache.rocketmq.v2.EndpointsOrBuilder getEndpointsOrBuilder(); } diff --git a/src/main/java/apache/rocketmq/v2/QueryRouteRequest.java b/src/main/java/apache/rocketmq/v2/QueryRouteRequest.java index f579d64..361bb6d 100644 --- a/src/main/java/apache/rocketmq/v2/QueryRouteRequest.java +++ b/src/main/java/apache/rocketmq/v2/QueryRouteRequest.java @@ -78,6 +78,19 @@ private static final long serialVersionUID = 0L; break; } + case 18: { + apache.rocketmq.v2.Endpoints.Builder subBuilder = null; + if (endpoints_ != null) { + subBuilder = endpoints_.toBuilder(); + } + endpoints_ = input.readMessage(apache.rocketmq.v2.Endpoints.parser(), extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(endpoints_); + endpoints_ = subBuilder.buildPartial(); + } + + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -136,6 +149,32 @@ private static final long serialVersionUID = 0L; return getTopic(); } + public static final int ENDPOINTS_FIELD_NUMBER = 2; + private apache.rocketmq.v2.Endpoints endpoints_; + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 2;</code> + * @return Whether the endpoints field is set. + */ + @java.lang.Override + public boolean hasEndpoints() { + return endpoints_ != null; + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 2;</code> + * @return The endpoints. + */ + @java.lang.Override + public apache.rocketmq.v2.Endpoints getEndpoints() { + return endpoints_ == null ? apache.rocketmq.v2.Endpoints.getDefaultInstance() : endpoints_; + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 2;</code> + */ + @java.lang.Override + public apache.rocketmq.v2.EndpointsOrBuilder getEndpointsOrBuilder() { + return getEndpoints(); + } + private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -153,6 +192,9 @@ private static final long serialVersionUID = 0L; if (topic_ != null) { output.writeMessage(1, getTopic()); } + if (endpoints_ != null) { + output.writeMessage(2, getEndpoints()); + } unknownFields.writeTo(output); } @@ -166,6 +208,10 @@ private static final long serialVersionUID = 0L; size += com.google.protobuf.CodedOutputStream .computeMessageSize(1, getTopic()); } + if (endpoints_ != null) { + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(2, getEndpoints()); + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -186,6 +232,11 @@ private static final long serialVersionUID = 0L; if (!getTopic() .equals(other.getTopic())) return false; } + if (hasEndpoints() != other.hasEndpoints()) return false; + if (hasEndpoints()) { + if (!getEndpoints() + .equals(other.getEndpoints())) return false; + } if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -201,6 +252,10 @@ private static final long serialVersionUID = 0L; hash = (37 * hash) + TOPIC_FIELD_NUMBER; hash = (53 * hash) + getTopic().hashCode(); } + if (hasEndpoints()) { + hash = (37 * hash) + ENDPOINTS_FIELD_NUMBER; + hash = (53 * hash) + getEndpoints().hashCode(); + } hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -357,6 +412,12 @@ private static final long serialVersionUID = 0L; topic_ = null; topicBuilder_ = null; } + if (endpointsBuilder_ == null) { + endpoints_ = null; + } else { + endpoints_ = null; + endpointsBuilder_ = null; + } return this; } @@ -388,6 +449,11 @@ private static final long serialVersionUID = 0L; } else { result.topic_ = topicBuilder_.build(); } + if (endpointsBuilder_ == null) { + result.endpoints_ = endpoints_; + } else { + result.endpoints_ = endpointsBuilder_.build(); + } onBuilt(); return result; } @@ -439,6 +505,9 @@ private static final long serialVersionUID = 0L; if (other.hasTopic()) { mergeTopic(other.getTopic()); } + if (other.hasEndpoints()) { + mergeEndpoints(other.getEndpoints()); + } this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -586,6 +655,125 @@ private static final long serialVersionUID = 0L; } return topicBuilder_; } + + private apache.rocketmq.v2.Endpoints endpoints_; + private com.google.protobuf.SingleFieldBuilderV3< + apache.rocketmq.v2.Endpoints, apache.rocketmq.v2.Endpoints.Builder, apache.rocketmq.v2.EndpointsOrBuilder> endpointsBuilder_; + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 2;</code> + * @return Whether the endpoints field is set. + */ + public boolean hasEndpoints() { + return endpointsBuilder_ != null || endpoints_ != null; + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 2;</code> + * @return The endpoints. + */ + public apache.rocketmq.v2.Endpoints getEndpoints() { + if (endpointsBuilder_ == null) { + return endpoints_ == null ? apache.rocketmq.v2.Endpoints.getDefaultInstance() : endpoints_; + } else { + return endpointsBuilder_.getMessage(); + } + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 2;</code> + */ + public Builder setEndpoints(apache.rocketmq.v2.Endpoints value) { + if (endpointsBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + endpoints_ = value; + onChanged(); + } else { + endpointsBuilder_.setMessage(value); + } + + return this; + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 2;</code> + */ + public Builder setEndpoints( + apache.rocketmq.v2.Endpoints.Builder builderForValue) { + if (endpointsBuilder_ == null) { + endpoints_ = builderForValue.build(); + onChanged(); + } else { + endpointsBuilder_.setMessage(builderForValue.build()); + } + + return this; + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 2;</code> + */ + public Builder mergeEndpoints(apache.rocketmq.v2.Endpoints value) { + if (endpointsBuilder_ == null) { + if (endpoints_ != null) { + endpoints_ = + apache.rocketmq.v2.Endpoints.newBuilder(endpoints_).mergeFrom(value).buildPartial(); + } else { + endpoints_ = value; + } + onChanged(); + } else { + endpointsBuilder_.mergeFrom(value); + } + + return this; + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 2;</code> + */ + public Builder clearEndpoints() { + if (endpointsBuilder_ == null) { + endpoints_ = null; + onChanged(); + } else { + endpoints_ = null; + endpointsBuilder_ = null; + } + + return this; + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 2;</code> + */ + public apache.rocketmq.v2.Endpoints.Builder getEndpointsBuilder() { + + onChanged(); + return getEndpointsFieldBuilder().getBuilder(); + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 2;</code> + */ + public apache.rocketmq.v2.EndpointsOrBuilder getEndpointsOrBuilder() { + if (endpointsBuilder_ != null) { + return endpointsBuilder_.getMessageOrBuilder(); + } else { + return endpoints_ == null ? + apache.rocketmq.v2.Endpoints.getDefaultInstance() : endpoints_; + } + } + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 2;</code> + */ + private com.google.protobuf.SingleFieldBuilderV3< + apache.rocketmq.v2.Endpoints, apache.rocketmq.v2.Endpoints.Builder, apache.rocketmq.v2.EndpointsOrBuilder> + getEndpointsFieldBuilder() { + if (endpointsBuilder_ == null) { + endpointsBuilder_ = new com.google.protobuf.SingleFieldBuilderV3< + apache.rocketmq.v2.Endpoints, apache.rocketmq.v2.Endpoints.Builder, apache.rocketmq.v2.EndpointsOrBuilder>( + getEndpoints(), + getParentForChildren(), + isClean()); + endpoints_ = null; + } + return endpointsBuilder_; + } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { diff --git a/src/main/java/apache/rocketmq/v2/QueryRouteRequestOrBuilder.java b/src/main/java/apache/rocketmq/v2/QueryRouteRequestOrBuilder.java index 0357827..a61c342 100644 --- a/src/main/java/apache/rocketmq/v2/QueryRouteRequestOrBuilder.java +++ b/src/main/java/apache/rocketmq/v2/QueryRouteRequestOrBuilder.java @@ -21,4 +21,19 @@ public interface QueryRouteRequestOrBuilder extends * <code>.apache.rocketmq.v2.Resource topic = 1;</code> */ apache.rocketmq.v2.ResourceOrBuilder getTopicOrBuilder(); + + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 2;</code> + * @return Whether the endpoints field is set. + */ + boolean hasEndpoints(); + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 2;</code> + * @return The endpoints. + */ + apache.rocketmq.v2.Endpoints getEndpoints(); + /** + * <code>.apache.rocketmq.v2.Endpoints endpoints = 2;</code> + */ + apache.rocketmq.v2.EndpointsOrBuilder getEndpointsOrBuilder(); } diff --git a/src/main/java/apache/rocketmq/v2/ReceiveMessageRequest.java b/src/main/java/apache/rocketmq/v2/ReceiveMessageRequest.java index 3122e1c..42f2936 100644 --- a/src/main/java/apache/rocketmq/v2/ReceiveMessageRequest.java +++ b/src/main/java/apache/rocketmq/v2/ReceiveMessageRequest.java @@ -106,6 +106,11 @@ private static final long serialVersionUID = 0L; bitField0_ |= 0x00000001; break; } + case 48: { + + autoRenew_ = input.readBool(); + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -266,6 +271,21 @@ private static final long serialVersionUID = 0L; return invisibleDuration_ == null ? com.google.protobuf.Duration.getDefaultInstance() : invisibleDuration_; } + public static final int AUTO_RENEW_FIELD_NUMBER = 6; + private boolean autoRenew_; + /** + * <pre> + * For message auto renew and clean + * </pre> + * + * <code>bool auto_renew = 6;</code> + * @return The autoRenew. + */ + @java.lang.Override + public boolean getAutoRenew() { + return autoRenew_; + } + private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -295,6 +315,9 @@ private static final long serialVersionUID = 0L; if (((bitField0_ & 0x00000001) != 0)) { output.writeMessage(5, getInvisibleDuration()); } + if (autoRenew_ != false) { + output.writeBool(6, autoRenew_); + } unknownFields.writeTo(output); } @@ -324,6 +347,10 @@ private static final long serialVersionUID = 0L; size += com.google.protobuf.CodedOutputStream .computeMessageSize(5, getInvisibleDuration()); } + if (autoRenew_ != false) { + size += com.google.protobuf.CodedOutputStream + .computeBoolSize(6, autoRenew_); + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -361,6 +388,8 @@ private static final long serialVersionUID = 0L; if (!getInvisibleDuration() .equals(other.getInvisibleDuration())) return false; } + if (getAutoRenew() + != other.getAutoRenew()) return false; if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -390,6 +419,9 @@ private static final long serialVersionUID = 0L; hash = (37 * hash) + INVISIBLE_DURATION_FIELD_NUMBER; hash = (53 * hash) + getInvisibleDuration().hashCode(); } + hash = (37 * hash) + AUTO_RENEW_FIELD_NUMBER; + hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean( + getAutoRenew()); hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -550,6 +582,8 @@ private static final long serialVersionUID = 0L; invisibleDurationBuilder_.clear(); } bitField0_ = (bitField0_ & ~0x00000001); + autoRenew_ = false; + return this; } @@ -602,6 +636,7 @@ private static final long serialVersionUID = 0L; } to_bitField0_ |= 0x00000001; } + result.autoRenew_ = autoRenew_; result.bitField0_ = to_bitField0_; onBuilt(); return result; @@ -666,6 +701,9 @@ private static final long serialVersionUID = 0L; if (other.hasInvisibleDuration()) { mergeInvisibleDuration(other.getInvisibleDuration()); } + if (other.getAutoRenew() != false) { + setAutoRenew(other.getAutoRenew()); + } this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -1239,6 +1277,49 @@ private static final long serialVersionUID = 0L; } return invisibleDurationBuilder_; } + + private boolean autoRenew_ ; + /** + * <pre> + * For message auto renew and clean + * </pre> + * + * <code>bool auto_renew = 6;</code> + * @return The autoRenew. + */ + @java.lang.Override + public boolean getAutoRenew() { + return autoRenew_; + } + /** + * <pre> + * For message auto renew and clean + * </pre> + * + * <code>bool auto_renew = 6;</code> + * @param value The autoRenew to set. + * @return This builder for chaining. + */ + public Builder setAutoRenew(boolean value) { + + autoRenew_ = value; + onChanged(); + return this; + } + /** + * <pre> + * For message auto renew and clean + * </pre> + * + * <code>bool auto_renew = 6;</code> + * @return This builder for chaining. + */ + public Builder clearAutoRenew() { + + autoRenew_ = 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 2a43b5e..b6fbc15 100644 --- a/src/main/java/apache/rocketmq/v2/ReceiveMessageRequestOrBuilder.java +++ b/src/main/java/apache/rocketmq/v2/ReceiveMessageRequestOrBuilder.java @@ -84,4 +84,14 @@ public interface ReceiveMessageRequestOrBuilder extends * <code>optional .google.protobuf.Duration invisible_duration = 5;</code> */ com.google.protobuf.DurationOrBuilder getInvisibleDurationOrBuilder(); + + /** + * <pre> + * For message auto renew and clean + * </pre> + * + * <code>bool auto_renew = 6;</code> + * @return The autoRenew. + */ + boolean getAutoRenew(); } diff --git a/src/main/java/apache/rocketmq/v2/Settings.java b/src/main/java/apache/rocketmq/v2/Settings.java index d626778..74b0ba0 100644 --- a/src/main/java/apache/rocketmq/v2/Settings.java +++ b/src/main/java/apache/rocketmq/v2/Settings.java @@ -71,7 +71,7 @@ private static final long serialVersionUID = 0L; } case 26: { apache.rocketmq.v2.RetryPolicy.Builder subBuilder = null; - if (backoffPolicy_ != null) { + if (((bitField0_ & 0x00000004) != 0)) { subBuilder = backoffPolicy_.toBuilder(); } backoffPolicy_ = input.readMessage(apache.rocketmq.v2.RetryPolicy.parser(), extensionRegistry); @@ -79,12 +79,12 @@ private static final long serialVersionUID = 0L; subBuilder.mergeFrom(backoffPolicy_); backoffPolicy_ = subBuilder.buildPartial(); } - + bitField0_ |= 0x00000004; break; } case 34: { com.google.protobuf.Duration.Builder subBuilder = null; - if (((bitField0_ & 0x00000004) != 0)) { + if (((bitField0_ & 0x00000008) != 0)) { subBuilder = requestTimeout_.toBuilder(); } requestTimeout_ = input.readMessage(com.google.protobuf.Duration.parser(), extensionRegistry); @@ -92,7 +92,7 @@ private static final long serialVersionUID = 0L; subBuilder.mergeFrom(requestTimeout_); requestTimeout_ = subBuilder.buildPartial(); } - bitField0_ |= 0x00000004; + bitField0_ |= 0x00000008; break; } case 42: { @@ -275,12 +275,12 @@ private static final long serialVersionUID = 0L; * the prior one depletes its lifecycle. * </pre> * - * <code>.apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> + * <code>optional .apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> * @return Whether the backoffPolicy field is set. */ @java.lang.Override public boolean hasBackoffPolicy() { - return backoffPolicy_ != null; + return ((bitField0_ & 0x00000004) != 0); } /** * <pre> @@ -294,7 +294,7 @@ private static final long serialVersionUID = 0L; * the prior one depletes its lifecycle. * </pre> * - * <code>.apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> + * <code>optional .apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> * @return The backoffPolicy. */ @java.lang.Override @@ -313,11 +313,11 @@ private static final long serialVersionUID = 0L; * the prior one depletes its lifecycle. * </pre> * - * <code>.apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> + * <code>optional .apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> */ @java.lang.Override public apache.rocketmq.v2.RetryPolicyOrBuilder getBackoffPolicyOrBuilder() { - return getBackoffPolicy(); + return backoffPolicy_ == null ? apache.rocketmq.v2.RetryPolicy.getDefaultInstance() : backoffPolicy_; } public static final int REQUEST_TIMEOUT_FIELD_NUMBER = 4; @@ -332,7 +332,7 @@ private static final long serialVersionUID = 0L; */ @java.lang.Override public boolean hasRequestTimeout() { - return ((bitField0_ & 0x00000004) != 0); + return ((bitField0_ & 0x00000008) != 0); } /** * <pre> @@ -440,10 +440,10 @@ private static final long serialVersionUID = 0L; if (((bitField0_ & 0x00000002) != 0)) { output.writeMessage(2, getAccessPoint()); } - if (backoffPolicy_ != null) { + if (((bitField0_ & 0x00000004) != 0)) { output.writeMessage(3, getBackoffPolicy()); } - if (((bitField0_ & 0x00000004) != 0)) { + if (((bitField0_ & 0x00000008) != 0)) { output.writeMessage(4, getRequestTimeout()); } if (pubSubCase_ == 5) { @@ -469,11 +469,11 @@ private static final long serialVersionUID = 0L; size += com.google.protobuf.CodedOutputStream .computeMessageSize(2, getAccessPoint()); } - if (backoffPolicy_ != null) { + if (((bitField0_ & 0x00000004) != 0)) { size += com.google.protobuf.CodedOutputStream .computeMessageSize(3, getBackoffPolicy()); } - if (((bitField0_ & 0x00000004) != 0)) { + if (((bitField0_ & 0x00000008) != 0)) { size += com.google.protobuf.CodedOutputStream .computeMessageSize(4, getRequestTimeout()); } @@ -700,6 +700,7 @@ private static final long serialVersionUID = 0L; if (com.google.protobuf.GeneratedMessageV3 .alwaysUseFieldBuilders) { getAccessPointFieldBuilder(); + getBackoffPolicyFieldBuilder(); getRequestTimeoutFieldBuilder(); } } @@ -717,15 +718,15 @@ private static final long serialVersionUID = 0L; if (backoffPolicyBuilder_ == null) { backoffPolicy_ = null; } else { - backoffPolicy_ = null; - backoffPolicyBuilder_ = null; + backoffPolicyBuilder_.clear(); } + bitField0_ = (bitField0_ & ~0x00000004); if (requestTimeoutBuilder_ == null) { requestTimeout_ = null; } else { requestTimeoutBuilder_.clear(); } - bitField0_ = (bitField0_ & ~0x00000004); + bitField0_ = (bitField0_ & ~0x00000008); pubSubCase_ = 0; pubSub_ = null; return this; @@ -768,18 +769,21 @@ private static final long serialVersionUID = 0L; } to_bitField0_ |= 0x00000002; } - if (backoffPolicyBuilder_ == null) { - result.backoffPolicy_ = backoffPolicy_; - } else { - result.backoffPolicy_ = backoffPolicyBuilder_.build(); - } if (((from_bitField0_ & 0x00000004) != 0)) { + if (backoffPolicyBuilder_ == null) { + result.backoffPolicy_ = backoffPolicy_; + } else { + result.backoffPolicy_ = backoffPolicyBuilder_.build(); + } + to_bitField0_ |= 0x00000004; + } + if (((from_bitField0_ & 0x00000008) != 0)) { if (requestTimeoutBuilder_ == null) { result.requestTimeout_ = requestTimeout_; } else { result.requestTimeout_ = requestTimeoutBuilder_.build(); } - to_bitField0_ |= 0x00000004; + to_bitField0_ |= 0x00000008; } if (pubSubCase_ == 5) { if (publishingBuilder_ == null) { @@ -1135,11 +1139,11 @@ private static final long serialVersionUID = 0L; * the prior one depletes its lifecycle. * </pre> * - * <code>.apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> + * <code>optional .apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> * @return Whether the backoffPolicy field is set. */ public boolean hasBackoffPolicy() { - return backoffPolicyBuilder_ != null || backoffPolicy_ != null; + return ((bitField0_ & 0x00000004) != 0); } /** * <pre> @@ -1153,7 +1157,7 @@ private static final long serialVersionUID = 0L; * the prior one depletes its lifecycle. * </pre> * - * <code>.apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> + * <code>optional .apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> * @return The backoffPolicy. */ public apache.rocketmq.v2.RetryPolicy getBackoffPolicy() { @@ -1175,7 +1179,7 @@ private static final long serialVersionUID = 0L; * the prior one depletes its lifecycle. * </pre> * - * <code>.apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> + * <code>optional .apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> */ public Builder setBackoffPolicy(apache.rocketmq.v2.RetryPolicy value) { if (backoffPolicyBuilder_ == null) { @@ -1187,7 +1191,7 @@ private static final long serialVersionUID = 0L; } else { backoffPolicyBuilder_.setMessage(value); } - + bitField0_ |= 0x00000004; return this; } /** @@ -1202,7 +1206,7 @@ private static final long serialVersionUID = 0L; * the prior one depletes its lifecycle. * </pre> * - * <code>.apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> + * <code>optional .apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> */ public Builder setBackoffPolicy( apache.rocketmq.v2.RetryPolicy.Builder builderForValue) { @@ -1212,7 +1216,7 @@ private static final long serialVersionUID = 0L; } else { backoffPolicyBuilder_.setMessage(builderForValue.build()); } - + bitField0_ |= 0x00000004; return this; } /** @@ -1227,11 +1231,13 @@ private static final long serialVersionUID = 0L; * the prior one depletes its lifecycle. * </pre> * - * <code>.apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> + * <code>optional .apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> */ public Builder mergeBackoffPolicy(apache.rocketmq.v2.RetryPolicy value) { if (backoffPolicyBuilder_ == null) { - if (backoffPolicy_ != null) { + if (((bitField0_ & 0x00000004) != 0) && + backoffPolicy_ != null && + backoffPolicy_ != apache.rocketmq.v2.RetryPolicy.getDefaultInstance()) { backoffPolicy_ = apache.rocketmq.v2.RetryPolicy.newBuilder(backoffPolicy_).mergeFrom(value).buildPartial(); } else { @@ -1241,7 +1247,7 @@ private static final long serialVersionUID = 0L; } else { backoffPolicyBuilder_.mergeFrom(value); } - + bitField0_ |= 0x00000004; return this; } /** @@ -1256,17 +1262,16 @@ private static final long serialVersionUID = 0L; * the prior one depletes its lifecycle. * </pre> * - * <code>.apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> + * <code>optional .apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> */ public Builder clearBackoffPolicy() { if (backoffPolicyBuilder_ == null) { backoffPolicy_ = null; onChanged(); } else { - backoffPolicy_ = null; - backoffPolicyBuilder_ = null; + backoffPolicyBuilder_.clear(); } - + bitField0_ = (bitField0_ & ~0x00000004); return this; } /** @@ -1281,10 +1286,10 @@ private static final long serialVersionUID = 0L; * the prior one depletes its lifecycle. * </pre> * - * <code>.apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> + * <code>optional .apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> */ public apache.rocketmq.v2.RetryPolicy.Builder getBackoffPolicyBuilder() { - + bitField0_ |= 0x00000004; onChanged(); return getBackoffPolicyFieldBuilder().getBuilder(); } @@ -1300,7 +1305,7 @@ private static final long serialVersionUID = 0L; * the prior one depletes its lifecycle. * </pre> * - * <code>.apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> + * <code>optional .apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> */ public apache.rocketmq.v2.RetryPolicyOrBuilder getBackoffPolicyOrBuilder() { if (backoffPolicyBuilder_ != null) { @@ -1322,7 +1327,7 @@ private static final long serialVersionUID = 0L; * the prior one depletes its lifecycle. * </pre> * - * <code>.apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> + * <code>optional .apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> */ private com.google.protobuf.SingleFieldBuilderV3< apache.rocketmq.v2.RetryPolicy, apache.rocketmq.v2.RetryPolicy.Builder, apache.rocketmq.v2.RetryPolicyOrBuilder> @@ -1350,7 +1355,7 @@ private static final long serialVersionUID = 0L; * @return Whether the requestTimeout field is set. */ public boolean hasRequestTimeout() { - return ((bitField0_ & 0x00000004) != 0); + return ((bitField0_ & 0x00000008) != 0); } /** * <pre> @@ -1384,7 +1389,7 @@ private static final long serialVersionUID = 0L; } else { requestTimeoutBuilder_.setMessage(value); } - bitField0_ |= 0x00000004; + bitField0_ |= 0x00000008; return this; } /** @@ -1402,7 +1407,7 @@ private static final long serialVersionUID = 0L; } else { requestTimeoutBuilder_.setMessage(builderForValue.build()); } - bitField0_ |= 0x00000004; + bitField0_ |= 0x00000008; return this; } /** @@ -1414,7 +1419,7 @@ private static final long serialVersionUID = 0L; */ public Builder mergeRequestTimeout(com.google.protobuf.Duration value) { if (requestTimeoutBuilder_ == null) { - if (((bitField0_ & 0x00000004) != 0) && + if (((bitField0_ & 0x00000008) != 0) && requestTimeout_ != null && requestTimeout_ != com.google.protobuf.Duration.getDefaultInstance()) { requestTimeout_ = @@ -1426,7 +1431,7 @@ private static final long serialVersionUID = 0L; } else { requestTimeoutBuilder_.mergeFrom(value); } - bitField0_ |= 0x00000004; + bitField0_ |= 0x00000008; return this; } /** @@ -1443,7 +1448,7 @@ private static final long serialVersionUID = 0L; } else { requestTimeoutBuilder_.clear(); } - bitField0_ = (bitField0_ & ~0x00000004); + bitField0_ = (bitField0_ & ~0x00000008); return this; } /** @@ -1454,7 +1459,7 @@ private static final long serialVersionUID = 0L; * <code>optional .google.protobuf.Duration request_timeout = 4;</code> */ public com.google.protobuf.Duration.Builder getRequestTimeoutBuilder() { - bitField0_ |= 0x00000004; + bitField0_ |= 0x00000008; onChanged(); return getRequestTimeoutFieldBuilder().getBuilder(); } diff --git a/src/main/java/apache/rocketmq/v2/SettingsOrBuilder.java b/src/main/java/apache/rocketmq/v2/SettingsOrBuilder.java index 0bdb176..66ca784 100644 --- a/src/main/java/apache/rocketmq/v2/SettingsOrBuilder.java +++ b/src/main/java/apache/rocketmq/v2/SettingsOrBuilder.java @@ -62,7 +62,7 @@ public interface SettingsOrBuilder extends * the prior one depletes its lifecycle. * </pre> * - * <code>.apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> + * <code>optional .apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> * @return Whether the backoffPolicy field is set. */ boolean hasBackoffPolicy(); @@ -78,7 +78,7 @@ public interface SettingsOrBuilder extends * the prior one depletes its lifecycle. * </pre> * - * <code>.apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> + * <code>optional .apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> * @return The backoffPolicy. */ apache.rocketmq.v2.RetryPolicy getBackoffPolicy(); @@ -94,7 +94,7 @@ public interface SettingsOrBuilder extends * the prior one depletes its lifecycle. * </pre> * - * <code>.apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> + * <code>optional .apache.rocketmq.v2.RetryPolicy backoff_policy = 3;</code> */ apache.rocketmq.v2.RetryPolicyOrBuilder getBackoffPolicyOrBuilder(); diff --git a/src/main/resources/proto/apache/rocketmq/v2/service.proto b/src/main/resources/proto/apache/rocketmq/v2/service.proto index b9cf533..e9fb514 100644 --- a/src/main/resources/proto/apache/rocketmq/v2/service.proto +++ b/src/main/resources/proto/apache/rocketmq/v2/service.proto @@ -46,7 +46,10 @@ option java_outer_classname = "MQService"; // access-point, which annotates tenant-id, instance-id or other // vendor-specific settings. Purpose-built name servers may respond customized // results based on these particular requirements. -message QueryRouteRequest { Resource topic = 1; } +message QueryRouteRequest { + Resource topic = 1; + Endpoints endpoints = 2; +} message QueryRouteResponse { Status status = 1; @@ -66,6 +69,7 @@ message SendMessageResponse { message QueryAssignmentRequest { Resource topic = 1; Resource group = 2; + Endpoints endpoints = 3; } message QueryAssignmentResponse { @@ -80,6 +84,8 @@ message ReceiveMessageRequest { int32 batch_size = 4; // Required if client type is simple consumer. optional google.protobuf.Duration invisible_duration = 5; + // For message auto renew and clean + bool auto_renew = 6; } message ReceiveMessageResponse { @@ -242,7 +248,7 @@ message Settings { // For FIFO messages, the interval should be relatively small because // messages of the same message group would not be readily available utill // the prior one depletes its lifecycle. - RetryPolicy backoff_policy = 3; + optional RetryPolicy backoff_policy = 3; // Request timeout for RPCs excluding long-polling. optional google.protobuf.Duration request_timeout = 4; @@ -290,6 +296,9 @@ message ChangeInvisibleDurationRequest { // New invisible duration google.protobuf.Duration invisible_duration = 4; + + // For message tracing + string message_id = 5; } message ChangeInvisibleDurationResponse {
