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 b4f7ca60c0e147a0aa3b5606fd657df13b68c864 Author: 凌楚 <[email protected]> AuthorDate: Tue Apr 19 16:49:52 2022 +0800 Apply IDL update --- .../apache/rocketmq/v2/AckMessageResponse.java | 300 +++++++++++++++++-- .../rocketmq/v2/AckMessageResponseOrBuilder.java | 40 ++- .../apache/rocketmq/v2/AckMessageResultEntry.java | 72 +++++ .../v2/AckMessageResultEntryOrBuilder.java | 18 ++ src/main/java/apache/rocketmq/v2/MQService.java | 325 +++++++++++---------- .../proto/apache/rocketmq/v2/service.proto | 13 +- 6 files changed, 574 insertions(+), 194 deletions(-) diff --git a/src/main/java/apache/rocketmq/v2/AckMessageResponse.java b/src/main/java/apache/rocketmq/v2/AckMessageResponse.java index 0c5ea92..90d8738 100644 --- a/src/main/java/apache/rocketmq/v2/AckMessageResponse.java +++ b/src/main/java/apache/rocketmq/v2/AckMessageResponse.java @@ -51,6 +51,19 @@ private static final long serialVersionUID = 0L; done = true; break; case 10: { + apache.rocketmq.v2.Status.Builder subBuilder = null; + if (status_ != null) { + subBuilder = status_.toBuilder(); + } + status_ = input.readMessage(apache.rocketmq.v2.Status.parser(), extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(status_); + status_ = subBuilder.buildPartial(); + } + + break; + } + case 18: { if (!((mutable_bitField0_ & 0x00000001) != 0)) { entries_ = new java.util.ArrayList<apache.rocketmq.v2.AckMessageResultEntry>(); mutable_bitField0_ |= 0x00000001; @@ -94,17 +107,58 @@ private static final long serialVersionUID = 0L; apache.rocketmq.v2.AckMessageResponse.class, apache.rocketmq.v2.AckMessageResponse.Builder.class); } - public static final int ENTRIES_FIELD_NUMBER = 1; + public static final int STATUS_FIELD_NUMBER = 1; + private apache.rocketmq.v2.Status status_; + /** + * <pre> + * RPC tier status, which is used to represent RPC-level errors including + * authentication, authorization, throttling and other general failures. + * </pre> + * + * <code>.apache.rocketmq.v2.Status status = 1;</code> + * @return Whether the status field is set. + */ + @java.lang.Override + public boolean hasStatus() { + return status_ != null; + } + /** + * <pre> + * RPC tier status, which is used to represent RPC-level errors including + * authentication, authorization, throttling and other general failures. + * </pre> + * + * <code>.apache.rocketmq.v2.Status status = 1;</code> + * @return The status. + */ + @java.lang.Override + public apache.rocketmq.v2.Status getStatus() { + return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_; + } + /** + * <pre> + * RPC tier status, which is used to represent RPC-level errors including + * authentication, authorization, throttling and other general failures. + * </pre> + * + * <code>.apache.rocketmq.v2.Status status = 1;</code> + */ + @java.lang.Override + public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() { + return getStatus(); + } + + public static final int ENTRIES_FIELD_NUMBER = 2; private java.util.List<apache.rocketmq.v2.AckMessageResultEntry> entries_; /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ @java.lang.Override public java.util.List<apache.rocketmq.v2.AckMessageResultEntry> getEntriesList() { return entries_; } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ @java.lang.Override public java.util.List<? extends apache.rocketmq.v2.AckMessageResultEntryOrBuilder> @@ -112,21 +166,21 @@ private static final long serialVersionUID = 0L; return entries_; } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ @java.lang.Override public int getEntriesCount() { return entries_.size(); } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ @java.lang.Override public apache.rocketmq.v2.AckMessageResultEntry getEntries(int index) { return entries_.get(index); } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ @java.lang.Override public apache.rocketmq.v2.AckMessageResultEntryOrBuilder getEntriesOrBuilder( @@ -148,8 +202,11 @@ private static final long serialVersionUID = 0L; @java.lang.Override public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException { + if (status_ != null) { + output.writeMessage(1, getStatus()); + } for (int i = 0; i < entries_.size(); i++) { - output.writeMessage(1, entries_.get(i)); + output.writeMessage(2, entries_.get(i)); } unknownFields.writeTo(output); } @@ -160,9 +217,13 @@ private static final long serialVersionUID = 0L; if (size != -1) return size; size = 0; + if (status_ != null) { + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(1, getStatus()); + } for (int i = 0; i < entries_.size(); i++) { size += com.google.protobuf.CodedOutputStream - .computeMessageSize(1, entries_.get(i)); + .computeMessageSize(2, entries_.get(i)); } size += unknownFields.getSerializedSize(); memoizedSize = size; @@ -179,6 +240,11 @@ private static final long serialVersionUID = 0L; } apache.rocketmq.v2.AckMessageResponse other = (apache.rocketmq.v2.AckMessageResponse) obj; + if (hasStatus() != other.hasStatus()) return false; + if (hasStatus()) { + if (!getStatus() + .equals(other.getStatus())) return false; + } if (!getEntriesList() .equals(other.getEntriesList())) return false; if (!unknownFields.equals(other.unknownFields)) return false; @@ -192,6 +258,10 @@ private static final long serialVersionUID = 0L; } int hash = 41; hash = (19 * hash) + getDescriptor().hashCode(); + if (hasStatus()) { + hash = (37 * hash) + STATUS_FIELD_NUMBER; + hash = (53 * hash) + getStatus().hashCode(); + } if (getEntriesCount() > 0) { hash = (37 * hash) + ENTRIES_FIELD_NUMBER; hash = (53 * hash) + getEntriesList().hashCode(); @@ -330,6 +400,12 @@ private static final long serialVersionUID = 0L; @java.lang.Override public Builder clear() { super.clear(); + if (statusBuilder_ == null) { + status_ = null; + } else { + status_ = null; + statusBuilder_ = null; + } if (entriesBuilder_ == null) { entries_ = java.util.Collections.emptyList(); bitField0_ = (bitField0_ & ~0x00000001); @@ -363,6 +439,11 @@ private static final long serialVersionUID = 0L; public apache.rocketmq.v2.AckMessageResponse buildPartial() { apache.rocketmq.v2.AckMessageResponse result = new apache.rocketmq.v2.AckMessageResponse(this); int from_bitField0_ = bitField0_; + if (statusBuilder_ == null) { + result.status_ = status_; + } else { + result.status_ = statusBuilder_.build(); + } if (entriesBuilder_ == null) { if (((bitField0_ & 0x00000001) != 0)) { entries_ = java.util.Collections.unmodifiableList(entries_); @@ -420,6 +501,9 @@ private static final long serialVersionUID = 0L; public Builder mergeFrom(apache.rocketmq.v2.AckMessageResponse other) { if (other == apache.rocketmq.v2.AckMessageResponse.getDefaultInstance()) return this; + if (other.hasStatus()) { + mergeStatus(other.getStatus()); + } if (entriesBuilder_ == null) { if (!other.entries_.isEmpty()) { if (entries_.isEmpty()) { @@ -476,6 +560,170 @@ private static final long serialVersionUID = 0L; } private int bitField0_; + private apache.rocketmq.v2.Status status_; + private com.google.protobuf.SingleFieldBuilderV3< + apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> statusBuilder_; + /** + * <pre> + * RPC tier status, which is used to represent RPC-level errors including + * authentication, authorization, throttling and other general failures. + * </pre> + * + * <code>.apache.rocketmq.v2.Status status = 1;</code> + * @return Whether the status field is set. + */ + public boolean hasStatus() { + return statusBuilder_ != null || status_ != null; + } + /** + * <pre> + * RPC tier status, which is used to represent RPC-level errors including + * authentication, authorization, throttling and other general failures. + * </pre> + * + * <code>.apache.rocketmq.v2.Status status = 1;</code> + * @return The status. + */ + public apache.rocketmq.v2.Status getStatus() { + if (statusBuilder_ == null) { + return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_; + } else { + return statusBuilder_.getMessage(); + } + } + /** + * <pre> + * RPC tier status, which is used to represent RPC-level errors including + * authentication, authorization, throttling and other general failures. + * </pre> + * + * <code>.apache.rocketmq.v2.Status status = 1;</code> + */ + public Builder setStatus(apache.rocketmq.v2.Status value) { + if (statusBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + status_ = value; + onChanged(); + } else { + statusBuilder_.setMessage(value); + } + + return this; + } + /** + * <pre> + * RPC tier status, which is used to represent RPC-level errors including + * authentication, authorization, throttling and other general failures. + * </pre> + * + * <code>.apache.rocketmq.v2.Status status = 1;</code> + */ + public Builder setStatus( + apache.rocketmq.v2.Status.Builder builderForValue) { + if (statusBuilder_ == null) { + status_ = builderForValue.build(); + onChanged(); + } else { + statusBuilder_.setMessage(builderForValue.build()); + } + + return this; + } + /** + * <pre> + * RPC tier status, which is used to represent RPC-level errors including + * authentication, authorization, throttling and other general failures. + * </pre> + * + * <code>.apache.rocketmq.v2.Status status = 1;</code> + */ + public Builder mergeStatus(apache.rocketmq.v2.Status value) { + if (statusBuilder_ == null) { + if (status_ != null) { + status_ = + apache.rocketmq.v2.Status.newBuilder(status_).mergeFrom(value).buildPartial(); + } else { + status_ = value; + } + onChanged(); + } else { + statusBuilder_.mergeFrom(value); + } + + return this; + } + /** + * <pre> + * RPC tier status, which is used to represent RPC-level errors including + * authentication, authorization, throttling and other general failures. + * </pre> + * + * <code>.apache.rocketmq.v2.Status status = 1;</code> + */ + public Builder clearStatus() { + if (statusBuilder_ == null) { + status_ = null; + onChanged(); + } else { + status_ = null; + statusBuilder_ = null; + } + + return this; + } + /** + * <pre> + * RPC tier status, which is used to represent RPC-level errors including + * authentication, authorization, throttling and other general failures. + * </pre> + * + * <code>.apache.rocketmq.v2.Status status = 1;</code> + */ + public apache.rocketmq.v2.Status.Builder getStatusBuilder() { + + onChanged(); + return getStatusFieldBuilder().getBuilder(); + } + /** + * <pre> + * RPC tier status, which is used to represent RPC-level errors including + * authentication, authorization, throttling and other general failures. + * </pre> + * + * <code>.apache.rocketmq.v2.Status status = 1;</code> + */ + public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() { + if (statusBuilder_ != null) { + return statusBuilder_.getMessageOrBuilder(); + } else { + return status_ == null ? + apache.rocketmq.v2.Status.getDefaultInstance() : status_; + } + } + /** + * <pre> + * RPC tier status, which is used to represent RPC-level errors including + * authentication, authorization, throttling and other general failures. + * </pre> + * + * <code>.apache.rocketmq.v2.Status status = 1;</code> + */ + private com.google.protobuf.SingleFieldBuilderV3< + apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> + getStatusFieldBuilder() { + if (statusBuilder_ == null) { + statusBuilder_ = new com.google.protobuf.SingleFieldBuilderV3< + apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder>( + getStatus(), + getParentForChildren(), + isClean()); + status_ = null; + } + return statusBuilder_; + } + private java.util.List<apache.rocketmq.v2.AckMessageResultEntry> entries_ = java.util.Collections.emptyList(); private void ensureEntriesIsMutable() { @@ -489,7 +737,7 @@ private static final long serialVersionUID = 0L; apache.rocketmq.v2.AckMessageResultEntry, apache.rocketmq.v2.AckMessageResultEntry.Builder, apache.rocketmq.v2.AckMessageResultEntryOrBuilder> entriesBuilder_; /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public java.util.List<apache.rocketmq.v2.AckMessageResultEntry> getEntriesList() { if (entriesBuilder_ == null) { @@ -499,7 +747,7 @@ private static final long serialVersionUID = 0L; } } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public int getEntriesCount() { if (entriesBuilder_ == null) { @@ -509,7 +757,7 @@ private static final long serialVersionUID = 0L; } } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public apache.rocketmq.v2.AckMessageResultEntry getEntries(int index) { if (entriesBuilder_ == null) { @@ -519,7 +767,7 @@ private static final long serialVersionUID = 0L; } } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public Builder setEntries( int index, apache.rocketmq.v2.AckMessageResultEntry value) { @@ -536,7 +784,7 @@ private static final long serialVersionUID = 0L; return this; } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public Builder setEntries( int index, apache.rocketmq.v2.AckMessageResultEntry.Builder builderForValue) { @@ -550,7 +798,7 @@ private static final long serialVersionUID = 0L; return this; } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public Builder addEntries(apache.rocketmq.v2.AckMessageResultEntry value) { if (entriesBuilder_ == null) { @@ -566,7 +814,7 @@ private static final long serialVersionUID = 0L; return this; } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public Builder addEntries( int index, apache.rocketmq.v2.AckMessageResultEntry value) { @@ -583,7 +831,7 @@ private static final long serialVersionUID = 0L; return this; } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public Builder addEntries( apache.rocketmq.v2.AckMessageResultEntry.Builder builderForValue) { @@ -597,7 +845,7 @@ private static final long serialVersionUID = 0L; return this; } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public Builder addEntries( int index, apache.rocketmq.v2.AckMessageResultEntry.Builder builderForValue) { @@ -611,7 +859,7 @@ private static final long serialVersionUID = 0L; return this; } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public Builder addAllEntries( java.lang.Iterable<? extends apache.rocketmq.v2.AckMessageResultEntry> values) { @@ -626,7 +874,7 @@ private static final long serialVersionUID = 0L; return this; } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public Builder clearEntries() { if (entriesBuilder_ == null) { @@ -639,7 +887,7 @@ private static final long serialVersionUID = 0L; return this; } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public Builder removeEntries(int index) { if (entriesBuilder_ == null) { @@ -652,14 +900,14 @@ private static final long serialVersionUID = 0L; return this; } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public apache.rocketmq.v2.AckMessageResultEntry.Builder getEntriesBuilder( int index) { return getEntriesFieldBuilder().getBuilder(index); } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public apache.rocketmq.v2.AckMessageResultEntryOrBuilder getEntriesOrBuilder( int index) { @@ -669,7 +917,7 @@ private static final long serialVersionUID = 0L; } } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public java.util.List<? extends apache.rocketmq.v2.AckMessageResultEntryOrBuilder> getEntriesOrBuilderList() { @@ -680,14 +928,14 @@ private static final long serialVersionUID = 0L; } } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public apache.rocketmq.v2.AckMessageResultEntry.Builder addEntriesBuilder() { return getEntriesFieldBuilder().addBuilder( apache.rocketmq.v2.AckMessageResultEntry.getDefaultInstance()); } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public apache.rocketmq.v2.AckMessageResultEntry.Builder addEntriesBuilder( int index) { @@ -695,7 +943,7 @@ private static final long serialVersionUID = 0L; index, apache.rocketmq.v2.AckMessageResultEntry.getDefaultInstance()); } /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ public java.util.List<apache.rocketmq.v2.AckMessageResultEntry.Builder> getEntriesBuilderList() { diff --git a/src/main/java/apache/rocketmq/v2/AckMessageResponseOrBuilder.java b/src/main/java/apache/rocketmq/v2/AckMessageResponseOrBuilder.java index 465702b..44693a4 100644 --- a/src/main/java/apache/rocketmq/v2/AckMessageResponseOrBuilder.java +++ b/src/main/java/apache/rocketmq/v2/AckMessageResponseOrBuilder.java @@ -8,25 +8,55 @@ public interface AckMessageResponseOrBuilder extends com.google.protobuf.MessageOrBuilder { /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <pre> + * RPC tier status, which is used to represent RPC-level errors including + * authentication, authorization, throttling and other general failures. + * </pre> + * + * <code>.apache.rocketmq.v2.Status status = 1;</code> + * @return Whether the status field is set. + */ + boolean hasStatus(); + /** + * <pre> + * RPC tier status, which is used to represent RPC-level errors including + * authentication, authorization, throttling and other general failures. + * </pre> + * + * <code>.apache.rocketmq.v2.Status status = 1;</code> + * @return The status. + */ + apache.rocketmq.v2.Status getStatus(); + /** + * <pre> + * RPC tier status, which is used to represent RPC-level errors including + * authentication, authorization, throttling and other general failures. + * </pre> + * + * <code>.apache.rocketmq.v2.Status status = 1;</code> + */ + apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder(); + + /** + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ java.util.List<apache.rocketmq.v2.AckMessageResultEntry> getEntriesList(); /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ apache.rocketmq.v2.AckMessageResultEntry getEntries(int index); /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ int getEntriesCount(); /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ java.util.List<? extends apache.rocketmq.v2.AckMessageResultEntryOrBuilder> getEntriesOrBuilderList(); /** - * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 1;</code> + * <code>repeated .apache.rocketmq.v2.AckMessageResultEntry entries = 2;</code> */ apache.rocketmq.v2.AckMessageResultEntryOrBuilder getEntriesOrBuilder( int index); diff --git a/src/main/java/apache/rocketmq/v2/AckMessageResultEntry.java b/src/main/java/apache/rocketmq/v2/AckMessageResultEntry.java index 1e9657f..baf3c21 100644 --- a/src/main/java/apache/rocketmq/v2/AckMessageResultEntry.java +++ b/src/main/java/apache/rocketmq/v2/AckMessageResultEntry.java @@ -186,6 +186,12 @@ private static final long serialVersionUID = 0L; public static final int STATUS_FIELD_NUMBER = 3; private apache.rocketmq.v2.Status status_; /** + * <pre> + * Acknowledge result may be acquired through inspecting + * `status.code`; In case acknowledgement failed, `status.message` + * is the explanation of the failure. + * </pre> + * * <code>.apache.rocketmq.v2.Status status = 3;</code> * @return Whether the status field is set. */ @@ -194,6 +200,12 @@ private static final long serialVersionUID = 0L; return status_ != null; } /** + * <pre> + * Acknowledge result may be acquired through inspecting + * `status.code`; In case acknowledgement failed, `status.message` + * is the explanation of the failure. + * </pre> + * * <code>.apache.rocketmq.v2.Status status = 3;</code> * @return The status. */ @@ -202,6 +214,12 @@ private static final long serialVersionUID = 0L; return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_; } /** + * <pre> + * Acknowledge result may be acquired through inspecting + * `status.code`; In case acknowledgement failed, `status.message` + * is the explanation of the failure. + * </pre> + * * <code>.apache.rocketmq.v2.Status status = 3;</code> */ @java.lang.Override @@ -714,6 +732,12 @@ private static final long serialVersionUID = 0L; private com.google.protobuf.SingleFieldBuilderV3< apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> statusBuilder_; /** + * <pre> + * Acknowledge result may be acquired through inspecting + * `status.code`; In case acknowledgement failed, `status.message` + * is the explanation of the failure. + * </pre> + * * <code>.apache.rocketmq.v2.Status status = 3;</code> * @return Whether the status field is set. */ @@ -721,6 +745,12 @@ private static final long serialVersionUID = 0L; return statusBuilder_ != null || status_ != null; } /** + * <pre> + * Acknowledge result may be acquired through inspecting + * `status.code`; In case acknowledgement failed, `status.message` + * is the explanation of the failure. + * </pre> + * * <code>.apache.rocketmq.v2.Status status = 3;</code> * @return The status. */ @@ -732,6 +762,12 @@ private static final long serialVersionUID = 0L; } } /** + * <pre> + * Acknowledge result may be acquired through inspecting + * `status.code`; In case acknowledgement failed, `status.message` + * is the explanation of the failure. + * </pre> + * * <code>.apache.rocketmq.v2.Status status = 3;</code> */ public Builder setStatus(apache.rocketmq.v2.Status value) { @@ -748,6 +784,12 @@ private static final long serialVersionUID = 0L; return this; } /** + * <pre> + * Acknowledge result may be acquired through inspecting + * `status.code`; In case acknowledgement failed, `status.message` + * is the explanation of the failure. + * </pre> + * * <code>.apache.rocketmq.v2.Status status = 3;</code> */ public Builder setStatus( @@ -762,6 +804,12 @@ private static final long serialVersionUID = 0L; return this; } /** + * <pre> + * Acknowledge result may be acquired through inspecting + * `status.code`; In case acknowledgement failed, `status.message` + * is the explanation of the failure. + * </pre> + * * <code>.apache.rocketmq.v2.Status status = 3;</code> */ public Builder mergeStatus(apache.rocketmq.v2.Status value) { @@ -780,6 +828,12 @@ private static final long serialVersionUID = 0L; return this; } /** + * <pre> + * Acknowledge result may be acquired through inspecting + * `status.code`; In case acknowledgement failed, `status.message` + * is the explanation of the failure. + * </pre> + * * <code>.apache.rocketmq.v2.Status status = 3;</code> */ public Builder clearStatus() { @@ -794,6 +848,12 @@ private static final long serialVersionUID = 0L; return this; } /** + * <pre> + * Acknowledge result may be acquired through inspecting + * `status.code`; In case acknowledgement failed, `status.message` + * is the explanation of the failure. + * </pre> + * * <code>.apache.rocketmq.v2.Status status = 3;</code> */ public apache.rocketmq.v2.Status.Builder getStatusBuilder() { @@ -802,6 +862,12 @@ private static final long serialVersionUID = 0L; return getStatusFieldBuilder().getBuilder(); } /** + * <pre> + * Acknowledge result may be acquired through inspecting + * `status.code`; In case acknowledgement failed, `status.message` + * is the explanation of the failure. + * </pre> + * * <code>.apache.rocketmq.v2.Status status = 3;</code> */ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() { @@ -813,6 +879,12 @@ private static final long serialVersionUID = 0L; } } /** + * <pre> + * Acknowledge result may be acquired through inspecting + * `status.code`; In case acknowledgement failed, `status.message` + * is the explanation of the failure. + * </pre> + * * <code>.apache.rocketmq.v2.Status status = 3;</code> */ private com.google.protobuf.SingleFieldBuilderV3< diff --git a/src/main/java/apache/rocketmq/v2/AckMessageResultEntryOrBuilder.java b/src/main/java/apache/rocketmq/v2/AckMessageResultEntryOrBuilder.java index 709f4fe..ca36989 100644 --- a/src/main/java/apache/rocketmq/v2/AckMessageResultEntryOrBuilder.java +++ b/src/main/java/apache/rocketmq/v2/AckMessageResultEntryOrBuilder.java @@ -32,16 +32,34 @@ public interface AckMessageResultEntryOrBuilder extends getReceiptHandleBytes(); /** + * <pre> + * Acknowledge result may be acquired through inspecting + * `status.code`; In case acknowledgement failed, `status.message` + * is the explanation of the failure. + * </pre> + * * <code>.apache.rocketmq.v2.Status status = 3;</code> * @return Whether the status field is set. */ boolean hasStatus(); /** + * <pre> + * Acknowledge result may be acquired through inspecting + * `status.code`; In case acknowledgement failed, `status.message` + * is the explanation of the failure. + * </pre> + * * <code>.apache.rocketmq.v2.Status status = 3;</code> * @return The status. */ apache.rocketmq.v2.Status getStatus(); /** + * <pre> + * Acknowledge result may be acquired through inspecting + * `status.code`; In case acknowledgement failed, `status.message` + * is the explanation of the failure. + * </pre> + * * <code>.apache.rocketmq.v2.Status status = 3;</code> */ apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder(); diff --git a/src/main/java/apache/rocketmq/v2/MQService.java b/src/main/java/apache/rocketmq/v2/MQService.java index 1f74846..aeddfe6 100644 --- a/src/main/java/apache/rocketmq/v2/MQService.java +++ b/src/main/java/apache/rocketmq/v2/MQService.java @@ -255,167 +255,168 @@ public final class MQService { "ketmq.v2.AckMessageEntry\"o\n\025AckMessageRe" + "sultEntry\022\022\n\nmessage_id\030\001 \001(\t\022\026\n\016receipt" + "_handle\030\002 \001(\t\022*\n\006status\030\003 \001(\0132\032.apache.r" + - "ocketmq.v2.Status\"P\n\022AckMessageResponse\022" + - ":\n\007entries\030\001 \003(\0132).apache.rocketmq.v2.Ac" + - "kMessageResultEntry\"\264\001\n\022NackMessageReque" + - "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\"A\n\023NackMessageResponse\022*\n\006status\030\001 \001(" + - "\0132\032.apache.rocketmq.v2.Status\"\347\001\n&Forwar" + - "dMessageToDeadLetterQueueRequest\022+\n\005grou" + - "p\030\001 \001(\0132\034.apache.rocketmq.v2.Resource\022+\n" + - "\005topic\030\002 \001(\0132\034.apache.rocketmq.v2.Resour" + - "ce\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\'ForwardMessag" + - "eToDeadLetterQueueResponse\022*\n\006status\030\001 \001" + - "(\0132\032.apache.rocketmq.v2.Status\"N\n\020Heartb" + - "eatRequest\0220\n\005group\030\001 \001(\0132\034.apache.rocke" + - "tmq.v2.ResourceH\000\210\001\001B\010\n\006_group\"?\n\021Heartb" + - "eatResponse\022*\n\006status\030\001 \001(\0132\032.apache.roc" + - "ketmq.v2.Status\"\375\001\n\025EndTransactionReques" + - "t\022+\n\005topic\030\001 \001(\0132\034.apache.rocketmq.v2.Re" + - "source\022\022\n\nmessage_id\030\002 \001(\t\022\026\n\016transactio" + - "n_id\030\003 \001(\t\022=\n\nresolution\030\004 \001(\0162).apache." + - "rocketmq.v2.TransactionResolution\0225\n\006sou" + - "rce\030\005 \001(\0162%.apache.rocketmq.v2.Transacti" + - "onSource\022\025\n\rtrace_context\030\006 \001(\t\"D\n\026EndTr" + - "ansactionResponse\022*\n\006status\030\001 \001(\0132\032.apac" + - "he.rocketmq.v2.Status\"-\n\034PrintThreadStac" + - "kTraceCommand\022\r\n\005nonce\030\001 \001(\t\"\205\001\n\020ThreadS" + - "tackTrace\022\r\n\005nonce\030\001 \001(\t\022*\n\006status\030\002 \001(\013" + - "2\032.apache.rocketmq.v2.Status\022\037\n\022thread_s" + - "tack_trace\030\003 \001(\tH\000\210\001\001B\025\n\023_thread_stack_t" + - "race\"S\n\024VerifyMessageCommand\022\r\n\005nonce\030\001 " + - "\001(\t\022,\n\007message\030\002 \001(\0132\033.apache.rocketmq.v" + - "2.Message\"P\n\023VerifyMessageResult\022\r\n\005nonc" + - "e\030\001 \001(\t\022*\n\006status\030\002 \001(\0132\032.apache.rocketm" + - "q.v2.Status\"\200\001\n!RecoverOrphanedTransacti" + - "onCommand\022C\n\036orphaned_transactional_mess" + - "age\030\001 \001(\0132\033.apache.rocketmq.v2.Message\022\026" + - "\n\016transaction_id\030\002 \001(\t\"\212\001\n\030ActivePublish" + - "ingSettings\0227\n\021publishing_topics\030\001 \003(\0132\034" + - ".apache.rocketmq.v2.Resource\0225\n\014retry_po" + - "licy\030\002 \001(\0132\037.apache.rocketmq.v2.RetryPol" + - "icy\"\300\003\n\032ActiveSubscriptionSettings\022+\n\005gr" + - "oup\030\001 \001(\0132\034.apache.rocketmq.v2.Resource\022" + - "<\n\rsubscriptions\030\002 \003(\0132%.apache.rocketmq" + - ".v2.SubscriptionEntry\022!\n\024consume_thread_" + - "count\030\003 \001(\005H\000\210\001\001\022#\n\026consume_max_batch_si" + - "ze\030\004 \001(\005H\001\210\001\001\022$\n\027max_cache_message_bytes" + - "\030\005 \001(\003H\002\210\001\001\022N\n&simple_consumer_receive_a" + - "wait_duration\030\006 \001(\0132\031.google.protobuf.Du" + - "rationH\003\210\001\001B\027\n\025_consume_thread_countB\031\n\027" + - "_consume_max_batch_sizeB\032\n\030_max_cache_me" + - "ssage_bytesB)\n\'_simple_consumer_receive_" + - "await_duration\"\227\003\n\033ReportActiveSettingsC" + - "ommand\022\r\n\005nonce\030\001 \001(\t\0223\n\013client_type\030\002 \001" + - "(\0162\036.apache.rocketmq.v2.ClientType\0223\n\014ac" + - "cess_point\030\003 \001(\0132\035.apache.rocketmq.v2.En" + - "dpoints\0225\n\022connection_timeout\030\004 \001(\0132\031.go" + - "ogle.protobuf.Duration\022\020\n\010trace_on\030\005 \001(\010" + - "\022R\n\032active_publishing_settings\030\006 \001(\0132,.a" + - "pache.rocketmq.v2.ActivePublishingSettin" + - "gsH\000\022V\n\034active_subscription_settings\030\007 \001" + - "(\0132..apache.rocketmq.v2.ActiveSubscripti" + - "onSettingsH\000B\n\n\010settings\"+\n\032ReportActive" + - "SettingsResult\022\r\n\005nonce\030\001 \001(\t\"\270\001\n\031Passiv" + - "ePublishingSettings\0220\n(message_body_comp" + - "ression_bytes_threshold\030\001 \001(\005\022\036\n\026max_mes" + - "sage_body_bytes\030\002 \001(\005\022I\n&orphaned_transa" + - "ction_recovery_duration\030\003 \001(\0132\031.google.p" + - "rotobuf.Duration\"\362\003\n\033PassiveSubscription" + - "Settings\022\014\n\004fifo\030\001 \001(\010\022\'\n\032max_fifo_deliv" + - "ery_attempts\030\002 \001(\005H\000\210\001\001\022D\n\034fifo_delivery" + - "_retry_interval\030\003 \001(\0132\031.google.protobuf." + - "DurationH\001\210\001\001\022-\n push_consumer_receive_b" + - "atch_size\030\004 \001(\005H\002\210\001\001\022L\n$push_consumer_re" + - "ceive_await_duration\030\005 \001(\0132\031.google.prot" + - "obuf.DurationH\003\210\001\001\0227\n\017consume_timeout\030\006 " + - "\001(\0132\031.google.protobuf.DurationH\004\210\001\001B\035\n\033_" + - "max_fifo_delivery_attemptsB\037\n\035_fifo_deli" + - "very_retry_intervalB#\n!_push_consumer_re" + - "ceive_batch_sizeB\'\n%_push_consumer_recei" + - "ve_await_durationB\022\n\020_consume_timeout\"\243\002" + - "\n\033ApplyPassiveSettingsCommand\022\r\n\005nonce\030\001" + - " \001(\t\0229\n\022trace_access_point\030\002 \001(\0132\035.apach" + - "e.rocketmq.v2.Endpoints\022T\n\033passive_publi" + - "shing_settings\030\003 \001(\0132-.apache.rocketmq.v" + - "2.PassivePublishingSettingsH\000\022X\n\035passive" + - "_subscription_settings\030\004 \001(\0132/.apache.ro" + - "cketmq.v2.PassiveSubscriptionSettingsH\000B" + - "\n\n\010settings\"+\n\032ApplyPassiveSettingsResul" + - "t\022\r\n\005nonce\030\001 \001(\t\"\244\006\n\020TelemetryCommand\022Y\n" + - "\036report_active_settings_command\030\001 \001(\0132/." + - "apache.rocketmq.v2.ReportActiveSettingsC" + - "ommandH\000\022W\n\035apply_passive_settings_resul" + - "t\030\002 \001(\0132..apache.rocketmq.v2.ApplyPassiv" + - "eSettingsResultH\000\022B\n\022thread_stack_trace\030" + - "\003 \001(\0132$.apache.rocketmq.v2.ThreadStackTr" + - "aceH\000\022H\n\025verify_message_result\030\004 \001(\0132\'.a" + - "pache.rocketmq.v2.VerifyMessageResultH\000\022" + - "Y\n\036apply_passive_settings_command\030\005 \001(\0132" + - "/.apache.rocketmq.v2.ApplyPassiveSetting" + - "sCommandH\000\022W\n\035report_active_settings_res" + - "ult\030\006 \001(\0132..apache.rocketmq.v2.ReportAct" + - "iveSettingsResultH\000\022e\n$recover_orphaned_" + - "transaction_command\030\007 \001(\01325.apache.rocke" + - "tmq.v2.RecoverOrphanedTransactionCommand" + - "H\000\022\\\n print_thread_stack_trace_command\030\010" + - " \001(\01320.apache.rocketmq.v2.PrintThreadSta" + - "ckTraceCommandH\000\022J\n\026verify_message_comma" + - "nd\030\t \001(\0132(.apache.rocketmq.v2.VerifyMess" + - "ageCommandH\000B\t\n\007command\"\\\n\036NotifyClientT" + - "erminationRequest\0220\n\005group\030\001 \001(\0132\034.apach" + - "e.rocketmq.v2.ResourceH\000\210\001\001B\010\n\006_group\"M\n" + - "\037NotifyClientTerminationResponse\022*\n\006stat" + - "us\030\001 \001(\0132\032.apache.rocketmq.v2.Status\"\311\001\n" + - "\036ChangeInvisibleDurationRequest\022+\n\005group" + - "\030\001 \001(\0132\034.apache.rocketmq.v2.Resource\022+\n\005" + - "topic\030\002 \001(\0132\034.apache.rocketmq.v2.Resourc" + - "e\022\026\n\016receipt_handle\030\003 \001(\t\0225\n\022invisible_d" + - "uration\030\004 \001(\0132\031.google.protobuf.Duration" + - "\"e\n\037ChangeInvisibleDurationResponse\022*\n\006s" + - "tatus\030\001 \001(\0132\032.apache.rocketmq.v2.Status\022" + - "\026\n\016receipt_handle\030\002 \001(\t2\302\n\n\020MessagingSer" + - "vice\022]\n\nQueryRoute\022%.apache.rocketmq.v2." + - "QueryRouteRequest\032&.apache.rocketmq.v2.Q" + - "ueryRouteResponse\"\000\022Z\n\tHeartbeat\022$.apach" + - "e.rocketmq.v2.HeartbeatRequest\032%.apache." + - "rocketmq.v2.HeartbeatResponse\"\000\022`\n\013SendM" + - "essage\022&.apache.rocketmq.v2.SendMessageR" + - "equest\032\'.apache.rocketmq.v2.SendMessageR" + - "esponse\"\000\022l\n\017QueryAssignment\022*.apache.ro" + - "cketmq.v2.QueryAssignmentRequest\032+.apach" + - "e.rocketmq.v2.QueryAssignmentResponse\"\000\022" + - "k\n\016ReceiveMessage\022).apache.rocketmq.v2.R" + - "eceiveMessageRequest\032*.apache.rocketmq.v" + - "2.ReceiveMessageResponse\"\0000\001\022]\n\nAckMessa" + - "ge\022%.apache.rocketmq.v2.AckMessageReques" + - "t\032&.apache.rocketmq.v2.AckMessageRespons" + - "e\"\000\022`\n\013NackMessage\022&.apache.rocketmq.v2." + - "NackMessageRequest\032\'.apache.rocketmq.v2." + - "NackMessageResponse\"\000\022\234\001\n\037ForwardMessage" + - "ToDeadLetterQueue\022:.apache.rocketmq.v2.F" + - "orwardMessageToDeadLetterQueueRequest\032;." + - "apache.rocketmq.v2.ForwardMessageToDeadL" + - "etterQueueResponse\"\000\022i\n\016EndTransaction\022)" + - ".apache.rocketmq.v2.EndTransactionReques" + - "t\032*.apache.rocketmq.v2.EndTransactionRes" + - "ponse\"\000\022]\n\tTelemetry\022$.apache.rocketmq.v" + - "2.TelemetryCommand\032$.apache.rocketmq.v2." + - "TelemetryCommand\"\000(\0010\001\022\204\001\n\027NotifyClientT" + - "ermination\0222.apache.rocketmq.v2.NotifyCl" + - "ientTerminationRequest\0323.apache.rocketmq" + - ".v2.NotifyClientTerminationResponse\"\000\022\204\001" + - "\n\027ChangeInvisibleDuration\0222.apache.rocke" + - "tmq.v2.ChangeInvisibleDurationRequest\0323." + - "apache.rocketmq.v2.ChangeInvisibleDurati" + - "onResponse\"\000B<\n\022apache.rocketmq.v2B\tMQSe" + - "rviceP\001\240\001\001\330\001\001\252\002\022Apache.Rocketmq.V2b\006prot" + - "o3" + "ocketmq.v2.Status\"|\n\022AckMessageResponse\022" + + "*\n\006status\030\001 \001(\0132\032.apache.rocketmq.v2.Sta" + + "tus\022:\n\007entries\030\002 \003(\0132).apache.rocketmq.v" + + "2.AckMessageResultEntry\"\264\001\n\022NackMessageR" + + "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\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\"A\n\023NackMessageResponse\022*\n\006status\030" + + "\001 \001(\0132\032.apache.rocketmq.v2.Status\"\347\001\n&Fo" + + "rwardMessageToDeadLetterQueueRequest\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\022\030\n\020delivery_attempt\030\005 \001(\005\022\035\n\025" + + "max_delivery_attempts\030\006 \001(\005\"U\n\'ForwardMe" + + "ssageToDeadLetterQueueResponse\022*\n\006status" + + "\030\001 \001(\0132\032.apache.rocketmq.v2.Status\"N\n\020He" + + "artbeatRequest\0220\n\005group\030\001 \001(\0132\034.apache.r" + + "ocketmq.v2.ResourceH\000\210\001\001B\010\n\006_group\"?\n\021He" + + "artbeatResponse\022*\n\006status\030\001 \001(\0132\032.apache" + + ".rocketmq.v2.Status\"\375\001\n\025EndTransactionRe" + + "quest\022+\n\005topic\030\001 \001(\0132\034.apache.rocketmq.v" + + "2.Resource\022\022\n\nmessage_id\030\002 \001(\t\022\026\n\016transa" + + "ction_id\030\003 \001(\t\022=\n\nresolution\030\004 \001(\0162).apa" + + "che.rocketmq.v2.TransactionResolution\0225\n" + + "\006source\030\005 \001(\0162%.apache.rocketmq.v2.Trans" + + "actionSource\022\025\n\rtrace_context\030\006 \001(\t\"D\n\026E" + + "ndTransactionResponse\022*\n\006status\030\001 \001(\0132\032." + + "apache.rocketmq.v2.Status\"-\n\034PrintThread" + + "StackTraceCommand\022\r\n\005nonce\030\001 \001(\t\"\205\001\n\020Thr" + + "eadStackTrace\022\r\n\005nonce\030\001 \001(\t\022*\n\006status\030\002" + + " \001(\0132\032.apache.rocketmq.v2.Status\022\037\n\022thre" + + "ad_stack_trace\030\003 \001(\tH\000\210\001\001B\025\n\023_thread_sta" + + "ck_trace\"S\n\024VerifyMessageCommand\022\r\n\005nonc" + + "e\030\001 \001(\t\022,\n\007message\030\002 \001(\0132\033.apache.rocket" + + "mq.v2.Message\"P\n\023VerifyMessageResult\022\r\n\005" + + "nonce\030\001 \001(\t\022*\n\006status\030\002 \001(\0132\032.apache.roc" + + "ketmq.v2.Status\"\200\001\n!RecoverOrphanedTrans" + + "actionCommand\022C\n\036orphaned_transactional_" + + "message\030\001 \001(\0132\033.apache.rocketmq.v2.Messa" + + "ge\022\026\n\016transaction_id\030\002 \001(\t\"\212\001\n\030ActivePub" + + "lishingSettings\0227\n\021publishing_topics\030\001 \003" + + "(\0132\034.apache.rocketmq.v2.Resource\0225\n\014retr" + + "y_policy\030\002 \001(\0132\037.apache.rocketmq.v2.Retr" + + "yPolicy\"\300\003\n\032ActiveSubscriptionSettings\022+" + + "\n\005group\030\001 \001(\0132\034.apache.rocketmq.v2.Resou" + + "rce\022<\n\rsubscriptions\030\002 \003(\0132%.apache.rock" + + "etmq.v2.SubscriptionEntry\022!\n\024consume_thr" + + "ead_count\030\003 \001(\005H\000\210\001\001\022#\n\026consume_max_batc" + + "h_size\030\004 \001(\005H\001\210\001\001\022$\n\027max_cache_message_b" + + "ytes\030\005 \001(\003H\002\210\001\001\022N\n&simple_consumer_recei" + + "ve_await_duration\030\006 \001(\0132\031.google.protobu" + + "f.DurationH\003\210\001\001B\027\n\025_consume_thread_count" + + "B\031\n\027_consume_max_batch_sizeB\032\n\030_max_cach" + + "e_message_bytesB)\n\'_simple_consumer_rece" + + "ive_await_duration\"\227\003\n\033ReportActiveSetti" + + "ngsCommand\022\r\n\005nonce\030\001 \001(\t\0223\n\013client_type" + + "\030\002 \001(\0162\036.apache.rocketmq.v2.ClientType\0223" + + "\n\014access_point\030\003 \001(\0132\035.apache.rocketmq.v" + + "2.Endpoints\0225\n\022connection_timeout\030\004 \001(\0132" + + "\031.google.protobuf.Duration\022\020\n\010trace_on\030\005" + + " \001(\010\022R\n\032active_publishing_settings\030\006 \001(\013" + + "2,.apache.rocketmq.v2.ActivePublishingSe" + + "ttingsH\000\022V\n\034active_subscription_settings" + + "\030\007 \001(\0132..apache.rocketmq.v2.ActiveSubscr" + + "iptionSettingsH\000B\n\n\010settings\"+\n\032ReportAc" + + "tiveSettingsResult\022\r\n\005nonce\030\001 \001(\t\"\270\001\n\031Pa" + + "ssivePublishingSettings\0220\n(message_body_" + + "compression_bytes_threshold\030\001 \001(\005\022\036\n\026max" + + "_message_body_bytes\030\002 \001(\005\022I\n&orphaned_tr" + + "ansaction_recovery_duration\030\003 \001(\0132\031.goog" + + "le.protobuf.Duration\"\362\003\n\033PassiveSubscrip" + + "tionSettings\022\014\n\004fifo\030\001 \001(\010\022\'\n\032max_fifo_d" + + "elivery_attempts\030\002 \001(\005H\000\210\001\001\022D\n\034fifo_deli" + + "very_retry_interval\030\003 \001(\0132\031.google.proto" + + "buf.DurationH\001\210\001\001\022-\n push_consumer_recei" + + "ve_batch_size\030\004 \001(\005H\002\210\001\001\022L\n$push_consume" + + "r_receive_await_duration\030\005 \001(\0132\031.google." + + "protobuf.DurationH\003\210\001\001\0227\n\017consume_timeou" + + "t\030\006 \001(\0132\031.google.protobuf.DurationH\004\210\001\001B" + + "\035\n\033_max_fifo_delivery_attemptsB\037\n\035_fifo_" + + "delivery_retry_intervalB#\n!_push_consume" + + "r_receive_batch_sizeB\'\n%_push_consumer_r" + + "eceive_await_durationB\022\n\020_consume_timeou" + + "t\"\243\002\n\033ApplyPassiveSettingsCommand\022\r\n\005non" + + "ce\030\001 \001(\t\0229\n\022trace_access_point\030\002 \001(\0132\035.a" + + "pache.rocketmq.v2.Endpoints\022T\n\033passive_p" + + "ublishing_settings\030\003 \001(\0132-.apache.rocket" + + "mq.v2.PassivePublishingSettingsH\000\022X\n\035pas" + + "sive_subscription_settings\030\004 \001(\0132/.apach" + + "e.rocketmq.v2.PassiveSubscriptionSetting" + + "sH\000B\n\n\010settings\"+\n\032ApplyPassiveSettingsR" + + "esult\022\r\n\005nonce\030\001 \001(\t\"\244\006\n\020TelemetryComman" + + "d\022Y\n\036report_active_settings_command\030\001 \001(" + + "\0132/.apache.rocketmq.v2.ReportActiveSetti" + + "ngsCommandH\000\022W\n\035apply_passive_settings_r" + + "esult\030\002 \001(\0132..apache.rocketmq.v2.ApplyPa" + + "ssiveSettingsResultH\000\022B\n\022thread_stack_tr" + + "ace\030\003 \001(\0132$.apache.rocketmq.v2.ThreadSta" + + "ckTraceH\000\022H\n\025verify_message_result\030\004 \001(\013" + + "2\'.apache.rocketmq.v2.VerifyMessageResul" + + "tH\000\022Y\n\036apply_passive_settings_command\030\005 " + + "\001(\0132/.apache.rocketmq.v2.ApplyPassiveSet" + + "tingsCommandH\000\022W\n\035report_active_settings" + + "_result\030\006 \001(\0132..apache.rocketmq.v2.Repor" + + "tActiveSettingsResultH\000\022e\n$recover_orpha" + + "ned_transaction_command\030\007 \001(\01325.apache.r" + + "ocketmq.v2.RecoverOrphanedTransactionCom" + + "mandH\000\022\\\n print_thread_stack_trace_comma" + + "nd\030\010 \001(\01320.apache.rocketmq.v2.PrintThrea" + + "dStackTraceCommandH\000\022J\n\026verify_message_c" + + "ommand\030\t \001(\0132(.apache.rocketmq.v2.Verify" + + "MessageCommandH\000B\t\n\007command\"\\\n\036NotifyCli" + + "entTerminationRequest\0220\n\005group\030\001 \001(\0132\034.a" + + "pache.rocketmq.v2.ResourceH\000\210\001\001B\010\n\006_grou" + + "p\"M\n\037NotifyClientTerminationResponse\022*\n\006" + + "status\030\001 \001(\0132\032.apache.rocketmq.v2.Status" + + "\"\311\001\n\036ChangeInvisibleDurationRequest\022+\n\005g" + + "roup\030\001 \001(\0132\034.apache.rocketmq.v2.Resource" + + "\022+\n\005topic\030\002 \001(\0132\034.apache.rocketmq.v2.Res" + + "ource\022\026\n\016receipt_handle\030\003 \001(\t\0225\n\022invisib" + + "le_duration\030\004 \001(\0132\031.google.protobuf.Dura" + + "tion\"e\n\037ChangeInvisibleDurationResponse\022" + + "*\n\006status\030\001 \001(\0132\032.apache.rocketmq.v2.Sta" + + "tus\022\026\n\016receipt_handle\030\002 \001(\t2\302\n\n\020Messagin" + + "gService\022]\n\nQueryRoute\022%.apache.rocketmq" + + ".v2.QueryRouteRequest\032&.apache.rocketmq." + + "v2.QueryRouteResponse\"\000\022Z\n\tHeartbeat\022$.a" + + "pache.rocketmq.v2.HeartbeatRequest\032%.apa" + + "che.rocketmq.v2.HeartbeatResponse\"\000\022`\n\013S" + + "endMessage\022&.apache.rocketmq.v2.SendMess" + + "ageRequest\032\'.apache.rocketmq.v2.SendMess" + + "ageResponse\"\000\022l\n\017QueryAssignment\022*.apach" + + "e.rocketmq.v2.QueryAssignmentRequest\032+.a" + + "pache.rocketmq.v2.QueryAssignmentRespons" + + "e\"\000\022k\n\016ReceiveMessage\022).apache.rocketmq." + + "v2.ReceiveMessageRequest\032*.apache.rocket" + + "mq.v2.ReceiveMessageResponse\"\0000\001\022]\n\nAckM" + + "essage\022%.apache.rocketmq.v2.AckMessageRe" + + "quest\032&.apache.rocketmq.v2.AckMessageRes" + + "ponse\"\000\022`\n\013NackMessage\022&.apache.rocketmq" + + ".v2.NackMessageRequest\032\'.apache.rocketmq" + + ".v2.NackMessageResponse\"\000\022\234\001\n\037ForwardMes" + + "sageToDeadLetterQueue\022:.apache.rocketmq." + + "v2.ForwardMessageToDeadLetterQueueReques" + + "t\032;.apache.rocketmq.v2.ForwardMessageToD" + + "eadLetterQueueResponse\"\000\022i\n\016EndTransacti" + + "on\022).apache.rocketmq.v2.EndTransactionRe" + + "quest\032*.apache.rocketmq.v2.EndTransactio" + + "nResponse\"\000\022]\n\tTelemetry\022$.apache.rocket" + + "mq.v2.TelemetryCommand\032$.apache.rocketmq" + + ".v2.TelemetryCommand\"\000(\0010\001\022\204\001\n\027NotifyCli" + + "entTermination\0222.apache.rocketmq.v2.Noti" + + "fyClientTerminationRequest\0323.apache.rock" + + "etmq.v2.NotifyClientTerminationResponse\"" + + "\000\022\204\001\n\027ChangeInvisibleDuration\0222.apache.r" + + "ocketmq.v2.ChangeInvisibleDurationReques" + + "t\0323.apache.rocketmq.v2.ChangeInvisibleDu" + + "rationResponse\"\000B<\n\022apache.rocketmq.v2B\t" + + "MQServiceP\001\240\001\001\330\001\001\252\002\022Apache.Rocketmq.V2b\006" + + "proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor .internalBuildGeneratedFileFrom(descriptorData, @@ -495,7 +496,7 @@ public final class MQService { internal_static_apache_rocketmq_v2_AckMessageResponse_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_apache_rocketmq_v2_AckMessageResponse_descriptor, - new java.lang.String[] { "Entries", }); + new java.lang.String[] { "Status", "Entries", }); internal_static_apache_rocketmq_v2_NackMessageRequest_descriptor = getDescriptor().getMessageTypes().get(12); internal_static_apache_rocketmq_v2_NackMessageRequest_fieldAccessorTable = new diff --git a/src/main/resources/proto/apache/rocketmq/v2/service.proto b/src/main/resources/proto/apache/rocketmq/v2/service.proto index 5c5c8d1..a6245eb 100644 --- a/src/main/resources/proto/apache/rocketmq/v2/service.proto +++ b/src/main/resources/proto/apache/rocketmq/v2/service.proto @@ -104,10 +104,21 @@ message AckMessageRequest { message AckMessageResultEntry { string message_id = 1; string receipt_handle = 2; + + // Acknowledge result may be acquired through inspecting + // `status.code`; In case acknowledgement failed, `status.message` + // is the explanation of the failure. Status status = 3; } -message AckMessageResponse { repeated AckMessageResultEntry entries = 1; } +message AckMessageResponse { + + // RPC tier status, which is used to represent RPC-level errors including + // authentication, authorization, throttling and other general failures. + Status status = 1; + + repeated AckMessageResultEntry entries = 2; +} message NackMessageRequest { Resource group = 1;
