You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2022/07/15 03:27:38 UTC
[rocketmq-apis] 05/38: Polish code
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 8d40bf8b4688fcf3967a10a2386d7f93d0fe20ca
Author: 凌楚 <ya...@alibaba-inc.com>
AuthorDate: Mon Mar 28 17:57:23 2022 +0800
Polish code
---
.../apache/rocketmq/v2/AckMessageResponse.java | 188 +++++-----
.../rocketmq/v2/AckMessageResponseOrBuilder.java | 16 +-
.../v2/ChangeInvisibleDurationResponse.java | 188 +++++-----
.../ChangeInvisibleDurationResponseOrBuilder.java | 16 +-
.../apache/rocketmq/v2/EndTransactionResponse.java | 188 +++++-----
.../v2/EndTransactionResponseOrBuilder.java | 16 +-
.../ForwardMessageToDeadLetterQueueResponse.java | 188 +++++-----
...dMessageToDeadLetterQueueResponseOrBuilder.java | 16 +-
.../java/apache/rocketmq/v2/HeartbeatResponse.java | 188 +++++-----
.../rocketmq/v2/HeartbeatResponseOrBuilder.java | 16 +-
src/main/java/apache/rocketmq/v2/MQService.java | 390 ++++++++++-----------
.../v2/NotifyClientTerminationResponse.java | 188 +++++-----
.../NotifyClientTerminationResponseOrBuilder.java | 16 +-
.../apache/rocketmq/v2/PullMessageResponse.java | 188 +++++-----
.../rocketmq/v2/PullMessageResponseOrBuilder.java | 16 +-
.../rocketmq/v2/QueryAssignmentResponse.java | 188 +++++-----
.../v2/QueryAssignmentResponseOrBuilder.java | 16 +-
.../apache/rocketmq/v2/QueryOffsetResponse.java | 188 +++++-----
.../rocketmq/v2/QueryOffsetResponseOrBuilder.java | 16 +-
.../apache/rocketmq/v2/QueryRouteResponse.java | 188 +++++-----
.../rocketmq/v2/QueryRouteResponseOrBuilder.java | 16 +-
.../apache/rocketmq/v2/ReceiveMessageResponse.java | 188 +++++-----
.../v2/ReceiveMessageResponseOrBuilder.java | 16 +-
src/main/java/apache/rocketmq/v2/ResponseCode.java | 60 ++--
.../apache/rocketmq/v2/SendMessageResponse.java | 188 +++++-----
.../rocketmq/v2/SendMessageResponseOrBuilder.java | 16 +-
.../v2/{ResponseCommon.java => Status.java} | 118 +++----
...seCommonOrBuilder.java => StatusOrBuilder.java} | 4 +-
.../apache/rocketmq/v2/VerifyMessageResult.java | 188 +++++-----
.../rocketmq/v2/VerifyMessageResultOrBuilder.java | 16 +-
.../proto/apache/rocketmq/v2/service.proto | 2 -
31 files changed, 1611 insertions(+), 1615 deletions(-)
diff --git a/src/main/java/apache/rocketmq/v2/AckMessageResponse.java b/src/main/java/apache/rocketmq/v2/AckMessageResponse.java
index ad5ffd7..a0defb4 100644
--- a/src/main/java/apache/rocketmq/v2/AckMessageResponse.java
+++ b/src/main/java/apache/rocketmq/v2/AckMessageResponse.java
@@ -49,14 +49,14 @@ private static final long serialVersionUID = 0L;
done = true;
break;
case 10: {
- apache.rocketmq.v2.ResponseCommon.Builder subBuilder = null;
- if (common_ != null) {
- subBuilder = common_.toBuilder();
+ apache.rocketmq.v2.Status.Builder subBuilder = null;
+ if (status_ != null) {
+ subBuilder = status_.toBuilder();
}
- common_ = input.readMessage(apache.rocketmq.v2.ResponseCommon.parser(), extensionRegistry);
+ status_ = input.readMessage(apache.rocketmq.v2.Status.parser(), extensionRegistry);
if (subBuilder != null) {
- subBuilder.mergeFrom(common_);
- common_ = subBuilder.buildPartial();
+ subBuilder.mergeFrom(status_);
+ status_ = subBuilder.buildPartial();
}
break;
@@ -93,30 +93,30 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.AckMessageResponse.class, apache.rocketmq.v2.AckMessageResponse.Builder.class);
}
- public static final int COMMON_FIELD_NUMBER = 1;
- private apache.rocketmq.v2.ResponseCommon common_;
+ public static final int STATUS_FIELD_NUMBER = 1;
+ private apache.rocketmq.v2.Status status_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
@java.lang.Override
- public boolean hasCommon() {
- return common_ != null;
+ public boolean hasStatus() {
+ return status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- return getCommon();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ return getStatus();
}
private byte memoizedIsInitialized = -1;
@@ -133,8 +133,8 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
- if (common_ != null) {
- output.writeMessage(1, getCommon());
+ if (status_ != null) {
+ output.writeMessage(1, getStatus());
}
unknownFields.writeTo(output);
}
@@ -145,9 +145,9 @@ private static final long serialVersionUID = 0L;
if (size != -1) return size;
size = 0;
- if (common_ != null) {
+ if (status_ != null) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(1, getCommon());
+ .computeMessageSize(1, getStatus());
}
size += unknownFields.getSerializedSize();
memoizedSize = size;
@@ -164,10 +164,10 @@ private static final long serialVersionUID = 0L;
}
apache.rocketmq.v2.AckMessageResponse other = (apache.rocketmq.v2.AckMessageResponse) obj;
- if (hasCommon() != other.hasCommon()) return false;
- if (hasCommon()) {
- if (!getCommon()
- .equals(other.getCommon())) return false;
+ if (hasStatus() != other.hasStatus()) return false;
+ if (hasStatus()) {
+ if (!getStatus()
+ .equals(other.getStatus())) return false;
}
if (!unknownFields.equals(other.unknownFields)) return false;
return true;
@@ -180,9 +180,9 @@ private static final long serialVersionUID = 0L;
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
- if (hasCommon()) {
- hash = (37 * hash) + COMMON_FIELD_NUMBER;
- hash = (53 * hash) + getCommon().hashCode();
+ if (hasStatus()) {
+ hash = (37 * hash) + STATUS_FIELD_NUMBER;
+ hash = (53 * hash) + getStatus().hashCode();
}
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
@@ -317,11 +317,11 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public Builder clear() {
super.clear();
- if (commonBuilder_ == null) {
- common_ = null;
+ if (statusBuilder_ == null) {
+ status_ = null;
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
@@ -349,10 +349,10 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public apache.rocketmq.v2.AckMessageResponse buildPartial() {
apache.rocketmq.v2.AckMessageResponse result = new apache.rocketmq.v2.AckMessageResponse(this);
- if (commonBuilder_ == null) {
- result.common_ = common_;
+ if (statusBuilder_ == null) {
+ result.status_ = status_;
} else {
- result.common_ = commonBuilder_.build();
+ result.status_ = statusBuilder_.build();
}
onBuilt();
return result;
@@ -402,8 +402,8 @@ 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.hasCommon()) {
- mergeCommon(other.getCommon());
+ if (other.hasStatus()) {
+ mergeStatus(other.getStatus());
}
this.mergeUnknownFields(other.unknownFields);
onChanged();
@@ -434,123 +434,123 @@ private static final long serialVersionUID = 0L;
return this;
}
- private apache.rocketmq.v2.ResponseCommon common_;
+ private apache.rocketmq.v2.Status status_;
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder> commonBuilder_;
+ apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> statusBuilder_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- public boolean hasCommon() {
- return commonBuilder_ != null || common_ != null;
+ public boolean hasStatus() {
+ return statusBuilder_ != null || status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- if (commonBuilder_ == null) {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ if (statusBuilder_ == null) {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
} else {
- return commonBuilder_.getMessage();
+ return statusBuilder_.getMessage();
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
+ public Builder setStatus(apache.rocketmq.v2.Status value) {
+ if (statusBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
- common_ = value;
+ status_ = value;
onChanged();
} else {
- commonBuilder_.setMessage(value);
+ statusBuilder_.setMessage(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(
- apache.rocketmq.v2.ResponseCommon.Builder builderForValue) {
- if (commonBuilder_ == null) {
- common_ = builderForValue.build();
+ public Builder setStatus(
+ apache.rocketmq.v2.Status.Builder builderForValue) {
+ if (statusBuilder_ == null) {
+ status_ = builderForValue.build();
onChanged();
} else {
- commonBuilder_.setMessage(builderForValue.build());
+ statusBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder mergeCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
- if (common_ != null) {
- common_ =
- apache.rocketmq.v2.ResponseCommon.newBuilder(common_).mergeFrom(value).buildPartial();
+ 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 {
- common_ = value;
+ status_ = value;
}
onChanged();
} else {
- commonBuilder_.mergeFrom(value);
+ statusBuilder_.mergeFrom(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder clearCommon() {
- if (commonBuilder_ == null) {
- common_ = null;
+ public Builder clearStatus() {
+ if (statusBuilder_ == null) {
+ status_ = null;
onChanged();
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommon.Builder getCommonBuilder() {
+ public apache.rocketmq.v2.Status.Builder getStatusBuilder() {
onChanged();
- return getCommonFieldBuilder().getBuilder();
+ return getStatusFieldBuilder().getBuilder();
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- if (commonBuilder_ != null) {
- return commonBuilder_.getMessageOrBuilder();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ if (statusBuilder_ != null) {
+ return statusBuilder_.getMessageOrBuilder();
} else {
- return common_ == null ?
- apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ return status_ == null ?
+ apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>
- getCommonFieldBuilder() {
- if (commonBuilder_ == null) {
- commonBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>(
- getCommon(),
+ 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());
- common_ = null;
+ status_ = null;
}
- return commonBuilder_;
+ return statusBuilder_;
}
@java.lang.Override
public final Builder setUnknownFields(
diff --git a/src/main/java/apache/rocketmq/v2/AckMessageResponseOrBuilder.java b/src/main/java/apache/rocketmq/v2/AckMessageResponseOrBuilder.java
index 87027be..57cb850 100644
--- a/src/main/java/apache/rocketmq/v2/AckMessageResponseOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/AckMessageResponseOrBuilder.java
@@ -8,17 +8,17 @@ public interface AckMessageResponseOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- boolean hasCommon();
+ boolean hasStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- apache.rocketmq.v2.ResponseCommon getCommon();
+ apache.rocketmq.v2.Status getStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder();
+ apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder();
}
diff --git a/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationResponse.java b/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationResponse.java
index 3d5bcc8..96dba25 100644
--- a/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationResponse.java
+++ b/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationResponse.java
@@ -50,14 +50,14 @@ private static final long serialVersionUID = 0L;
done = true;
break;
case 10: {
- apache.rocketmq.v2.ResponseCommon.Builder subBuilder = null;
- if (common_ != null) {
- subBuilder = common_.toBuilder();
+ apache.rocketmq.v2.Status.Builder subBuilder = null;
+ if (status_ != null) {
+ subBuilder = status_.toBuilder();
}
- common_ = input.readMessage(apache.rocketmq.v2.ResponseCommon.parser(), extensionRegistry);
+ status_ = input.readMessage(apache.rocketmq.v2.Status.parser(), extensionRegistry);
if (subBuilder != null) {
- subBuilder.mergeFrom(common_);
- common_ = subBuilder.buildPartial();
+ subBuilder.mergeFrom(status_);
+ status_ = subBuilder.buildPartial();
}
break;
@@ -100,30 +100,30 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.ChangeInvisibleDurationResponse.class, apache.rocketmq.v2.ChangeInvisibleDurationResponse.Builder.class);
}
- public static final int COMMON_FIELD_NUMBER = 1;
- private apache.rocketmq.v2.ResponseCommon common_;
+ public static final int STATUS_FIELD_NUMBER = 1;
+ private apache.rocketmq.v2.Status status_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
@java.lang.Override
- public boolean hasCommon() {
- return common_ != null;
+ public boolean hasStatus() {
+ return status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- return getCommon();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ return getStatus();
}
public static final int RECEIPT_HANDLE_FIELD_NUMBER = 2;
@@ -186,8 +186,8 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
- if (common_ != null) {
- output.writeMessage(1, getCommon());
+ if (status_ != null) {
+ output.writeMessage(1, getStatus());
}
if (!getReceiptHandleBytes().isEmpty()) {
com.google.protobuf.GeneratedMessageV3.writeString(output, 2, receiptHandle_);
@@ -201,9 +201,9 @@ private static final long serialVersionUID = 0L;
if (size != -1) return size;
size = 0;
- if (common_ != null) {
+ if (status_ != null) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(1, getCommon());
+ .computeMessageSize(1, getStatus());
}
if (!getReceiptHandleBytes().isEmpty()) {
size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, receiptHandle_);
@@ -223,10 +223,10 @@ private static final long serialVersionUID = 0L;
}
apache.rocketmq.v2.ChangeInvisibleDurationResponse other = (apache.rocketmq.v2.ChangeInvisibleDurationResponse) obj;
- if (hasCommon() != other.hasCommon()) return false;
- if (hasCommon()) {
- if (!getCommon()
- .equals(other.getCommon())) return false;
+ if (hasStatus() != other.hasStatus()) return false;
+ if (hasStatus()) {
+ if (!getStatus()
+ .equals(other.getStatus())) return false;
}
if (!getReceiptHandle()
.equals(other.getReceiptHandle())) return false;
@@ -241,9 +241,9 @@ private static final long serialVersionUID = 0L;
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
- if (hasCommon()) {
- hash = (37 * hash) + COMMON_FIELD_NUMBER;
- hash = (53 * hash) + getCommon().hashCode();
+ if (hasStatus()) {
+ hash = (37 * hash) + STATUS_FIELD_NUMBER;
+ hash = (53 * hash) + getStatus().hashCode();
}
hash = (37 * hash) + RECEIPT_HANDLE_FIELD_NUMBER;
hash = (53 * hash) + getReceiptHandle().hashCode();
@@ -380,11 +380,11 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public Builder clear() {
super.clear();
- if (commonBuilder_ == null) {
- common_ = null;
+ if (statusBuilder_ == null) {
+ status_ = null;
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
receiptHandle_ = "";
@@ -414,10 +414,10 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public apache.rocketmq.v2.ChangeInvisibleDurationResponse buildPartial() {
apache.rocketmq.v2.ChangeInvisibleDurationResponse result = new apache.rocketmq.v2.ChangeInvisibleDurationResponse(this);
- if (commonBuilder_ == null) {
- result.common_ = common_;
+ if (statusBuilder_ == null) {
+ result.status_ = status_;
} else {
- result.common_ = commonBuilder_.build();
+ result.status_ = statusBuilder_.build();
}
result.receiptHandle_ = receiptHandle_;
onBuilt();
@@ -468,8 +468,8 @@ private static final long serialVersionUID = 0L;
public Builder mergeFrom(apache.rocketmq.v2.ChangeInvisibleDurationResponse other) {
if (other == apache.rocketmq.v2.ChangeInvisibleDurationResponse.getDefaultInstance()) return this;
- if (other.hasCommon()) {
- mergeCommon(other.getCommon());
+ if (other.hasStatus()) {
+ mergeStatus(other.getStatus());
}
if (!other.getReceiptHandle().isEmpty()) {
receiptHandle_ = other.receiptHandle_;
@@ -504,123 +504,123 @@ private static final long serialVersionUID = 0L;
return this;
}
- private apache.rocketmq.v2.ResponseCommon common_;
+ private apache.rocketmq.v2.Status status_;
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder> commonBuilder_;
+ apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> statusBuilder_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- public boolean hasCommon() {
- return commonBuilder_ != null || common_ != null;
+ public boolean hasStatus() {
+ return statusBuilder_ != null || status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- if (commonBuilder_ == null) {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ if (statusBuilder_ == null) {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
} else {
- return commonBuilder_.getMessage();
+ return statusBuilder_.getMessage();
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
+ public Builder setStatus(apache.rocketmq.v2.Status value) {
+ if (statusBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
- common_ = value;
+ status_ = value;
onChanged();
} else {
- commonBuilder_.setMessage(value);
+ statusBuilder_.setMessage(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(
- apache.rocketmq.v2.ResponseCommon.Builder builderForValue) {
- if (commonBuilder_ == null) {
- common_ = builderForValue.build();
+ public Builder setStatus(
+ apache.rocketmq.v2.Status.Builder builderForValue) {
+ if (statusBuilder_ == null) {
+ status_ = builderForValue.build();
onChanged();
} else {
- commonBuilder_.setMessage(builderForValue.build());
+ statusBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder mergeCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
- if (common_ != null) {
- common_ =
- apache.rocketmq.v2.ResponseCommon.newBuilder(common_).mergeFrom(value).buildPartial();
+ 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 {
- common_ = value;
+ status_ = value;
}
onChanged();
} else {
- commonBuilder_.mergeFrom(value);
+ statusBuilder_.mergeFrom(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder clearCommon() {
- if (commonBuilder_ == null) {
- common_ = null;
+ public Builder clearStatus() {
+ if (statusBuilder_ == null) {
+ status_ = null;
onChanged();
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommon.Builder getCommonBuilder() {
+ public apache.rocketmq.v2.Status.Builder getStatusBuilder() {
onChanged();
- return getCommonFieldBuilder().getBuilder();
+ return getStatusFieldBuilder().getBuilder();
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- if (commonBuilder_ != null) {
- return commonBuilder_.getMessageOrBuilder();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ if (statusBuilder_ != null) {
+ return statusBuilder_.getMessageOrBuilder();
} else {
- return common_ == null ?
- apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ return status_ == null ?
+ apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>
- getCommonFieldBuilder() {
- if (commonBuilder_ == null) {
- commonBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>(
- getCommon(),
+ 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());
- common_ = null;
+ status_ = null;
}
- return commonBuilder_;
+ return statusBuilder_;
}
private java.lang.Object receiptHandle_ = "";
diff --git a/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationResponseOrBuilder.java b/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationResponseOrBuilder.java
index 83666fe..a1dd4cb 100644
--- a/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationResponseOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationResponseOrBuilder.java
@@ -8,19 +8,19 @@ public interface ChangeInvisibleDurationResponseOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- boolean hasCommon();
+ boolean hasStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- apache.rocketmq.v2.ResponseCommon getCommon();
+ apache.rocketmq.v2.Status getStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder();
+ apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder();
/**
* <pre>
diff --git a/src/main/java/apache/rocketmq/v2/EndTransactionResponse.java b/src/main/java/apache/rocketmq/v2/EndTransactionResponse.java
index 2b4ac3e..7aa6a1e 100644
--- a/src/main/java/apache/rocketmq/v2/EndTransactionResponse.java
+++ b/src/main/java/apache/rocketmq/v2/EndTransactionResponse.java
@@ -49,14 +49,14 @@ private static final long serialVersionUID = 0L;
done = true;
break;
case 10: {
- apache.rocketmq.v2.ResponseCommon.Builder subBuilder = null;
- if (common_ != null) {
- subBuilder = common_.toBuilder();
+ apache.rocketmq.v2.Status.Builder subBuilder = null;
+ if (status_ != null) {
+ subBuilder = status_.toBuilder();
}
- common_ = input.readMessage(apache.rocketmq.v2.ResponseCommon.parser(), extensionRegistry);
+ status_ = input.readMessage(apache.rocketmq.v2.Status.parser(), extensionRegistry);
if (subBuilder != null) {
- subBuilder.mergeFrom(common_);
- common_ = subBuilder.buildPartial();
+ subBuilder.mergeFrom(status_);
+ status_ = subBuilder.buildPartial();
}
break;
@@ -93,30 +93,30 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.EndTransactionResponse.class, apache.rocketmq.v2.EndTransactionResponse.Builder.class);
}
- public static final int COMMON_FIELD_NUMBER = 1;
- private apache.rocketmq.v2.ResponseCommon common_;
+ public static final int STATUS_FIELD_NUMBER = 1;
+ private apache.rocketmq.v2.Status status_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
@java.lang.Override
- public boolean hasCommon() {
- return common_ != null;
+ public boolean hasStatus() {
+ return status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- return getCommon();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ return getStatus();
}
private byte memoizedIsInitialized = -1;
@@ -133,8 +133,8 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
- if (common_ != null) {
- output.writeMessage(1, getCommon());
+ if (status_ != null) {
+ output.writeMessage(1, getStatus());
}
unknownFields.writeTo(output);
}
@@ -145,9 +145,9 @@ private static final long serialVersionUID = 0L;
if (size != -1) return size;
size = 0;
- if (common_ != null) {
+ if (status_ != null) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(1, getCommon());
+ .computeMessageSize(1, getStatus());
}
size += unknownFields.getSerializedSize();
memoizedSize = size;
@@ -164,10 +164,10 @@ private static final long serialVersionUID = 0L;
}
apache.rocketmq.v2.EndTransactionResponse other = (apache.rocketmq.v2.EndTransactionResponse) obj;
- if (hasCommon() != other.hasCommon()) return false;
- if (hasCommon()) {
- if (!getCommon()
- .equals(other.getCommon())) return false;
+ if (hasStatus() != other.hasStatus()) return false;
+ if (hasStatus()) {
+ if (!getStatus()
+ .equals(other.getStatus())) return false;
}
if (!unknownFields.equals(other.unknownFields)) return false;
return true;
@@ -180,9 +180,9 @@ private static final long serialVersionUID = 0L;
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
- if (hasCommon()) {
- hash = (37 * hash) + COMMON_FIELD_NUMBER;
- hash = (53 * hash) + getCommon().hashCode();
+ if (hasStatus()) {
+ hash = (37 * hash) + STATUS_FIELD_NUMBER;
+ hash = (53 * hash) + getStatus().hashCode();
}
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
@@ -317,11 +317,11 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public Builder clear() {
super.clear();
- if (commonBuilder_ == null) {
- common_ = null;
+ if (statusBuilder_ == null) {
+ status_ = null;
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
@@ -349,10 +349,10 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public apache.rocketmq.v2.EndTransactionResponse buildPartial() {
apache.rocketmq.v2.EndTransactionResponse result = new apache.rocketmq.v2.EndTransactionResponse(this);
- if (commonBuilder_ == null) {
- result.common_ = common_;
+ if (statusBuilder_ == null) {
+ result.status_ = status_;
} else {
- result.common_ = commonBuilder_.build();
+ result.status_ = statusBuilder_.build();
}
onBuilt();
return result;
@@ -402,8 +402,8 @@ private static final long serialVersionUID = 0L;
public Builder mergeFrom(apache.rocketmq.v2.EndTransactionResponse other) {
if (other == apache.rocketmq.v2.EndTransactionResponse.getDefaultInstance()) return this;
- if (other.hasCommon()) {
- mergeCommon(other.getCommon());
+ if (other.hasStatus()) {
+ mergeStatus(other.getStatus());
}
this.mergeUnknownFields(other.unknownFields);
onChanged();
@@ -434,123 +434,123 @@ private static final long serialVersionUID = 0L;
return this;
}
- private apache.rocketmq.v2.ResponseCommon common_;
+ private apache.rocketmq.v2.Status status_;
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder> commonBuilder_;
+ apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> statusBuilder_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- public boolean hasCommon() {
- return commonBuilder_ != null || common_ != null;
+ public boolean hasStatus() {
+ return statusBuilder_ != null || status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- if (commonBuilder_ == null) {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ if (statusBuilder_ == null) {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
} else {
- return commonBuilder_.getMessage();
+ return statusBuilder_.getMessage();
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
+ public Builder setStatus(apache.rocketmq.v2.Status value) {
+ if (statusBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
- common_ = value;
+ status_ = value;
onChanged();
} else {
- commonBuilder_.setMessage(value);
+ statusBuilder_.setMessage(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(
- apache.rocketmq.v2.ResponseCommon.Builder builderForValue) {
- if (commonBuilder_ == null) {
- common_ = builderForValue.build();
+ public Builder setStatus(
+ apache.rocketmq.v2.Status.Builder builderForValue) {
+ if (statusBuilder_ == null) {
+ status_ = builderForValue.build();
onChanged();
} else {
- commonBuilder_.setMessage(builderForValue.build());
+ statusBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder mergeCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
- if (common_ != null) {
- common_ =
- apache.rocketmq.v2.ResponseCommon.newBuilder(common_).mergeFrom(value).buildPartial();
+ 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 {
- common_ = value;
+ status_ = value;
}
onChanged();
} else {
- commonBuilder_.mergeFrom(value);
+ statusBuilder_.mergeFrom(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder clearCommon() {
- if (commonBuilder_ == null) {
- common_ = null;
+ public Builder clearStatus() {
+ if (statusBuilder_ == null) {
+ status_ = null;
onChanged();
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommon.Builder getCommonBuilder() {
+ public apache.rocketmq.v2.Status.Builder getStatusBuilder() {
onChanged();
- return getCommonFieldBuilder().getBuilder();
+ return getStatusFieldBuilder().getBuilder();
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- if (commonBuilder_ != null) {
- return commonBuilder_.getMessageOrBuilder();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ if (statusBuilder_ != null) {
+ return statusBuilder_.getMessageOrBuilder();
} else {
- return common_ == null ?
- apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ return status_ == null ?
+ apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>
- getCommonFieldBuilder() {
- if (commonBuilder_ == null) {
- commonBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>(
- getCommon(),
+ 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());
- common_ = null;
+ status_ = null;
}
- return commonBuilder_;
+ return statusBuilder_;
}
@java.lang.Override
public final Builder setUnknownFields(
diff --git a/src/main/java/apache/rocketmq/v2/EndTransactionResponseOrBuilder.java b/src/main/java/apache/rocketmq/v2/EndTransactionResponseOrBuilder.java
index 9750e48..36f5c0e 100644
--- a/src/main/java/apache/rocketmq/v2/EndTransactionResponseOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/EndTransactionResponseOrBuilder.java
@@ -8,17 +8,17 @@ public interface EndTransactionResponseOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- boolean hasCommon();
+ boolean hasStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- apache.rocketmq.v2.ResponseCommon getCommon();
+ apache.rocketmq.v2.Status getStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder();
+ apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder();
}
diff --git a/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueResponse.java b/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueResponse.java
index 2467b3b..cf83cf1 100644
--- a/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueResponse.java
+++ b/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueResponse.java
@@ -49,14 +49,14 @@ private static final long serialVersionUID = 0L;
done = true;
break;
case 10: {
- apache.rocketmq.v2.ResponseCommon.Builder subBuilder = null;
- if (common_ != null) {
- subBuilder = common_.toBuilder();
+ apache.rocketmq.v2.Status.Builder subBuilder = null;
+ if (status_ != null) {
+ subBuilder = status_.toBuilder();
}
- common_ = input.readMessage(apache.rocketmq.v2.ResponseCommon.parser(), extensionRegistry);
+ status_ = input.readMessage(apache.rocketmq.v2.Status.parser(), extensionRegistry);
if (subBuilder != null) {
- subBuilder.mergeFrom(common_);
- common_ = subBuilder.buildPartial();
+ subBuilder.mergeFrom(status_);
+ status_ = subBuilder.buildPartial();
}
break;
@@ -93,30 +93,30 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.ForwardMessageToDeadLetterQueueResponse.class, apache.rocketmq.v2.ForwardMessageToDeadLetterQueueResponse.Builder.class);
}
- public static final int COMMON_FIELD_NUMBER = 1;
- private apache.rocketmq.v2.ResponseCommon common_;
+ public static final int STATUS_FIELD_NUMBER = 1;
+ private apache.rocketmq.v2.Status status_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
@java.lang.Override
- public boolean hasCommon() {
- return common_ != null;
+ public boolean hasStatus() {
+ return status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- return getCommon();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ return getStatus();
}
private byte memoizedIsInitialized = -1;
@@ -133,8 +133,8 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
- if (common_ != null) {
- output.writeMessage(1, getCommon());
+ if (status_ != null) {
+ output.writeMessage(1, getStatus());
}
unknownFields.writeTo(output);
}
@@ -145,9 +145,9 @@ private static final long serialVersionUID = 0L;
if (size != -1) return size;
size = 0;
- if (common_ != null) {
+ if (status_ != null) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(1, getCommon());
+ .computeMessageSize(1, getStatus());
}
size += unknownFields.getSerializedSize();
memoizedSize = size;
@@ -164,10 +164,10 @@ private static final long serialVersionUID = 0L;
}
apache.rocketmq.v2.ForwardMessageToDeadLetterQueueResponse other = (apache.rocketmq.v2.ForwardMessageToDeadLetterQueueResponse) obj;
- if (hasCommon() != other.hasCommon()) return false;
- if (hasCommon()) {
- if (!getCommon()
- .equals(other.getCommon())) return false;
+ if (hasStatus() != other.hasStatus()) return false;
+ if (hasStatus()) {
+ if (!getStatus()
+ .equals(other.getStatus())) return false;
}
if (!unknownFields.equals(other.unknownFields)) return false;
return true;
@@ -180,9 +180,9 @@ private static final long serialVersionUID = 0L;
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
- if (hasCommon()) {
- hash = (37 * hash) + COMMON_FIELD_NUMBER;
- hash = (53 * hash) + getCommon().hashCode();
+ if (hasStatus()) {
+ hash = (37 * hash) + STATUS_FIELD_NUMBER;
+ hash = (53 * hash) + getStatus().hashCode();
}
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
@@ -317,11 +317,11 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public Builder clear() {
super.clear();
- if (commonBuilder_ == null) {
- common_ = null;
+ if (statusBuilder_ == null) {
+ status_ = null;
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
@@ -349,10 +349,10 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public apache.rocketmq.v2.ForwardMessageToDeadLetterQueueResponse buildPartial() {
apache.rocketmq.v2.ForwardMessageToDeadLetterQueueResponse result = new apache.rocketmq.v2.ForwardMessageToDeadLetterQueueResponse(this);
- if (commonBuilder_ == null) {
- result.common_ = common_;
+ if (statusBuilder_ == null) {
+ result.status_ = status_;
} else {
- result.common_ = commonBuilder_.build();
+ result.status_ = statusBuilder_.build();
}
onBuilt();
return result;
@@ -402,8 +402,8 @@ private static final long serialVersionUID = 0L;
public Builder mergeFrom(apache.rocketmq.v2.ForwardMessageToDeadLetterQueueResponse other) {
if (other == apache.rocketmq.v2.ForwardMessageToDeadLetterQueueResponse.getDefaultInstance()) return this;
- if (other.hasCommon()) {
- mergeCommon(other.getCommon());
+ if (other.hasStatus()) {
+ mergeStatus(other.getStatus());
}
this.mergeUnknownFields(other.unknownFields);
onChanged();
@@ -434,123 +434,123 @@ private static final long serialVersionUID = 0L;
return this;
}
- private apache.rocketmq.v2.ResponseCommon common_;
+ private apache.rocketmq.v2.Status status_;
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder> commonBuilder_;
+ apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> statusBuilder_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- public boolean hasCommon() {
- return commonBuilder_ != null || common_ != null;
+ public boolean hasStatus() {
+ return statusBuilder_ != null || status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- if (commonBuilder_ == null) {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ if (statusBuilder_ == null) {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
} else {
- return commonBuilder_.getMessage();
+ return statusBuilder_.getMessage();
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
+ public Builder setStatus(apache.rocketmq.v2.Status value) {
+ if (statusBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
- common_ = value;
+ status_ = value;
onChanged();
} else {
- commonBuilder_.setMessage(value);
+ statusBuilder_.setMessage(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(
- apache.rocketmq.v2.ResponseCommon.Builder builderForValue) {
- if (commonBuilder_ == null) {
- common_ = builderForValue.build();
+ public Builder setStatus(
+ apache.rocketmq.v2.Status.Builder builderForValue) {
+ if (statusBuilder_ == null) {
+ status_ = builderForValue.build();
onChanged();
} else {
- commonBuilder_.setMessage(builderForValue.build());
+ statusBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder mergeCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
- if (common_ != null) {
- common_ =
- apache.rocketmq.v2.ResponseCommon.newBuilder(common_).mergeFrom(value).buildPartial();
+ 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 {
- common_ = value;
+ status_ = value;
}
onChanged();
} else {
- commonBuilder_.mergeFrom(value);
+ statusBuilder_.mergeFrom(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder clearCommon() {
- if (commonBuilder_ == null) {
- common_ = null;
+ public Builder clearStatus() {
+ if (statusBuilder_ == null) {
+ status_ = null;
onChanged();
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommon.Builder getCommonBuilder() {
+ public apache.rocketmq.v2.Status.Builder getStatusBuilder() {
onChanged();
- return getCommonFieldBuilder().getBuilder();
+ return getStatusFieldBuilder().getBuilder();
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- if (commonBuilder_ != null) {
- return commonBuilder_.getMessageOrBuilder();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ if (statusBuilder_ != null) {
+ return statusBuilder_.getMessageOrBuilder();
} else {
- return common_ == null ?
- apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ return status_ == null ?
+ apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>
- getCommonFieldBuilder() {
- if (commonBuilder_ == null) {
- commonBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>(
- getCommon(),
+ 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());
- common_ = null;
+ status_ = null;
}
- return commonBuilder_;
+ return statusBuilder_;
}
@java.lang.Override
public final Builder setUnknownFields(
diff --git a/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueResponseOrBuilder.java b/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueResponseOrBuilder.java
index 4b18a93..b5a8add 100644
--- a/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueResponseOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueResponseOrBuilder.java
@@ -8,17 +8,17 @@ public interface ForwardMessageToDeadLetterQueueResponseOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- boolean hasCommon();
+ boolean hasStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- apache.rocketmq.v2.ResponseCommon getCommon();
+ apache.rocketmq.v2.Status getStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder();
+ apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder();
}
diff --git a/src/main/java/apache/rocketmq/v2/HeartbeatResponse.java b/src/main/java/apache/rocketmq/v2/HeartbeatResponse.java
index f90b8e4..c7456c7 100644
--- a/src/main/java/apache/rocketmq/v2/HeartbeatResponse.java
+++ b/src/main/java/apache/rocketmq/v2/HeartbeatResponse.java
@@ -49,14 +49,14 @@ private static final long serialVersionUID = 0L;
done = true;
break;
case 10: {
- apache.rocketmq.v2.ResponseCommon.Builder subBuilder = null;
- if (common_ != null) {
- subBuilder = common_.toBuilder();
+ apache.rocketmq.v2.Status.Builder subBuilder = null;
+ if (status_ != null) {
+ subBuilder = status_.toBuilder();
}
- common_ = input.readMessage(apache.rocketmq.v2.ResponseCommon.parser(), extensionRegistry);
+ status_ = input.readMessage(apache.rocketmq.v2.Status.parser(), extensionRegistry);
if (subBuilder != null) {
- subBuilder.mergeFrom(common_);
- common_ = subBuilder.buildPartial();
+ subBuilder.mergeFrom(status_);
+ status_ = subBuilder.buildPartial();
}
break;
@@ -93,30 +93,30 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.HeartbeatResponse.class, apache.rocketmq.v2.HeartbeatResponse.Builder.class);
}
- public static final int COMMON_FIELD_NUMBER = 1;
- private apache.rocketmq.v2.ResponseCommon common_;
+ public static final int STATUS_FIELD_NUMBER = 1;
+ private apache.rocketmq.v2.Status status_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
@java.lang.Override
- public boolean hasCommon() {
- return common_ != null;
+ public boolean hasStatus() {
+ return status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- return getCommon();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ return getStatus();
}
private byte memoizedIsInitialized = -1;
@@ -133,8 +133,8 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
- if (common_ != null) {
- output.writeMessage(1, getCommon());
+ if (status_ != null) {
+ output.writeMessage(1, getStatus());
}
unknownFields.writeTo(output);
}
@@ -145,9 +145,9 @@ private static final long serialVersionUID = 0L;
if (size != -1) return size;
size = 0;
- if (common_ != null) {
+ if (status_ != null) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(1, getCommon());
+ .computeMessageSize(1, getStatus());
}
size += unknownFields.getSerializedSize();
memoizedSize = size;
@@ -164,10 +164,10 @@ private static final long serialVersionUID = 0L;
}
apache.rocketmq.v2.HeartbeatResponse other = (apache.rocketmq.v2.HeartbeatResponse) obj;
- if (hasCommon() != other.hasCommon()) return false;
- if (hasCommon()) {
- if (!getCommon()
- .equals(other.getCommon())) return false;
+ if (hasStatus() != other.hasStatus()) return false;
+ if (hasStatus()) {
+ if (!getStatus()
+ .equals(other.getStatus())) return false;
}
if (!unknownFields.equals(other.unknownFields)) return false;
return true;
@@ -180,9 +180,9 @@ private static final long serialVersionUID = 0L;
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
- if (hasCommon()) {
- hash = (37 * hash) + COMMON_FIELD_NUMBER;
- hash = (53 * hash) + getCommon().hashCode();
+ if (hasStatus()) {
+ hash = (37 * hash) + STATUS_FIELD_NUMBER;
+ hash = (53 * hash) + getStatus().hashCode();
}
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
@@ -317,11 +317,11 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public Builder clear() {
super.clear();
- if (commonBuilder_ == null) {
- common_ = null;
+ if (statusBuilder_ == null) {
+ status_ = null;
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
@@ -349,10 +349,10 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public apache.rocketmq.v2.HeartbeatResponse buildPartial() {
apache.rocketmq.v2.HeartbeatResponse result = new apache.rocketmq.v2.HeartbeatResponse(this);
- if (commonBuilder_ == null) {
- result.common_ = common_;
+ if (statusBuilder_ == null) {
+ result.status_ = status_;
} else {
- result.common_ = commonBuilder_.build();
+ result.status_ = statusBuilder_.build();
}
onBuilt();
return result;
@@ -402,8 +402,8 @@ private static final long serialVersionUID = 0L;
public Builder mergeFrom(apache.rocketmq.v2.HeartbeatResponse other) {
if (other == apache.rocketmq.v2.HeartbeatResponse.getDefaultInstance()) return this;
- if (other.hasCommon()) {
- mergeCommon(other.getCommon());
+ if (other.hasStatus()) {
+ mergeStatus(other.getStatus());
}
this.mergeUnknownFields(other.unknownFields);
onChanged();
@@ -434,123 +434,123 @@ private static final long serialVersionUID = 0L;
return this;
}
- private apache.rocketmq.v2.ResponseCommon common_;
+ private apache.rocketmq.v2.Status status_;
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder> commonBuilder_;
+ apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> statusBuilder_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- public boolean hasCommon() {
- return commonBuilder_ != null || common_ != null;
+ public boolean hasStatus() {
+ return statusBuilder_ != null || status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- if (commonBuilder_ == null) {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ if (statusBuilder_ == null) {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
} else {
- return commonBuilder_.getMessage();
+ return statusBuilder_.getMessage();
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
+ public Builder setStatus(apache.rocketmq.v2.Status value) {
+ if (statusBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
- common_ = value;
+ status_ = value;
onChanged();
} else {
- commonBuilder_.setMessage(value);
+ statusBuilder_.setMessage(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(
- apache.rocketmq.v2.ResponseCommon.Builder builderForValue) {
- if (commonBuilder_ == null) {
- common_ = builderForValue.build();
+ public Builder setStatus(
+ apache.rocketmq.v2.Status.Builder builderForValue) {
+ if (statusBuilder_ == null) {
+ status_ = builderForValue.build();
onChanged();
} else {
- commonBuilder_.setMessage(builderForValue.build());
+ statusBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder mergeCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
- if (common_ != null) {
- common_ =
- apache.rocketmq.v2.ResponseCommon.newBuilder(common_).mergeFrom(value).buildPartial();
+ 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 {
- common_ = value;
+ status_ = value;
}
onChanged();
} else {
- commonBuilder_.mergeFrom(value);
+ statusBuilder_.mergeFrom(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder clearCommon() {
- if (commonBuilder_ == null) {
- common_ = null;
+ public Builder clearStatus() {
+ if (statusBuilder_ == null) {
+ status_ = null;
onChanged();
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommon.Builder getCommonBuilder() {
+ public apache.rocketmq.v2.Status.Builder getStatusBuilder() {
onChanged();
- return getCommonFieldBuilder().getBuilder();
+ return getStatusFieldBuilder().getBuilder();
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- if (commonBuilder_ != null) {
- return commonBuilder_.getMessageOrBuilder();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ if (statusBuilder_ != null) {
+ return statusBuilder_.getMessageOrBuilder();
} else {
- return common_ == null ?
- apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ return status_ == null ?
+ apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>
- getCommonFieldBuilder() {
- if (commonBuilder_ == null) {
- commonBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>(
- getCommon(),
+ 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());
- common_ = null;
+ status_ = null;
}
- return commonBuilder_;
+ return statusBuilder_;
}
@java.lang.Override
public final Builder setUnknownFields(
diff --git a/src/main/java/apache/rocketmq/v2/HeartbeatResponseOrBuilder.java b/src/main/java/apache/rocketmq/v2/HeartbeatResponseOrBuilder.java
index e0083b9..fa005c9 100644
--- a/src/main/java/apache/rocketmq/v2/HeartbeatResponseOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/HeartbeatResponseOrBuilder.java
@@ -8,17 +8,17 @@ public interface HeartbeatResponseOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- boolean hasCommon();
+ boolean hasStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- apache.rocketmq.v2.ResponseCommon getCommon();
+ apache.rocketmq.v2.Status getStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder();
+ 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 4d74acb..0f2c78a 100644
--- a/src/main/java/apache/rocketmq/v2/MQService.java
+++ b/src/main/java/apache/rocketmq/v2/MQService.java
@@ -15,10 +15,10 @@ public final class MQService {
(com.google.protobuf.ExtensionRegistryLite) registry);
}
static final com.google.protobuf.Descriptors.Descriptor
- internal_static_apache_rocketmq_v2_ResponseCommon_descriptor;
+ internal_static_apache_rocketmq_v2_Status_descriptor;
static final
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internal_static_apache_rocketmq_v2_ResponseCommon_fieldAccessorTable;
+ internal_static_apache_rocketmq_v2_Status_fieldAccessorTable;
static final com.google.protobuf.Descriptors.Descriptor
internal_static_apache_rocketmq_v2_QueryRouteRequest_descriptor;
static final
@@ -188,186 +188,184 @@ public final class MQService {
".proto\032\037google/protobuf/timestamp.proto\032" +
"\036google/rpc/error_details.proto\032\027google/" +
"rpc/status.proto\032#apache/rocketmq/v2/def" +
- "inition.proto\"Q\n\016ResponseCommon\022.\n\004code\030" +
- "\001 \001(\0162 .apache.rocketmq.v2.ResponseCode\022" +
- "\017\n\007message\030\002 \001(\t\"r\n\021QueryRouteRequest\022+\n" +
- "\005topic\030\001 \001(\0132\034.apache.rocketmq.v2.Resour" +
- "ce\0220\n\tendpoints\030\002 \001(\0132\035.apache.rocketmq." +
- "v2.Endpoints\"\202\001\n\022QueryRouteResponse\0222\n\006c" +
- "ommon\030\001 \001(\0132\".apache.rocketmq.v2.Respons" +
- "eCommon\0228\n\016message_queues\030\002 \003(\0132 .apache" +
- ".rocketmq.v2.MessageQueue\"|\n\022SendMessage" +
- "Request\022-\n\010messages\030\001 \003(\0132\033.apache.rocke" +
- "tmq.v2.Message\0227\n\rmessage_queue\030\002 \001(\0132 ." +
- "apache.rocketmq.v2.MessageQueue\"|\n\023SendM" +
- "essageResponse\0222\n\006common\030\001 \001(\0132\".apache." +
- "rocketmq.v2.ResponseCommon\0221\n\010receipts\030\002" +
- " \003(\0132\037.apache.rocketmq.v2.SendReceipt\"\267\001" +
- "\n\026QueryAssignmentRequest\022+\n\005topic\030\001 \001(\0132" +
- "\034.apache.rocketmq.v2.Resource\022+\n\005group\030\002" +
- " \001(\0132\034.apache.rocketmq.v2.Resource\022\021\n\tcl" +
- "ient_id\030\003 \001(\t\0220\n\tendpoints\030\004 \001(\0132\035.apach" +
- "e.rocketmq.v2.Endpoints\"\202\001\n\027QueryAssignm" +
- "entResponse\0222\n\006common\030\001 \001(\0132\".apache.roc" +
- "ketmq.v2.ResponseCommon\0223\n\013assignments\030\002" +
- " \003(\0132\036.apache.rocketmq.v2.Assignment\"\233\003\n" +
- "\025ReceiveMessageRequest\022+\n\005group\030\001 \001(\0132\034." +
- "apache.rocketmq.v2.Resource\022\021\n\tclient_id" +
- "\030\002 \001(\t\0227\n\rmessage_queue\030\003 \001(\0132 .apache.r" +
- "ocketmq.v2.MessageQueue\022?\n\021filter_expres" +
- "sion\030\004 \001(\0132$.apache.rocketmq.v2.FilterEx" +
- "pression\022<\n\030initialization_timestamp\030\005 \001" +
- "(\0132\032.google.protobuf.Timestamp\022\022\n\nbatch_" +
- "size\030\006 \001(\005\0225\n\022invisible_duration\030\007 \001(\0132\031" +
- ".google.protobuf.Duration\0221\n\016await_durat" +
- "ion\030\010 \001(\0132\031.google.protobuf.Duration\022\014\n\004" +
- "fifo\030\t \001(\010\"\352\001\n\026ReceiveMessageResponse\0222\n" +
- "\006common\030\001 \001(\0132\".apache.rocketmq.v2.Respo" +
- "nseCommon\022-\n\010messages\030\002 \003(\0132\033.apache.roc" +
- "ketmq.v2.Message\0226\n\022delivery_timestamp\030\003" +
- " \001(\0132\032.google.protobuf.Timestamp\0225\n\022invi" +
- "sible_duration\030\004 \001(\0132\031.google.protobuf.D" +
- "uration\"\254\001\n\021AckMessageRequest\022+\n\005group\030\001" +
- " \001(\0132\034.apache.rocketmq.v2.Resource\022+\n\005to" +
- "pic\030\002 \001(\0132\034.apache.rocketmq.v2.Resource\022" +
- "\021\n\tclient_id\030\003 \001(\t\022\026\n\016receipt_handle\030\004 \001" +
- "(\t\022\022\n\nmessage_id\030\005 \001(\t\"H\n\022AckMessageResp" +
- "onse\0222\n\006common\030\001 \001(\0132\".apache.rocketmq.v" +
- "2.ResponseCommon\"\372\001\n&ForwardMessageToDea" +
- "dLetterQueueRequest\022+\n\005group\030\001 \001(\0132\034.apa" +
- "che.rocketmq.v2.Resource\022+\n\005topic\030\002 \001(\0132" +
- "\034.apache.rocketmq.v2.Resource\022\021\n\tclient_" +
- "id\030\003 \001(\t\022\026\n\016receipt_handle\030\004 \001(\t\022\022\n\nmess" +
- "age_id\030\005 \001(\t\022\030\n\020delivery_attempt\030\006 \001(\005\022\035" +
- "\n\025max_delivery_attempts\030\007 \001(\005\"]\n\'Forward" +
- "MessageToDeadLetterQueueResponse\0222\n\006comm" +
- "on\030\001 \001(\0132\".apache.rocketmq.v2.ResponseCo" +
- "mmon\"R\n\020HeartbeatRequest\022\021\n\tclient_id\030\001 " +
- "\001(\t\022+\n\005group\030\002 \001(\0132\034.apache.rocketmq.v2." +
- "Resource\"G\n\021HeartbeatResponse\0222\n\006common\030" +
- "\001 \001(\0132\".apache.rocketmq.v2.ResponseCommo" +
- "n\"\375\001\n\025EndTransactionRequest\022+\n\005group\030\001 \001" +
- "(\0132\034.apache.rocketmq.v2.Resource\022\022\n\nmess" +
- "age_id\030\002 \001(\t\022\026\n\016transaction_id\030\003 \001(\t\022=\n\n" +
- "resolution\030\004 \001(\0162).apache.rocketmq.v2.Tr" +
- "ansactionResolution\0225\n\006source\030\005 \001(\0162%.ap" +
- "ache.rocketmq.v2.TransactionSource\022\025\n\rtr" +
- "ace_context\030\006 \001(\t\"L\n\026EndTransactionRespo" +
- "nse\0222\n\006common\030\001 \001(\0132\".apache.rocketmq.v2" +
- ".ResponseCommon\"\264\001\n\022QueryOffsetRequest\0227" +
- "\n\rmessage_queue\030\001 \001(\0132 .apache.rocketmq." +
- "v2.MessageQueue\0225\n\006policy\030\002 \001(\0162%.apache" +
- ".rocketmq.v2.QueryOffsetPolicy\022.\n\ntime_p" +
- "oint\030\003 \001(\0132\032.google.protobuf.Timestamp\"Y" +
- "\n\023QueryOffsetResponse\0222\n\006common\030\001 \001(\0132\"." +
- "apache.rocketmq.v2.ResponseCommon\022\016\n\006off" +
- "set\030\002 \001(\003\"\241\002\n\022PullMessageRequest\022+\n\005grou" +
- "p\030\001 \001(\0132\034.apache.rocketmq.v2.Resource\0227\n" +
+ "inition.proto\"I\n\006Status\022.\n\004code\030\001 \001(\0162 ." +
+ "apache.rocketmq.v2.ResponseCode\022\017\n\007messa" +
+ "ge\030\002 \001(\t\"r\n\021QueryRouteRequest\022+\n\005topic\030\001" +
+ " \001(\0132\034.apache.rocketmq.v2.Resource\0220\n\ten" +
+ "dpoints\030\002 \001(\0132\035.apache.rocketmq.v2.Endpo" +
+ "ints\"z\n\022QueryRouteResponse\022*\n\006status\030\001 \001" +
+ "(\0132\032.apache.rocketmq.v2.Status\0228\n\016messag" +
+ "e_queues\030\002 \003(\0132 .apache.rocketmq.v2.Mess" +
+ "ageQueue\"|\n\022SendMessageRequest\022-\n\010messag" +
+ "es\030\001 \003(\0132\033.apache.rocketmq.v2.Message\0227\n" +
"\rmessage_queue\030\002 \001(\0132 .apache.rocketmq.v" +
- "2.MessageQueue\022\016\n\006offset\030\003 \001(\003\022\022\n\nbatch_" +
- "size\030\004 \001(\005\022-\n\nawait_time\030\005 \001(\0132\031.google." +
- "protobuf.Duration\022?\n\021filter_expression\030\006" +
- " \001(\0132$.apache.rocketmq.v2.FilterExpressi" +
- "on\022\021\n\tclient_id\030\007 \001(\t\"\265\001\n\023PullMessageRes" +
- "ponse\0222\n\006common\030\001 \001(\0132\".apache.rocketmq." +
- "v2.ResponseCommon\022\022\n\nmin_offset\030\002 \001(\003\022\023\n" +
- "\013next_offset\030\003 \001(\003\022\022\n\nmax_offset\030\004 \001(\003\022-" +
- "\n\010messages\030\005 \003(\0132\033.apache.rocketmq.v2.Me" +
- "ssage\"2\n\034PrintThreadStackTraceCommand\022\022\n" +
- "\ncommand_id\030\001 \001(\003\"B\n\020ThreadStackTrace\022\022\n" +
- "\ncommand_id\030\001 \001(\003\022\032\n\022thread_stack_trace\030" +
- "\002 \001(\t\"X\n\024VerifyMessageCommand\022\022\n\ncommand" +
- "_id\030\001 \001(\003\022,\n\007message\030\002 \001(\0132\033.apache.rock" +
- "etmq.v2.Message\"]\n\023VerifyMessageResult\022\022" +
- "\n\ncommand_id\030\001 \001(\003\0222\n\006common\030\002 \001(\0132\".apa" +
- "che.rocketmq.v2.ResponseCommon\"\224\001\n!Recov" +
- "erOrphanedTransactionCommand\022\022\n\ncommand_" +
- "id\030\001 \001(\003\022C\n\036orphaned_transactional_messa" +
- "ge\030\002 \001(\0132\033.apache.rocketmq.v2.Message\022\026\n" +
- "\016transaction_id\030\003 \001(\t\"\325\001\n\010Settings\022\021\n\tcl" +
- "ient_id\030\001 \001(\t\022\024\n\014access_point\030\002 \001(\t\022,\n\007p" +
- "ublish\030\003 \001(\0132\033.apache.rocketmq.v2.Publis" +
- "h\0226\n\014subscription\030\004 \001(\0132 .apache.rocketm" +
- "q.v2.Subscription\022:\n\016authentication\030\005 \001(" +
- "\0132\".apache.rocketmq.v2.Authentication\"\356\003" +
- "\n\020TelemetryCommand\0220\n\010settings\030\001 \001(\0132\034.a" +
- "pache.rocketmq.v2.SettingsH\000\022e\n$recover_" +
- "orphaned_transaction_command\030\002 \001(\01325.apa" +
- "che.rocketmq.v2.RecoverOrphanedTransacti" +
- "onCommandH\000\022\\\n print_thread_stack_trace_" +
- "command\030\003 \001(\01320.apache.rocketmq.v2.Print" +
- "ThreadStackTraceCommandH\000\022B\n\022thread_stac" +
- "k_trace\030\004 \001(\0132$.apache.rocketmq.v2.Threa" +
- "dStackTraceH\000\022J\n\026verify_message_command\030" +
- "\005 \001(\0132(.apache.rocketmq.v2.VerifyMessage" +
- "CommandH\000\022H\n\025verify_message_result\030\006 \001(\013" +
- "2\'.apache.rocketmq.v2.VerifyMessageResul" +
- "tH\000B\t\n\007command\"`\n\036NotifyClientTerminatio" +
+ "2.MessageQueue\"t\n\023SendMessageResponse\022*\n" +
+ "\006status\030\001 \001(\0132\032.apache.rocketmq.v2.Statu" +
+ "s\0221\n\010receipts\030\002 \003(\0132\037.apache.rocketmq.v2" +
+ ".SendReceipt\"\267\001\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\022\021\n\tclient_id\030\003 \001(\t\0220\n\tendpoint" +
+ "s\030\004 \001(\0132\035.apache.rocketmq.v2.Endpoints\"z" +
+ "\n\027QueryAssignmentResponse\022*\n\006status\030\001 \001(" +
+ "\0132\032.apache.rocketmq.v2.Status\0223\n\013assignm" +
+ "ents\030\002 \003(\0132\036.apache.rocketmq.v2.Assignme" +
+ "nt\"\233\003\n\025ReceiveMessageRequest\022+\n\005group\030\001 " +
+ "\001(\0132\034.apache.rocketmq.v2.Resource\022\021\n\tcli" +
+ "ent_id\030\002 \001(\t\0227\n\rmessage_queue\030\003 \001(\0132 .ap" +
+ "ache.rocketmq.v2.MessageQueue\022?\n\021filter_" +
+ "expression\030\004 \001(\0132$.apache.rocketmq.v2.Fi" +
+ "lterExpression\022<\n\030initialization_timesta" +
+ "mp\030\005 \001(\0132\032.google.protobuf.Timestamp\022\022\n\n" +
+ "batch_size\030\006 \001(\005\0225\n\022invisible_duration\030\007" +
+ " \001(\0132\031.google.protobuf.Duration\0221\n\016await" +
+ "_duration\030\010 \001(\0132\031.google.protobuf.Durati" +
+ "on\022\014\n\004fifo\030\t \001(\010\"\342\001\n\026ReceiveMessageRespo" +
+ "nse\022*\n\006status\030\001 \001(\0132\032.apache.rocketmq.v2" +
+ ".Status\022-\n\010messages\030\002 \003(\0132\033.apache.rocke" +
+ "tmq.v2.Message\0226\n\022delivery_timestamp\030\003 \001" +
+ "(\0132\032.google.protobuf.Timestamp\0225\n\022invisi" +
+ "ble_duration\030\004 \001(\0132\031.google.protobuf.Dur" +
+ "ation\"\254\001\n\021AckMessageRequest\022+\n\005group\030\001 \001" +
+ "(\0132\034.apache.rocketmq.v2.Resource\022+\n\005topi" +
+ "c\030\002 \001(\0132\034.apache.rocketmq.v2.Resource\022\021\n" +
+ "\tclient_id\030\003 \001(\t\022\026\n\016receipt_handle\030\004 \001(\t" +
+ "\022\022\n\nmessage_id\030\005 \001(\t\"@\n\022AckMessageRespon" +
+ "se\022*\n\006status\030\001 \001(\0132\032.apache.rocketmq.v2." +
+ "Status\"\372\001\n&ForwardMessageToDeadLetterQue" +
+ "ueRequest\022+\n\005group\030\001 \001(\0132\034.apache.rocket" +
+ "mq.v2.Resource\022+\n\005topic\030\002 \001(\0132\034.apache.r" +
+ "ocketmq.v2.Resource\022\021\n\tclient_id\030\003 \001(\t\022\026" +
+ "\n\016receipt_handle\030\004 \001(\t\022\022\n\nmessage_id\030\005 \001" +
+ "(\t\022\030\n\020delivery_attempt\030\006 \001(\005\022\035\n\025max_deli" +
+ "very_attempts\030\007 \001(\005\"U\n\'ForwardMessageToD" +
+ "eadLetterQueueResponse\022*\n\006status\030\001 \001(\0132\032" +
+ ".apache.rocketmq.v2.Status\"R\n\020HeartbeatR" +
+ "equest\022\021\n\tclient_id\030\001 \001(\t\022+\n\005group\030\002 \001(\013" +
+ "2\034.apache.rocketmq.v2.Resource\"?\n\021Heartb" +
+ "eatResponse\022*\n\006status\030\001 \001(\0132\032.apache.roc" +
+ "ketmq.v2.Status\"\375\001\n\025EndTransactionReques" +
+ "t\022+\n\005group\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\"\264\001\n\022QueryOffsetReq" +
+ "uest\0227\n\rmessage_queue\030\001 \001(\0132 .apache.roc" +
+ "ketmq.v2.MessageQueue\0225\n\006policy\030\002 \001(\0162%." +
+ "apache.rocketmq.v2.QueryOffsetPolicy\022.\n\n" +
+ "time_point\030\003 \001(\0132\032.google.protobuf.Times" +
+ "tamp\"Q\n\023QueryOffsetResponse\022*\n\006status\030\001 " +
+ "\001(\0132\032.apache.rocketmq.v2.Status\022\016\n\006offse" +
+ "t\030\002 \001(\003\"\241\002\n\022PullMessageRequest\022+\n\005group\030" +
+ "\001 \001(\0132\034.apache.rocketmq.v2.Resource\0227\n\rm" +
+ "essage_queue\030\002 \001(\0132 .apache.rocketmq.v2." +
+ "MessageQueue\022\016\n\006offset\030\003 \001(\003\022\022\n\nbatch_si" +
+ "ze\030\004 \001(\005\022-\n\nawait_time\030\005 \001(\0132\031.google.pr" +
+ "otobuf.Duration\022?\n\021filter_expression\030\006 \001" +
+ "(\0132$.apache.rocketmq.v2.FilterExpression" +
+ "\022\021\n\tclient_id\030\007 \001(\t\"\255\001\n\023PullMessageRespo" +
+ "nse\022*\n\006status\030\001 \001(\0132\032.apache.rocketmq.v2" +
+ ".Status\022\022\n\nmin_offset\030\002 \001(\003\022\023\n\013next_offs" +
+ "et\030\003 \001(\003\022\022\n\nmax_offset\030\004 \001(\003\022-\n\010messages" +
+ "\030\005 \003(\0132\033.apache.rocketmq.v2.Message\"2\n\034P" +
+ "rintThreadStackTraceCommand\022\022\n\ncommand_i" +
+ "d\030\001 \001(\003\"B\n\020ThreadStackTrace\022\022\n\ncommand_i" +
+ "d\030\001 \001(\003\022\032\n\022thread_stack_trace\030\002 \001(\t\"X\n\024V" +
+ "erifyMessageCommand\022\022\n\ncommand_id\030\001 \001(\003\022" +
+ ",\n\007message\030\002 \001(\0132\033.apache.rocketmq.v2.Me" +
+ "ssage\"U\n\023VerifyMessageResult\022\022\n\ncommand_" +
+ "id\030\001 \001(\003\022*\n\006status\030\002 \001(\0132\032.apache.rocket" +
+ "mq.v2.Status\"\224\001\n!RecoverOrphanedTransact" +
+ "ionCommand\022\022\n\ncommand_id\030\001 \001(\003\022C\n\036orphan" +
+ "ed_transactional_message\030\002 \001(\0132\033.apache." +
+ "rocketmq.v2.Message\022\026\n\016transaction_id\030\003 " +
+ "\001(\t\"\325\001\n\010Settings\022\021\n\tclient_id\030\001 \001(\t\022\024\n\014a" +
+ "ccess_point\030\002 \001(\t\022,\n\007publish\030\003 \001(\0132\033.apa" +
+ "che.rocketmq.v2.Publish\0226\n\014subscription\030" +
+ "\004 \001(\0132 .apache.rocketmq.v2.Subscription\022" +
+ ":\n\016authentication\030\005 \001(\0132\".apache.rocketm" +
+ "q.v2.Authentication\"\356\003\n\020TelemetryCommand" +
+ "\0220\n\010settings\030\001 \001(\0132\034.apache.rocketmq.v2." +
+ "SettingsH\000\022e\n$recover_orphaned_transacti" +
+ "on_command\030\002 \001(\01325.apache.rocketmq.v2.Re" +
+ "coverOrphanedTransactionCommandH\000\022\\\n pri" +
+ "nt_thread_stack_trace_command\030\003 \001(\01320.ap" +
+ "ache.rocketmq.v2.PrintThreadStackTraceCo" +
+ "mmandH\000\022B\n\022thread_stack_trace\030\004 \001(\0132$.ap" +
+ "ache.rocketmq.v2.ThreadStackTraceH\000\022J\n\026v" +
+ "erify_message_command\030\005 \001(\0132(.apache.roc" +
+ "ketmq.v2.VerifyMessageCommandH\000\022H\n\025verif" +
+ "y_message_result\030\006 \001(\0132\'.apache.rocketmq" +
+ ".v2.VerifyMessageResultH\000B\t\n\007command\"`\n\036" +
+ "NotifyClientTerminationRequest\022+\n\005group\030" +
+ "\001 \001(\0132\034.apache.rocketmq.v2.Resource\022\021\n\tc" +
+ "lient_id\030\002 \001(\t\"M\n\037NotifyClientTerminatio" +
+ "nResponse\022*\n\006status\030\001 \001(\0132\032.apache.rocke" +
+ "tmq.v2.Status\"\311\001\n\036ChangeInvisibleDuratio" +
"nRequest\022+\n\005group\030\001 \001(\0132\034.apache.rocketm" +
- "q.v2.Resource\022\021\n\tclient_id\030\002 \001(\t\"U\n\037Noti" +
- "fyClientTerminationResponse\0222\n\006common\030\001 " +
- "\001(\0132\".apache.rocketmq.v2.ResponseCommon\"" +
- "\311\001\n\036ChangeInvisibleDurationRequest\022+\n\005gr" +
- "oup\030\001 \001(\0132\034.apache.rocketmq.v2.Resource\022" +
- "+\n\005topic\030\002 \001(\0132\034.apache.rocketmq.v2.Reso" +
- "urce\022\026\n\016receipt_handle\030\003 \001(\t\0225\n\022invisibl" +
- "e_duration\030\004 \001(\0132\031.google.protobuf.Durat" +
- "ion\"m\n\037ChangeInvisibleDurationResponse\0222" +
- "\n\006common\030\001 \001(\0132\".apache.rocketmq.v2.Resp" +
- "onseCommon\022\026\n\016receipt_handle\030\002 \001(\t*\304\004\n\014R" +
- "esponseCode\022\006\n\002OK\020\000\022\030\n\024ILLEGAL_ACCESS_PO" +
- "INT\020\001\022\021\n\rILLEGAL_TOPIC\020\002\022\032\n\026ILLEGAL_CONS" +
- "UMER_GROUP\020\003\022\027\n\023ILLEGAL_MESSAGE_TAG\020\004\022\027\n" +
- "\023ILLEGAL_MESSAGE_KEY\020\005\022\032\n\026MESSAGE_KEYS_T" +
- "OO_LARGE\020\006\022\031\n\025ILLEGAL_MESSAGE_GROUP\020\007\022 \n" +
- "\034ILLEGAL_MESSAGE_PROPERTY_KEY\020\010\022 \n\034MESSA" +
- "GE_PROPERTIES_TOO_LARGE\020\t\022\032\n\026MESSAGE_BOD" +
- "Y_TOO_LARGE\020\n\022!\n\035REQUEST_AUTHORISATION_F" +
- "AILURE\020\013\022\"\n\036REQUEST_AUTHENTICATION_FAILU" +
- "RE\020\014\022\030\n\024TOPIC_DOES_NOT_EXIST\020\r\022!\n\035CONSUM" +
- "ER_GROUP_DOES_NOT_EXIST\020\016\022\033\n\027OPERATION_N" +
- "OT_SUPPORTED\020\017\022\035\n\031FAILED_TO_CONSUME_MESS" +
- "AGE\020\020\022\025\n\021MESSAGE_CORRUPTED\020\021\022\020\n\014FLOW_CON" +
- "TROL\020\022\022\023\n\017REQUEST_EXPIRED\020\023\022\034\n\030MESSAGE_T" +
- "YPE_NOT_MATCHED\020\0242\242\013\n\020MessagingService\022]" +
- "\n\nQueryRoute\022%.apache.rocketmq.v2.QueryR" +
- "outeRequest\032&.apache.rocketmq.v2.QueryRo" +
- "uteResponse\"\000\022Z\n\tHeartbeat\022$.apache.rock" +
- "etmq.v2.HeartbeatRequest\032%.apache.rocket" +
- "mq.v2.HeartbeatResponse\"\000\022`\n\013SendMessage" +
- "\022&.apache.rocketmq.v2.SendMessageRequest" +
- "\032\'.apache.rocketmq.v2.SendMessageRespons" +
- "e\"\000\022l\n\017QueryAssignment\022*.apache.rocketmq" +
- ".v2.QueryAssignmentRequest\032+.apache.rock" +
- "etmq.v2.QueryAssignmentResponse\"\000\022i\n\016Rec" +
- "eiveMessage\022).apache.rocketmq.v2.Receive" +
- "MessageRequest\032*.apache.rocketmq.v2.Rece" +
- "iveMessageResponse\"\000\022]\n\nAckMessage\022%.apa" +
- "che.rocketmq.v2.AckMessageRequest\032&.apac" +
- "he.rocketmq.v2.AckMessageResponse\"\000\022\234\001\n\037" +
- "ForwardMessageToDeadLetterQueue\022:.apache" +
- ".rocketmq.v2.ForwardMessageToDeadLetterQ" +
- "ueueRequest\032;.apache.rocketmq.v2.Forward" +
- "MessageToDeadLetterQueueResponse\"\000\022i\n\016En" +
- "dTransaction\022).apache.rocketmq.v2.EndTra" +
- "nsactionRequest\032*.apache.rocketmq.v2.End" +
- "TransactionResponse\"\000\022`\n\013QueryOffset\022&.a" +
- "pache.rocketmq.v2.QueryOffsetRequest\032\'.a" +
- "pache.rocketmq.v2.QueryOffsetResponse\"\000\022" +
- "`\n\013PullMessage\022&.apache.rocketmq.v2.Pull" +
- "MessageRequest\032\'.apache.rocketmq.v2.Pull" +
- "MessageResponse\"\000\022]\n\tTelemetry\022$.apache." +
- "rocketmq.v2.TelemetryCommand\032$.apache.ro" +
- "cketmq.v2.TelemetryCommand\"\000(\0010\001\022\204\001\n\027Not" +
- "ifyClientTermination\0222.apache.rocketmq.v" +
- "2.NotifyClientTerminationRequest\0323.apach" +
- "e.rocketmq.v2.NotifyClientTerminationRes" +
- "ponse\"\000\022\204\001\n\027ChangeInvisibleDuration\0222.ap" +
- "ache.rocketmq.v2.ChangeInvisibleDuration" +
- "Request\0323.apache.rocketmq.v2.ChangeInvis" +
- "ibleDurationResponse\"\000B<\n\022apache.rocketm" +
- "q.v2B\tMQServiceP\001\240\001\001\330\001\001\252\002\022Apache.Rocketm" +
- "q.V2b\006proto3"
+ "q.v2.Resource\022+\n\005topic\030\002 \001(\0132\034.apache.ro" +
+ "cketmq.v2.Resource\022\026\n\016receipt_handle\030\003 \001" +
+ "(\t\0225\n\022invisible_duration\030\004 \001(\0132\031.google." +
+ "protobuf.Duration\"e\n\037ChangeInvisibleDura" +
+ "tionResponse\022*\n\006status\030\001 \001(\0132\032.apache.ro" +
+ "cketmq.v2.Status\022\026\n\016receipt_handle\030\002 \001(\t" +
+ "*\353\004\n\014ResponseCode\022\006\n\002OK\020\000\022\030\n\024ILLEGAL_ACC" +
+ "ESS_POINT\020\001\022\021\n\rILLEGAL_TOPIC\020\002\022\032\n\026ILLEGA" +
+ "L_CONSUMER_GROUP\020\003\022\027\n\023ILLEGAL_MESSAGE_TA" +
+ "G\020\004\022\027\n\023ILLEGAL_MESSAGE_KEY\020\005\022\032\n\026MESSAGE_" +
+ "KEYS_TOO_LARGE\020\006\022\031\n\025ILLEGAL_MESSAGE_GROU" +
+ "P\020\007\022 \n\034ILLEGAL_MESSAGE_PROPERTY_KEY\020\010\022 \n" +
+ "\034MESSAGE_PROPERTIES_TOO_LARGE\020\t\022\032\n\026MESSA" +
+ "GE_BODY_TOO_LARGE\020\n\022!\n\035REQUEST_AUTHORISA" +
+ "TION_FAILURE\020\013\022\"\n\036REQUEST_AUTHENTICATION" +
+ "_FAILURE\020\014\022\030\n\024TOPIC_DOES_NOT_EXIST\020\r\022!\n\035" +
+ "CONSUMER_GROUP_DOES_NOT_EXIST\020\016\022\036\n\032VERIF" +
+ "Y_MESSAGE_NOT_ALLOWED\020\017\022\035\n\031FAILED_TO_CON" +
+ "SUME_MESSAGE\020\020\022\025\n\021MESSAGE_CORRUPTED\020\021\022\030\n" +
+ "\024REQUEST_FLOW_CONTROL\020\022\022\033\n\027ACKNOWLEDGEME" +
+ "NT_EXPIRED\020\023\0220\n,MESSAGE_PROPERTY_DOES_NO" +
+ "T_MATCH_MESSAGE_TYPE\020\0242\242\013\n\020MessagingServ" +
+ "ice\022]\n\nQueryRoute\022%.apache.rocketmq.v2.Q" +
+ "ueryRouteRequest\032&.apache.rocketmq.v2.Qu" +
+ "eryRouteResponse\"\000\022Z\n\tHeartbeat\022$.apache" +
+ ".rocketmq.v2.HeartbeatRequest\032%.apache.r" +
+ "ocketmq.v2.HeartbeatResponse\"\000\022`\n\013SendMe" +
+ "ssage\022&.apache.rocketmq.v2.SendMessageRe" +
+ "quest\032\'.apache.rocketmq.v2.SendMessageRe" +
+ "sponse\"\000\022l\n\017QueryAssignment\022*.apache.roc" +
+ "ketmq.v2.QueryAssignmentRequest\032+.apache" +
+ ".rocketmq.v2.QueryAssignmentResponse\"\000\022i" +
+ "\n\016ReceiveMessage\022).apache.rocketmq.v2.Re" +
+ "ceiveMessageRequest\032*.apache.rocketmq.v2" +
+ ".ReceiveMessageResponse\"\000\022]\n\nAckMessage\022" +
+ "%.apache.rocketmq.v2.AckMessageRequest\032&" +
+ ".apache.rocketmq.v2.AckMessageResponse\"\000" +
+ "\022\234\001\n\037ForwardMessageToDeadLetterQueue\022:.a" +
+ "pache.rocketmq.v2.ForwardMessageToDeadLe" +
+ "tterQueueRequest\032;.apache.rocketmq.v2.Fo" +
+ "rwardMessageToDeadLetterQueueResponse\"\000\022" +
+ "i\n\016EndTransaction\022).apache.rocketmq.v2.E" +
+ "ndTransactionRequest\032*.apache.rocketmq.v" +
+ "2.EndTransactionResponse\"\000\022`\n\013QueryOffse" +
+ "t\022&.apache.rocketmq.v2.QueryOffsetReques" +
+ "t\032\'.apache.rocketmq.v2.QueryOffsetRespon" +
+ "se\"\000\022`\n\013PullMessage\022&.apache.rocketmq.v2" +
+ ".PullMessageRequest\032\'.apache.rocketmq.v2" +
+ ".PullMessageResponse\"\000\022]\n\tTelemetry\022$.ap" +
+ "ache.rocketmq.v2.TelemetryCommand\032$.apac" +
+ "he.rocketmq.v2.TelemetryCommand\"\000(\0010\001\022\204\001" +
+ "\n\027NotifyClientTermination\0222.apache.rocke" +
+ "tmq.v2.NotifyClientTerminationRequest\0323." +
+ "apache.rocketmq.v2.NotifyClientTerminati" +
+ "onResponse\"\000\022\204\001\n\027ChangeInvisibleDuration" +
+ "\0222.apache.rocketmq.v2.ChangeInvisibleDur" +
+ "ationRequest\0323.apache.rocketmq.v2.Change" +
+ "InvisibleDurationResponse\"\000B<\n\022apache.ro" +
+ "cketmq.v2B\tMQServiceP\001\240\001\001\330\001\001\252\002\022Apache.Ro" +
+ "cketmq.V2b\006proto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,
@@ -378,11 +376,11 @@ public final class MQService {
com.google.rpc.StatusProto.getDescriptor(),
apache.rocketmq.v2.MQDomain.getDescriptor(),
});
- internal_static_apache_rocketmq_v2_ResponseCommon_descriptor =
+ internal_static_apache_rocketmq_v2_Status_descriptor =
getDescriptor().getMessageTypes().get(0);
- internal_static_apache_rocketmq_v2_ResponseCommon_fieldAccessorTable = new
+ internal_static_apache_rocketmq_v2_Status_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
- internal_static_apache_rocketmq_v2_ResponseCommon_descriptor,
+ internal_static_apache_rocketmq_v2_Status_descriptor,
new java.lang.String[] { "Code", "Message", });
internal_static_apache_rocketmq_v2_QueryRouteRequest_descriptor =
getDescriptor().getMessageTypes().get(1);
@@ -395,7 +393,7 @@ public final class MQService {
internal_static_apache_rocketmq_v2_QueryRouteResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_QueryRouteResponse_descriptor,
- new java.lang.String[] { "Common", "MessageQueues", });
+ new java.lang.String[] { "Status", "MessageQueues", });
internal_static_apache_rocketmq_v2_SendMessageRequest_descriptor =
getDescriptor().getMessageTypes().get(3);
internal_static_apache_rocketmq_v2_SendMessageRequest_fieldAccessorTable = new
@@ -407,7 +405,7 @@ public final class MQService {
internal_static_apache_rocketmq_v2_SendMessageResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_SendMessageResponse_descriptor,
- new java.lang.String[] { "Common", "Receipts", });
+ new java.lang.String[] { "Status", "Receipts", });
internal_static_apache_rocketmq_v2_QueryAssignmentRequest_descriptor =
getDescriptor().getMessageTypes().get(5);
internal_static_apache_rocketmq_v2_QueryAssignmentRequest_fieldAccessorTable = new
@@ -419,7 +417,7 @@ public final class MQService {
internal_static_apache_rocketmq_v2_QueryAssignmentResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_QueryAssignmentResponse_descriptor,
- new java.lang.String[] { "Common", "Assignments", });
+ new java.lang.String[] { "Status", "Assignments", });
internal_static_apache_rocketmq_v2_ReceiveMessageRequest_descriptor =
getDescriptor().getMessageTypes().get(7);
internal_static_apache_rocketmq_v2_ReceiveMessageRequest_fieldAccessorTable = new
@@ -431,7 +429,7 @@ public final class MQService {
internal_static_apache_rocketmq_v2_ReceiveMessageResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_ReceiveMessageResponse_descriptor,
- new java.lang.String[] { "Common", "Messages", "DeliveryTimestamp", "InvisibleDuration", });
+ new java.lang.String[] { "Status", "Messages", "DeliveryTimestamp", "InvisibleDuration", });
internal_static_apache_rocketmq_v2_AckMessageRequest_descriptor =
getDescriptor().getMessageTypes().get(9);
internal_static_apache_rocketmq_v2_AckMessageRequest_fieldAccessorTable = new
@@ -443,7 +441,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[] { "Common", });
+ new java.lang.String[] { "Status", });
internal_static_apache_rocketmq_v2_ForwardMessageToDeadLetterQueueRequest_descriptor =
getDescriptor().getMessageTypes().get(11);
internal_static_apache_rocketmq_v2_ForwardMessageToDeadLetterQueueRequest_fieldAccessorTable = new
@@ -455,7 +453,7 @@ public final class MQService {
internal_static_apache_rocketmq_v2_ForwardMessageToDeadLetterQueueResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_ForwardMessageToDeadLetterQueueResponse_descriptor,
- new java.lang.String[] { "Common", });
+ new java.lang.String[] { "Status", });
internal_static_apache_rocketmq_v2_HeartbeatRequest_descriptor =
getDescriptor().getMessageTypes().get(13);
internal_static_apache_rocketmq_v2_HeartbeatRequest_fieldAccessorTable = new
@@ -467,7 +465,7 @@ public final class MQService {
internal_static_apache_rocketmq_v2_HeartbeatResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_HeartbeatResponse_descriptor,
- new java.lang.String[] { "Common", });
+ new java.lang.String[] { "Status", });
internal_static_apache_rocketmq_v2_EndTransactionRequest_descriptor =
getDescriptor().getMessageTypes().get(15);
internal_static_apache_rocketmq_v2_EndTransactionRequest_fieldAccessorTable = new
@@ -479,7 +477,7 @@ public final class MQService {
internal_static_apache_rocketmq_v2_EndTransactionResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_EndTransactionResponse_descriptor,
- new java.lang.String[] { "Common", });
+ new java.lang.String[] { "Status", });
internal_static_apache_rocketmq_v2_QueryOffsetRequest_descriptor =
getDescriptor().getMessageTypes().get(17);
internal_static_apache_rocketmq_v2_QueryOffsetRequest_fieldAccessorTable = new
@@ -491,7 +489,7 @@ public final class MQService {
internal_static_apache_rocketmq_v2_QueryOffsetResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_QueryOffsetResponse_descriptor,
- new java.lang.String[] { "Common", "Offset", });
+ new java.lang.String[] { "Status", "Offset", });
internal_static_apache_rocketmq_v2_PullMessageRequest_descriptor =
getDescriptor().getMessageTypes().get(19);
internal_static_apache_rocketmq_v2_PullMessageRequest_fieldAccessorTable = new
@@ -503,7 +501,7 @@ public final class MQService {
internal_static_apache_rocketmq_v2_PullMessageResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_PullMessageResponse_descriptor,
- new java.lang.String[] { "Common", "MinOffset", "NextOffset", "MaxOffset", "Messages", });
+ new java.lang.String[] { "Status", "MinOffset", "NextOffset", "MaxOffset", "Messages", });
internal_static_apache_rocketmq_v2_PrintThreadStackTraceCommand_descriptor =
getDescriptor().getMessageTypes().get(21);
internal_static_apache_rocketmq_v2_PrintThreadStackTraceCommand_fieldAccessorTable = new
@@ -527,7 +525,7 @@ public final class MQService {
internal_static_apache_rocketmq_v2_VerifyMessageResult_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_VerifyMessageResult_descriptor,
- new java.lang.String[] { "CommandId", "Common", });
+ new java.lang.String[] { "CommandId", "Status", });
internal_static_apache_rocketmq_v2_RecoverOrphanedTransactionCommand_descriptor =
getDescriptor().getMessageTypes().get(25);
internal_static_apache_rocketmq_v2_RecoverOrphanedTransactionCommand_fieldAccessorTable = new
@@ -557,7 +555,7 @@ public final class MQService {
internal_static_apache_rocketmq_v2_NotifyClientTerminationResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_NotifyClientTerminationResponse_descriptor,
- new java.lang.String[] { "Common", });
+ new java.lang.String[] { "Status", });
internal_static_apache_rocketmq_v2_ChangeInvisibleDurationRequest_descriptor =
getDescriptor().getMessageTypes().get(30);
internal_static_apache_rocketmq_v2_ChangeInvisibleDurationRequest_fieldAccessorTable = new
@@ -569,7 +567,7 @@ public final class MQService {
internal_static_apache_rocketmq_v2_ChangeInvisibleDurationResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_ChangeInvisibleDurationResponse_descriptor,
- new java.lang.String[] { "Common", "ReceiptHandle", });
+ new java.lang.String[] { "Status", "ReceiptHandle", });
com.google.protobuf.DurationProto.getDescriptor();
com.google.protobuf.TimestampProto.getDescriptor();
com.google.rpc.ErrorDetailsProto.getDescriptor();
diff --git a/src/main/java/apache/rocketmq/v2/NotifyClientTerminationResponse.java b/src/main/java/apache/rocketmq/v2/NotifyClientTerminationResponse.java
index 54a8865..d7aa44d 100644
--- a/src/main/java/apache/rocketmq/v2/NotifyClientTerminationResponse.java
+++ b/src/main/java/apache/rocketmq/v2/NotifyClientTerminationResponse.java
@@ -49,14 +49,14 @@ private static final long serialVersionUID = 0L;
done = true;
break;
case 10: {
- apache.rocketmq.v2.ResponseCommon.Builder subBuilder = null;
- if (common_ != null) {
- subBuilder = common_.toBuilder();
+ apache.rocketmq.v2.Status.Builder subBuilder = null;
+ if (status_ != null) {
+ subBuilder = status_.toBuilder();
}
- common_ = input.readMessage(apache.rocketmq.v2.ResponseCommon.parser(), extensionRegistry);
+ status_ = input.readMessage(apache.rocketmq.v2.Status.parser(), extensionRegistry);
if (subBuilder != null) {
- subBuilder.mergeFrom(common_);
- common_ = subBuilder.buildPartial();
+ subBuilder.mergeFrom(status_);
+ status_ = subBuilder.buildPartial();
}
break;
@@ -93,30 +93,30 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.NotifyClientTerminationResponse.class, apache.rocketmq.v2.NotifyClientTerminationResponse.Builder.class);
}
- public static final int COMMON_FIELD_NUMBER = 1;
- private apache.rocketmq.v2.ResponseCommon common_;
+ public static final int STATUS_FIELD_NUMBER = 1;
+ private apache.rocketmq.v2.Status status_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
@java.lang.Override
- public boolean hasCommon() {
- return common_ != null;
+ public boolean hasStatus() {
+ return status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- return getCommon();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ return getStatus();
}
private byte memoizedIsInitialized = -1;
@@ -133,8 +133,8 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
- if (common_ != null) {
- output.writeMessage(1, getCommon());
+ if (status_ != null) {
+ output.writeMessage(1, getStatus());
}
unknownFields.writeTo(output);
}
@@ -145,9 +145,9 @@ private static final long serialVersionUID = 0L;
if (size != -1) return size;
size = 0;
- if (common_ != null) {
+ if (status_ != null) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(1, getCommon());
+ .computeMessageSize(1, getStatus());
}
size += unknownFields.getSerializedSize();
memoizedSize = size;
@@ -164,10 +164,10 @@ private static final long serialVersionUID = 0L;
}
apache.rocketmq.v2.NotifyClientTerminationResponse other = (apache.rocketmq.v2.NotifyClientTerminationResponse) obj;
- if (hasCommon() != other.hasCommon()) return false;
- if (hasCommon()) {
- if (!getCommon()
- .equals(other.getCommon())) return false;
+ if (hasStatus() != other.hasStatus()) return false;
+ if (hasStatus()) {
+ if (!getStatus()
+ .equals(other.getStatus())) return false;
}
if (!unknownFields.equals(other.unknownFields)) return false;
return true;
@@ -180,9 +180,9 @@ private static final long serialVersionUID = 0L;
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
- if (hasCommon()) {
- hash = (37 * hash) + COMMON_FIELD_NUMBER;
- hash = (53 * hash) + getCommon().hashCode();
+ if (hasStatus()) {
+ hash = (37 * hash) + STATUS_FIELD_NUMBER;
+ hash = (53 * hash) + getStatus().hashCode();
}
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
@@ -317,11 +317,11 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public Builder clear() {
super.clear();
- if (commonBuilder_ == null) {
- common_ = null;
+ if (statusBuilder_ == null) {
+ status_ = null;
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
@@ -349,10 +349,10 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public apache.rocketmq.v2.NotifyClientTerminationResponse buildPartial() {
apache.rocketmq.v2.NotifyClientTerminationResponse result = new apache.rocketmq.v2.NotifyClientTerminationResponse(this);
- if (commonBuilder_ == null) {
- result.common_ = common_;
+ if (statusBuilder_ == null) {
+ result.status_ = status_;
} else {
- result.common_ = commonBuilder_.build();
+ result.status_ = statusBuilder_.build();
}
onBuilt();
return result;
@@ -402,8 +402,8 @@ private static final long serialVersionUID = 0L;
public Builder mergeFrom(apache.rocketmq.v2.NotifyClientTerminationResponse other) {
if (other == apache.rocketmq.v2.NotifyClientTerminationResponse.getDefaultInstance()) return this;
- if (other.hasCommon()) {
- mergeCommon(other.getCommon());
+ if (other.hasStatus()) {
+ mergeStatus(other.getStatus());
}
this.mergeUnknownFields(other.unknownFields);
onChanged();
@@ -434,123 +434,123 @@ private static final long serialVersionUID = 0L;
return this;
}
- private apache.rocketmq.v2.ResponseCommon common_;
+ private apache.rocketmq.v2.Status status_;
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder> commonBuilder_;
+ apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> statusBuilder_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- public boolean hasCommon() {
- return commonBuilder_ != null || common_ != null;
+ public boolean hasStatus() {
+ return statusBuilder_ != null || status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- if (commonBuilder_ == null) {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ if (statusBuilder_ == null) {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
} else {
- return commonBuilder_.getMessage();
+ return statusBuilder_.getMessage();
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
+ public Builder setStatus(apache.rocketmq.v2.Status value) {
+ if (statusBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
- common_ = value;
+ status_ = value;
onChanged();
} else {
- commonBuilder_.setMessage(value);
+ statusBuilder_.setMessage(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(
- apache.rocketmq.v2.ResponseCommon.Builder builderForValue) {
- if (commonBuilder_ == null) {
- common_ = builderForValue.build();
+ public Builder setStatus(
+ apache.rocketmq.v2.Status.Builder builderForValue) {
+ if (statusBuilder_ == null) {
+ status_ = builderForValue.build();
onChanged();
} else {
- commonBuilder_.setMessage(builderForValue.build());
+ statusBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder mergeCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
- if (common_ != null) {
- common_ =
- apache.rocketmq.v2.ResponseCommon.newBuilder(common_).mergeFrom(value).buildPartial();
+ 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 {
- common_ = value;
+ status_ = value;
}
onChanged();
} else {
- commonBuilder_.mergeFrom(value);
+ statusBuilder_.mergeFrom(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder clearCommon() {
- if (commonBuilder_ == null) {
- common_ = null;
+ public Builder clearStatus() {
+ if (statusBuilder_ == null) {
+ status_ = null;
onChanged();
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommon.Builder getCommonBuilder() {
+ public apache.rocketmq.v2.Status.Builder getStatusBuilder() {
onChanged();
- return getCommonFieldBuilder().getBuilder();
+ return getStatusFieldBuilder().getBuilder();
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- if (commonBuilder_ != null) {
- return commonBuilder_.getMessageOrBuilder();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ if (statusBuilder_ != null) {
+ return statusBuilder_.getMessageOrBuilder();
} else {
- return common_ == null ?
- apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ return status_ == null ?
+ apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>
- getCommonFieldBuilder() {
- if (commonBuilder_ == null) {
- commonBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>(
- getCommon(),
+ 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());
- common_ = null;
+ status_ = null;
}
- return commonBuilder_;
+ return statusBuilder_;
}
@java.lang.Override
public final Builder setUnknownFields(
diff --git a/src/main/java/apache/rocketmq/v2/NotifyClientTerminationResponseOrBuilder.java b/src/main/java/apache/rocketmq/v2/NotifyClientTerminationResponseOrBuilder.java
index dfa2cb5..ee1a6fc 100644
--- a/src/main/java/apache/rocketmq/v2/NotifyClientTerminationResponseOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/NotifyClientTerminationResponseOrBuilder.java
@@ -8,17 +8,17 @@ public interface NotifyClientTerminationResponseOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- boolean hasCommon();
+ boolean hasStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- apache.rocketmq.v2.ResponseCommon getCommon();
+ apache.rocketmq.v2.Status getStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder();
+ apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder();
}
diff --git a/src/main/java/apache/rocketmq/v2/PullMessageResponse.java b/src/main/java/apache/rocketmq/v2/PullMessageResponse.java
index ae4a003..b026609 100644
--- a/src/main/java/apache/rocketmq/v2/PullMessageResponse.java
+++ b/src/main/java/apache/rocketmq/v2/PullMessageResponse.java
@@ -51,14 +51,14 @@ private static final long serialVersionUID = 0L;
done = true;
break;
case 10: {
- apache.rocketmq.v2.ResponseCommon.Builder subBuilder = null;
- if (common_ != null) {
- subBuilder = common_.toBuilder();
+ apache.rocketmq.v2.Status.Builder subBuilder = null;
+ if (status_ != null) {
+ subBuilder = status_.toBuilder();
}
- common_ = input.readMessage(apache.rocketmq.v2.ResponseCommon.parser(), extensionRegistry);
+ status_ = input.readMessage(apache.rocketmq.v2.Status.parser(), extensionRegistry);
if (subBuilder != null) {
- subBuilder.mergeFrom(common_);
- common_ = subBuilder.buildPartial();
+ subBuilder.mergeFrom(status_);
+ status_ = subBuilder.buildPartial();
}
break;
@@ -122,30 +122,30 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.PullMessageResponse.class, apache.rocketmq.v2.PullMessageResponse.Builder.class);
}
- public static final int COMMON_FIELD_NUMBER = 1;
- private apache.rocketmq.v2.ResponseCommon common_;
+ public static final int STATUS_FIELD_NUMBER = 1;
+ private apache.rocketmq.v2.Status status_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
@java.lang.Override
- public boolean hasCommon() {
- return common_ != null;
+ public boolean hasStatus() {
+ return status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- return getCommon();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ return getStatus();
}
public static final int MIN_OFFSET_FIELD_NUMBER = 2;
@@ -235,8 +235,8 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
- if (common_ != null) {
- output.writeMessage(1, getCommon());
+ if (status_ != null) {
+ output.writeMessage(1, getStatus());
}
if (minOffset_ != 0L) {
output.writeInt64(2, minOffset_);
@@ -259,9 +259,9 @@ private static final long serialVersionUID = 0L;
if (size != -1) return size;
size = 0;
- if (common_ != null) {
+ if (status_ != null) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(1, getCommon());
+ .computeMessageSize(1, getStatus());
}
if (minOffset_ != 0L) {
size += com.google.protobuf.CodedOutputStream
@@ -294,10 +294,10 @@ private static final long serialVersionUID = 0L;
}
apache.rocketmq.v2.PullMessageResponse other = (apache.rocketmq.v2.PullMessageResponse) obj;
- if (hasCommon() != other.hasCommon()) return false;
- if (hasCommon()) {
- if (!getCommon()
- .equals(other.getCommon())) return false;
+ if (hasStatus() != other.hasStatus()) return false;
+ if (hasStatus()) {
+ if (!getStatus()
+ .equals(other.getStatus())) return false;
}
if (getMinOffset()
!= other.getMinOffset()) return false;
@@ -318,9 +318,9 @@ private static final long serialVersionUID = 0L;
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
- if (hasCommon()) {
- hash = (37 * hash) + COMMON_FIELD_NUMBER;
- hash = (53 * hash) + getCommon().hashCode();
+ if (hasStatus()) {
+ hash = (37 * hash) + STATUS_FIELD_NUMBER;
+ hash = (53 * hash) + getStatus().hashCode();
}
hash = (37 * hash) + MIN_OFFSET_FIELD_NUMBER;
hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
@@ -469,11 +469,11 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public Builder clear() {
super.clear();
- if (commonBuilder_ == null) {
- common_ = null;
+ if (statusBuilder_ == null) {
+ status_ = null;
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
minOffset_ = 0L;
@@ -514,10 +514,10 @@ private static final long serialVersionUID = 0L;
public apache.rocketmq.v2.PullMessageResponse buildPartial() {
apache.rocketmq.v2.PullMessageResponse result = new apache.rocketmq.v2.PullMessageResponse(this);
int from_bitField0_ = bitField0_;
- if (commonBuilder_ == null) {
- result.common_ = common_;
+ if (statusBuilder_ == null) {
+ result.status_ = status_;
} else {
- result.common_ = commonBuilder_.build();
+ result.status_ = statusBuilder_.build();
}
result.minOffset_ = minOffset_;
result.nextOffset_ = nextOffset_;
@@ -579,8 +579,8 @@ private static final long serialVersionUID = 0L;
public Builder mergeFrom(apache.rocketmq.v2.PullMessageResponse other) {
if (other == apache.rocketmq.v2.PullMessageResponse.getDefaultInstance()) return this;
- if (other.hasCommon()) {
- mergeCommon(other.getCommon());
+ if (other.hasStatus()) {
+ mergeStatus(other.getStatus());
}
if (other.getMinOffset() != 0L) {
setMinOffset(other.getMinOffset());
@@ -647,123 +647,123 @@ private static final long serialVersionUID = 0L;
}
private int bitField0_;
- private apache.rocketmq.v2.ResponseCommon common_;
+ private apache.rocketmq.v2.Status status_;
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder> commonBuilder_;
+ apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> statusBuilder_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- public boolean hasCommon() {
- return commonBuilder_ != null || common_ != null;
+ public boolean hasStatus() {
+ return statusBuilder_ != null || status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- if (commonBuilder_ == null) {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ if (statusBuilder_ == null) {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
} else {
- return commonBuilder_.getMessage();
+ return statusBuilder_.getMessage();
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
+ public Builder setStatus(apache.rocketmq.v2.Status value) {
+ if (statusBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
- common_ = value;
+ status_ = value;
onChanged();
} else {
- commonBuilder_.setMessage(value);
+ statusBuilder_.setMessage(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(
- apache.rocketmq.v2.ResponseCommon.Builder builderForValue) {
- if (commonBuilder_ == null) {
- common_ = builderForValue.build();
+ public Builder setStatus(
+ apache.rocketmq.v2.Status.Builder builderForValue) {
+ if (statusBuilder_ == null) {
+ status_ = builderForValue.build();
onChanged();
} else {
- commonBuilder_.setMessage(builderForValue.build());
+ statusBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder mergeCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
- if (common_ != null) {
- common_ =
- apache.rocketmq.v2.ResponseCommon.newBuilder(common_).mergeFrom(value).buildPartial();
+ 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 {
- common_ = value;
+ status_ = value;
}
onChanged();
} else {
- commonBuilder_.mergeFrom(value);
+ statusBuilder_.mergeFrom(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder clearCommon() {
- if (commonBuilder_ == null) {
- common_ = null;
+ public Builder clearStatus() {
+ if (statusBuilder_ == null) {
+ status_ = null;
onChanged();
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommon.Builder getCommonBuilder() {
+ public apache.rocketmq.v2.Status.Builder getStatusBuilder() {
onChanged();
- return getCommonFieldBuilder().getBuilder();
+ return getStatusFieldBuilder().getBuilder();
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- if (commonBuilder_ != null) {
- return commonBuilder_.getMessageOrBuilder();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ if (statusBuilder_ != null) {
+ return statusBuilder_.getMessageOrBuilder();
} else {
- return common_ == null ?
- apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ return status_ == null ?
+ apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>
- getCommonFieldBuilder() {
- if (commonBuilder_ == null) {
- commonBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>(
- getCommon(),
+ 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());
- common_ = null;
+ status_ = null;
}
- return commonBuilder_;
+ return statusBuilder_;
}
private long minOffset_ ;
diff --git a/src/main/java/apache/rocketmq/v2/PullMessageResponseOrBuilder.java b/src/main/java/apache/rocketmq/v2/PullMessageResponseOrBuilder.java
index 6b7b741..55141f8 100644
--- a/src/main/java/apache/rocketmq/v2/PullMessageResponseOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/PullMessageResponseOrBuilder.java
@@ -8,19 +8,19 @@ public interface PullMessageResponseOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- boolean hasCommon();
+ boolean hasStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- apache.rocketmq.v2.ResponseCommon getCommon();
+ apache.rocketmq.v2.Status getStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder();
+ apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder();
/**
* <code>int64 min_offset = 2;</code>
diff --git a/src/main/java/apache/rocketmq/v2/QueryAssignmentResponse.java b/src/main/java/apache/rocketmq/v2/QueryAssignmentResponse.java
index b4bf3e1..1b87826 100644
--- a/src/main/java/apache/rocketmq/v2/QueryAssignmentResponse.java
+++ b/src/main/java/apache/rocketmq/v2/QueryAssignmentResponse.java
@@ -51,14 +51,14 @@ private static final long serialVersionUID = 0L;
done = true;
break;
case 10: {
- apache.rocketmq.v2.ResponseCommon.Builder subBuilder = null;
- if (common_ != null) {
- subBuilder = common_.toBuilder();
+ apache.rocketmq.v2.Status.Builder subBuilder = null;
+ if (status_ != null) {
+ subBuilder = status_.toBuilder();
}
- common_ = input.readMessage(apache.rocketmq.v2.ResponseCommon.parser(), extensionRegistry);
+ status_ = input.readMessage(apache.rocketmq.v2.Status.parser(), extensionRegistry);
if (subBuilder != null) {
- subBuilder.mergeFrom(common_);
- common_ = subBuilder.buildPartial();
+ subBuilder.mergeFrom(status_);
+ status_ = subBuilder.buildPartial();
}
break;
@@ -107,30 +107,30 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.QueryAssignmentResponse.class, apache.rocketmq.v2.QueryAssignmentResponse.Builder.class);
}
- public static final int COMMON_FIELD_NUMBER = 1;
- private apache.rocketmq.v2.ResponseCommon common_;
+ public static final int STATUS_FIELD_NUMBER = 1;
+ private apache.rocketmq.v2.Status status_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
@java.lang.Override
- public boolean hasCommon() {
- return common_ != null;
+ public boolean hasStatus() {
+ return status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- return getCommon();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ return getStatus();
}
public static final int ASSIGNMENTS_FIELD_NUMBER = 2;
@@ -187,8 +187,8 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
- if (common_ != null) {
- output.writeMessage(1, getCommon());
+ if (status_ != null) {
+ output.writeMessage(1, getStatus());
}
for (int i = 0; i < assignments_.size(); i++) {
output.writeMessage(2, assignments_.get(i));
@@ -202,9 +202,9 @@ private static final long serialVersionUID = 0L;
if (size != -1) return size;
size = 0;
- if (common_ != null) {
+ if (status_ != null) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(1, getCommon());
+ .computeMessageSize(1, getStatus());
}
for (int i = 0; i < assignments_.size(); i++) {
size += com.google.protobuf.CodedOutputStream
@@ -225,10 +225,10 @@ private static final long serialVersionUID = 0L;
}
apache.rocketmq.v2.QueryAssignmentResponse other = (apache.rocketmq.v2.QueryAssignmentResponse) obj;
- if (hasCommon() != other.hasCommon()) return false;
- if (hasCommon()) {
- if (!getCommon()
- .equals(other.getCommon())) return false;
+ if (hasStatus() != other.hasStatus()) return false;
+ if (hasStatus()) {
+ if (!getStatus()
+ .equals(other.getStatus())) return false;
}
if (!getAssignmentsList()
.equals(other.getAssignmentsList())) return false;
@@ -243,9 +243,9 @@ private static final long serialVersionUID = 0L;
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
- if (hasCommon()) {
- hash = (37 * hash) + COMMON_FIELD_NUMBER;
- hash = (53 * hash) + getCommon().hashCode();
+ if (hasStatus()) {
+ hash = (37 * hash) + STATUS_FIELD_NUMBER;
+ hash = (53 * hash) + getStatus().hashCode();
}
if (getAssignmentsCount() > 0) {
hash = (37 * hash) + ASSIGNMENTS_FIELD_NUMBER;
@@ -385,11 +385,11 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public Builder clear() {
super.clear();
- if (commonBuilder_ == null) {
- common_ = null;
+ if (statusBuilder_ == null) {
+ status_ = null;
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
if (assignmentsBuilder_ == null) {
assignments_ = java.util.Collections.emptyList();
@@ -424,10 +424,10 @@ private static final long serialVersionUID = 0L;
public apache.rocketmq.v2.QueryAssignmentResponse buildPartial() {
apache.rocketmq.v2.QueryAssignmentResponse result = new apache.rocketmq.v2.QueryAssignmentResponse(this);
int from_bitField0_ = bitField0_;
- if (commonBuilder_ == null) {
- result.common_ = common_;
+ if (statusBuilder_ == null) {
+ result.status_ = status_;
} else {
- result.common_ = commonBuilder_.build();
+ result.status_ = statusBuilder_.build();
}
if (assignmentsBuilder_ == null) {
if (((bitField0_ & 0x00000001) != 0)) {
@@ -486,8 +486,8 @@ private static final long serialVersionUID = 0L;
public Builder mergeFrom(apache.rocketmq.v2.QueryAssignmentResponse other) {
if (other == apache.rocketmq.v2.QueryAssignmentResponse.getDefaultInstance()) return this;
- if (other.hasCommon()) {
- mergeCommon(other.getCommon());
+ if (other.hasStatus()) {
+ mergeStatus(other.getStatus());
}
if (assignmentsBuilder_ == null) {
if (!other.assignments_.isEmpty()) {
@@ -545,123 +545,123 @@ private static final long serialVersionUID = 0L;
}
private int bitField0_;
- private apache.rocketmq.v2.ResponseCommon common_;
+ private apache.rocketmq.v2.Status status_;
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder> commonBuilder_;
+ apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> statusBuilder_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- public boolean hasCommon() {
- return commonBuilder_ != null || common_ != null;
+ public boolean hasStatus() {
+ return statusBuilder_ != null || status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- if (commonBuilder_ == null) {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ if (statusBuilder_ == null) {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
} else {
- return commonBuilder_.getMessage();
+ return statusBuilder_.getMessage();
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
+ public Builder setStatus(apache.rocketmq.v2.Status value) {
+ if (statusBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
- common_ = value;
+ status_ = value;
onChanged();
} else {
- commonBuilder_.setMessage(value);
+ statusBuilder_.setMessage(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(
- apache.rocketmq.v2.ResponseCommon.Builder builderForValue) {
- if (commonBuilder_ == null) {
- common_ = builderForValue.build();
+ public Builder setStatus(
+ apache.rocketmq.v2.Status.Builder builderForValue) {
+ if (statusBuilder_ == null) {
+ status_ = builderForValue.build();
onChanged();
} else {
- commonBuilder_.setMessage(builderForValue.build());
+ statusBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder mergeCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
- if (common_ != null) {
- common_ =
- apache.rocketmq.v2.ResponseCommon.newBuilder(common_).mergeFrom(value).buildPartial();
+ 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 {
- common_ = value;
+ status_ = value;
}
onChanged();
} else {
- commonBuilder_.mergeFrom(value);
+ statusBuilder_.mergeFrom(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder clearCommon() {
- if (commonBuilder_ == null) {
- common_ = null;
+ public Builder clearStatus() {
+ if (statusBuilder_ == null) {
+ status_ = null;
onChanged();
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommon.Builder getCommonBuilder() {
+ public apache.rocketmq.v2.Status.Builder getStatusBuilder() {
onChanged();
- return getCommonFieldBuilder().getBuilder();
+ return getStatusFieldBuilder().getBuilder();
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- if (commonBuilder_ != null) {
- return commonBuilder_.getMessageOrBuilder();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ if (statusBuilder_ != null) {
+ return statusBuilder_.getMessageOrBuilder();
} else {
- return common_ == null ?
- apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ return status_ == null ?
+ apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>
- getCommonFieldBuilder() {
- if (commonBuilder_ == null) {
- commonBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>(
- getCommon(),
+ 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());
- common_ = null;
+ status_ = null;
}
- return commonBuilder_;
+ return statusBuilder_;
}
private java.util.List<apache.rocketmq.v2.Assignment> assignments_ =
diff --git a/src/main/java/apache/rocketmq/v2/QueryAssignmentResponseOrBuilder.java b/src/main/java/apache/rocketmq/v2/QueryAssignmentResponseOrBuilder.java
index a4ce5f1..90034ae 100644
--- a/src/main/java/apache/rocketmq/v2/QueryAssignmentResponseOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/QueryAssignmentResponseOrBuilder.java
@@ -8,19 +8,19 @@ public interface QueryAssignmentResponseOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- boolean hasCommon();
+ boolean hasStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- apache.rocketmq.v2.ResponseCommon getCommon();
+ apache.rocketmq.v2.Status getStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder();
+ apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder();
/**
* <code>repeated .apache.rocketmq.v2.Assignment assignments = 2;</code>
diff --git a/src/main/java/apache/rocketmq/v2/QueryOffsetResponse.java b/src/main/java/apache/rocketmq/v2/QueryOffsetResponse.java
index 944e687..29f98c8 100644
--- a/src/main/java/apache/rocketmq/v2/QueryOffsetResponse.java
+++ b/src/main/java/apache/rocketmq/v2/QueryOffsetResponse.java
@@ -49,14 +49,14 @@ private static final long serialVersionUID = 0L;
done = true;
break;
case 10: {
- apache.rocketmq.v2.ResponseCommon.Builder subBuilder = null;
- if (common_ != null) {
- subBuilder = common_.toBuilder();
+ apache.rocketmq.v2.Status.Builder subBuilder = null;
+ if (status_ != null) {
+ subBuilder = status_.toBuilder();
}
- common_ = input.readMessage(apache.rocketmq.v2.ResponseCommon.parser(), extensionRegistry);
+ status_ = input.readMessage(apache.rocketmq.v2.Status.parser(), extensionRegistry);
if (subBuilder != null) {
- subBuilder.mergeFrom(common_);
- common_ = subBuilder.buildPartial();
+ subBuilder.mergeFrom(status_);
+ status_ = subBuilder.buildPartial();
}
break;
@@ -98,30 +98,30 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.QueryOffsetResponse.class, apache.rocketmq.v2.QueryOffsetResponse.Builder.class);
}
- public static final int COMMON_FIELD_NUMBER = 1;
- private apache.rocketmq.v2.ResponseCommon common_;
+ public static final int STATUS_FIELD_NUMBER = 1;
+ private apache.rocketmq.v2.Status status_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
@java.lang.Override
- public boolean hasCommon() {
- return common_ != null;
+ public boolean hasStatus() {
+ return status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- return getCommon();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ return getStatus();
}
public static final int OFFSET_FIELD_NUMBER = 2;
@@ -149,8 +149,8 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
- if (common_ != null) {
- output.writeMessage(1, getCommon());
+ if (status_ != null) {
+ output.writeMessage(1, getStatus());
}
if (offset_ != 0L) {
output.writeInt64(2, offset_);
@@ -164,9 +164,9 @@ private static final long serialVersionUID = 0L;
if (size != -1) return size;
size = 0;
- if (common_ != null) {
+ if (status_ != null) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(1, getCommon());
+ .computeMessageSize(1, getStatus());
}
if (offset_ != 0L) {
size += com.google.protobuf.CodedOutputStream
@@ -187,10 +187,10 @@ private static final long serialVersionUID = 0L;
}
apache.rocketmq.v2.QueryOffsetResponse other = (apache.rocketmq.v2.QueryOffsetResponse) obj;
- if (hasCommon() != other.hasCommon()) return false;
- if (hasCommon()) {
- if (!getCommon()
- .equals(other.getCommon())) return false;
+ if (hasStatus() != other.hasStatus()) return false;
+ if (hasStatus()) {
+ if (!getStatus()
+ .equals(other.getStatus())) return false;
}
if (getOffset()
!= other.getOffset()) return false;
@@ -205,9 +205,9 @@ private static final long serialVersionUID = 0L;
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
- if (hasCommon()) {
- hash = (37 * hash) + COMMON_FIELD_NUMBER;
- hash = (53 * hash) + getCommon().hashCode();
+ if (hasStatus()) {
+ hash = (37 * hash) + STATUS_FIELD_NUMBER;
+ hash = (53 * hash) + getStatus().hashCode();
}
hash = (37 * hash) + OFFSET_FIELD_NUMBER;
hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
@@ -345,11 +345,11 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public Builder clear() {
super.clear();
- if (commonBuilder_ == null) {
- common_ = null;
+ if (statusBuilder_ == null) {
+ status_ = null;
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
offset_ = 0L;
@@ -379,10 +379,10 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public apache.rocketmq.v2.QueryOffsetResponse buildPartial() {
apache.rocketmq.v2.QueryOffsetResponse result = new apache.rocketmq.v2.QueryOffsetResponse(this);
- if (commonBuilder_ == null) {
- result.common_ = common_;
+ if (statusBuilder_ == null) {
+ result.status_ = status_;
} else {
- result.common_ = commonBuilder_.build();
+ result.status_ = statusBuilder_.build();
}
result.offset_ = offset_;
onBuilt();
@@ -433,8 +433,8 @@ private static final long serialVersionUID = 0L;
public Builder mergeFrom(apache.rocketmq.v2.QueryOffsetResponse other) {
if (other == apache.rocketmq.v2.QueryOffsetResponse.getDefaultInstance()) return this;
- if (other.hasCommon()) {
- mergeCommon(other.getCommon());
+ if (other.hasStatus()) {
+ mergeStatus(other.getStatus());
}
if (other.getOffset() != 0L) {
setOffset(other.getOffset());
@@ -468,123 +468,123 @@ private static final long serialVersionUID = 0L;
return this;
}
- private apache.rocketmq.v2.ResponseCommon common_;
+ private apache.rocketmq.v2.Status status_;
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder> commonBuilder_;
+ apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> statusBuilder_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- public boolean hasCommon() {
- return commonBuilder_ != null || common_ != null;
+ public boolean hasStatus() {
+ return statusBuilder_ != null || status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- if (commonBuilder_ == null) {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ if (statusBuilder_ == null) {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
} else {
- return commonBuilder_.getMessage();
+ return statusBuilder_.getMessage();
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
+ public Builder setStatus(apache.rocketmq.v2.Status value) {
+ if (statusBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
- common_ = value;
+ status_ = value;
onChanged();
} else {
- commonBuilder_.setMessage(value);
+ statusBuilder_.setMessage(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(
- apache.rocketmq.v2.ResponseCommon.Builder builderForValue) {
- if (commonBuilder_ == null) {
- common_ = builderForValue.build();
+ public Builder setStatus(
+ apache.rocketmq.v2.Status.Builder builderForValue) {
+ if (statusBuilder_ == null) {
+ status_ = builderForValue.build();
onChanged();
} else {
- commonBuilder_.setMessage(builderForValue.build());
+ statusBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder mergeCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
- if (common_ != null) {
- common_ =
- apache.rocketmq.v2.ResponseCommon.newBuilder(common_).mergeFrom(value).buildPartial();
+ 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 {
- common_ = value;
+ status_ = value;
}
onChanged();
} else {
- commonBuilder_.mergeFrom(value);
+ statusBuilder_.mergeFrom(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder clearCommon() {
- if (commonBuilder_ == null) {
- common_ = null;
+ public Builder clearStatus() {
+ if (statusBuilder_ == null) {
+ status_ = null;
onChanged();
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommon.Builder getCommonBuilder() {
+ public apache.rocketmq.v2.Status.Builder getStatusBuilder() {
onChanged();
- return getCommonFieldBuilder().getBuilder();
+ return getStatusFieldBuilder().getBuilder();
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- if (commonBuilder_ != null) {
- return commonBuilder_.getMessageOrBuilder();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ if (statusBuilder_ != null) {
+ return statusBuilder_.getMessageOrBuilder();
} else {
- return common_ == null ?
- apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ return status_ == null ?
+ apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>
- getCommonFieldBuilder() {
- if (commonBuilder_ == null) {
- commonBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>(
- getCommon(),
+ 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());
- common_ = null;
+ status_ = null;
}
- return commonBuilder_;
+ return statusBuilder_;
}
private long offset_ ;
diff --git a/src/main/java/apache/rocketmq/v2/QueryOffsetResponseOrBuilder.java b/src/main/java/apache/rocketmq/v2/QueryOffsetResponseOrBuilder.java
index 76948e9..0a53cff 100644
--- a/src/main/java/apache/rocketmq/v2/QueryOffsetResponseOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/QueryOffsetResponseOrBuilder.java
@@ -8,19 +8,19 @@ public interface QueryOffsetResponseOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- boolean hasCommon();
+ boolean hasStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- apache.rocketmq.v2.ResponseCommon getCommon();
+ apache.rocketmq.v2.Status getStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder();
+ apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder();
/**
* <code>int64 offset = 2;</code>
diff --git a/src/main/java/apache/rocketmq/v2/QueryRouteResponse.java b/src/main/java/apache/rocketmq/v2/QueryRouteResponse.java
index db0cefc..0b56b7b 100644
--- a/src/main/java/apache/rocketmq/v2/QueryRouteResponse.java
+++ b/src/main/java/apache/rocketmq/v2/QueryRouteResponse.java
@@ -51,14 +51,14 @@ private static final long serialVersionUID = 0L;
done = true;
break;
case 10: {
- apache.rocketmq.v2.ResponseCommon.Builder subBuilder = null;
- if (common_ != null) {
- subBuilder = common_.toBuilder();
+ apache.rocketmq.v2.Status.Builder subBuilder = null;
+ if (status_ != null) {
+ subBuilder = status_.toBuilder();
}
- common_ = input.readMessage(apache.rocketmq.v2.ResponseCommon.parser(), extensionRegistry);
+ status_ = input.readMessage(apache.rocketmq.v2.Status.parser(), extensionRegistry);
if (subBuilder != null) {
- subBuilder.mergeFrom(common_);
- common_ = subBuilder.buildPartial();
+ subBuilder.mergeFrom(status_);
+ status_ = subBuilder.buildPartial();
}
break;
@@ -107,30 +107,30 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.QueryRouteResponse.class, apache.rocketmq.v2.QueryRouteResponse.Builder.class);
}
- public static final int COMMON_FIELD_NUMBER = 1;
- private apache.rocketmq.v2.ResponseCommon common_;
+ public static final int STATUS_FIELD_NUMBER = 1;
+ private apache.rocketmq.v2.Status status_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
@java.lang.Override
- public boolean hasCommon() {
- return common_ != null;
+ public boolean hasStatus() {
+ return status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- return getCommon();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ return getStatus();
}
public static final int MESSAGE_QUEUES_FIELD_NUMBER = 2;
@@ -187,8 +187,8 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
- if (common_ != null) {
- output.writeMessage(1, getCommon());
+ if (status_ != null) {
+ output.writeMessage(1, getStatus());
}
for (int i = 0; i < messageQueues_.size(); i++) {
output.writeMessage(2, messageQueues_.get(i));
@@ -202,9 +202,9 @@ private static final long serialVersionUID = 0L;
if (size != -1) return size;
size = 0;
- if (common_ != null) {
+ if (status_ != null) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(1, getCommon());
+ .computeMessageSize(1, getStatus());
}
for (int i = 0; i < messageQueues_.size(); i++) {
size += com.google.protobuf.CodedOutputStream
@@ -225,10 +225,10 @@ private static final long serialVersionUID = 0L;
}
apache.rocketmq.v2.QueryRouteResponse other = (apache.rocketmq.v2.QueryRouteResponse) obj;
- if (hasCommon() != other.hasCommon()) return false;
- if (hasCommon()) {
- if (!getCommon()
- .equals(other.getCommon())) return false;
+ if (hasStatus() != other.hasStatus()) return false;
+ if (hasStatus()) {
+ if (!getStatus()
+ .equals(other.getStatus())) return false;
}
if (!getMessageQueuesList()
.equals(other.getMessageQueuesList())) return false;
@@ -243,9 +243,9 @@ private static final long serialVersionUID = 0L;
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
- if (hasCommon()) {
- hash = (37 * hash) + COMMON_FIELD_NUMBER;
- hash = (53 * hash) + getCommon().hashCode();
+ if (hasStatus()) {
+ hash = (37 * hash) + STATUS_FIELD_NUMBER;
+ hash = (53 * hash) + getStatus().hashCode();
}
if (getMessageQueuesCount() > 0) {
hash = (37 * hash) + MESSAGE_QUEUES_FIELD_NUMBER;
@@ -385,11 +385,11 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public Builder clear() {
super.clear();
- if (commonBuilder_ == null) {
- common_ = null;
+ if (statusBuilder_ == null) {
+ status_ = null;
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
if (messageQueuesBuilder_ == null) {
messageQueues_ = java.util.Collections.emptyList();
@@ -424,10 +424,10 @@ private static final long serialVersionUID = 0L;
public apache.rocketmq.v2.QueryRouteResponse buildPartial() {
apache.rocketmq.v2.QueryRouteResponse result = new apache.rocketmq.v2.QueryRouteResponse(this);
int from_bitField0_ = bitField0_;
- if (commonBuilder_ == null) {
- result.common_ = common_;
+ if (statusBuilder_ == null) {
+ result.status_ = status_;
} else {
- result.common_ = commonBuilder_.build();
+ result.status_ = statusBuilder_.build();
}
if (messageQueuesBuilder_ == null) {
if (((bitField0_ & 0x00000001) != 0)) {
@@ -486,8 +486,8 @@ private static final long serialVersionUID = 0L;
public Builder mergeFrom(apache.rocketmq.v2.QueryRouteResponse other) {
if (other == apache.rocketmq.v2.QueryRouteResponse.getDefaultInstance()) return this;
- if (other.hasCommon()) {
- mergeCommon(other.getCommon());
+ if (other.hasStatus()) {
+ mergeStatus(other.getStatus());
}
if (messageQueuesBuilder_ == null) {
if (!other.messageQueues_.isEmpty()) {
@@ -545,123 +545,123 @@ private static final long serialVersionUID = 0L;
}
private int bitField0_;
- private apache.rocketmq.v2.ResponseCommon common_;
+ private apache.rocketmq.v2.Status status_;
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder> commonBuilder_;
+ apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> statusBuilder_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- public boolean hasCommon() {
- return commonBuilder_ != null || common_ != null;
+ public boolean hasStatus() {
+ return statusBuilder_ != null || status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- if (commonBuilder_ == null) {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ if (statusBuilder_ == null) {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
} else {
- return commonBuilder_.getMessage();
+ return statusBuilder_.getMessage();
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
+ public Builder setStatus(apache.rocketmq.v2.Status value) {
+ if (statusBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
- common_ = value;
+ status_ = value;
onChanged();
} else {
- commonBuilder_.setMessage(value);
+ statusBuilder_.setMessage(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(
- apache.rocketmq.v2.ResponseCommon.Builder builderForValue) {
- if (commonBuilder_ == null) {
- common_ = builderForValue.build();
+ public Builder setStatus(
+ apache.rocketmq.v2.Status.Builder builderForValue) {
+ if (statusBuilder_ == null) {
+ status_ = builderForValue.build();
onChanged();
} else {
- commonBuilder_.setMessage(builderForValue.build());
+ statusBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder mergeCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
- if (common_ != null) {
- common_ =
- apache.rocketmq.v2.ResponseCommon.newBuilder(common_).mergeFrom(value).buildPartial();
+ 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 {
- common_ = value;
+ status_ = value;
}
onChanged();
} else {
- commonBuilder_.mergeFrom(value);
+ statusBuilder_.mergeFrom(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder clearCommon() {
- if (commonBuilder_ == null) {
- common_ = null;
+ public Builder clearStatus() {
+ if (statusBuilder_ == null) {
+ status_ = null;
onChanged();
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommon.Builder getCommonBuilder() {
+ public apache.rocketmq.v2.Status.Builder getStatusBuilder() {
onChanged();
- return getCommonFieldBuilder().getBuilder();
+ return getStatusFieldBuilder().getBuilder();
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- if (commonBuilder_ != null) {
- return commonBuilder_.getMessageOrBuilder();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ if (statusBuilder_ != null) {
+ return statusBuilder_.getMessageOrBuilder();
} else {
- return common_ == null ?
- apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ return status_ == null ?
+ apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>
- getCommonFieldBuilder() {
- if (commonBuilder_ == null) {
- commonBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>(
- getCommon(),
+ 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());
- common_ = null;
+ status_ = null;
}
- return commonBuilder_;
+ return statusBuilder_;
}
private java.util.List<apache.rocketmq.v2.MessageQueue> messageQueues_ =
diff --git a/src/main/java/apache/rocketmq/v2/QueryRouteResponseOrBuilder.java b/src/main/java/apache/rocketmq/v2/QueryRouteResponseOrBuilder.java
index 3775a42..48bc953 100644
--- a/src/main/java/apache/rocketmq/v2/QueryRouteResponseOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/QueryRouteResponseOrBuilder.java
@@ -8,19 +8,19 @@ public interface QueryRouteResponseOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- boolean hasCommon();
+ boolean hasStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- apache.rocketmq.v2.ResponseCommon getCommon();
+ apache.rocketmq.v2.Status getStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder();
+ apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder();
/**
* <code>repeated .apache.rocketmq.v2.MessageQueue message_queues = 2;</code>
diff --git a/src/main/java/apache/rocketmq/v2/ReceiveMessageResponse.java b/src/main/java/apache/rocketmq/v2/ReceiveMessageResponse.java
index e09efe7..2c2a19d 100644
--- a/src/main/java/apache/rocketmq/v2/ReceiveMessageResponse.java
+++ b/src/main/java/apache/rocketmq/v2/ReceiveMessageResponse.java
@@ -51,14 +51,14 @@ private static final long serialVersionUID = 0L;
done = true;
break;
case 10: {
- apache.rocketmq.v2.ResponseCommon.Builder subBuilder = null;
- if (common_ != null) {
- subBuilder = common_.toBuilder();
+ apache.rocketmq.v2.Status.Builder subBuilder = null;
+ if (status_ != null) {
+ subBuilder = status_.toBuilder();
}
- common_ = input.readMessage(apache.rocketmq.v2.ResponseCommon.parser(), extensionRegistry);
+ status_ = input.readMessage(apache.rocketmq.v2.Status.parser(), extensionRegistry);
if (subBuilder != null) {
- subBuilder.mergeFrom(common_);
- common_ = subBuilder.buildPartial();
+ subBuilder.mergeFrom(status_);
+ status_ = subBuilder.buildPartial();
}
break;
@@ -133,30 +133,30 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.ReceiveMessageResponse.class, apache.rocketmq.v2.ReceiveMessageResponse.Builder.class);
}
- public static final int COMMON_FIELD_NUMBER = 1;
- private apache.rocketmq.v2.ResponseCommon common_;
+ public static final int STATUS_FIELD_NUMBER = 1;
+ private apache.rocketmq.v2.Status status_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
@java.lang.Override
- public boolean hasCommon() {
- return common_ != null;
+ public boolean hasStatus() {
+ return status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- return getCommon();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ return getStatus();
}
public static final int MESSAGES_FIELD_NUMBER = 2;
@@ -265,8 +265,8 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
- if (common_ != null) {
- output.writeMessage(1, getCommon());
+ if (status_ != null) {
+ output.writeMessage(1, getStatus());
}
for (int i = 0; i < messages_.size(); i++) {
output.writeMessage(2, messages_.get(i));
@@ -286,9 +286,9 @@ private static final long serialVersionUID = 0L;
if (size != -1) return size;
size = 0;
- if (common_ != null) {
+ if (status_ != null) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(1, getCommon());
+ .computeMessageSize(1, getStatus());
}
for (int i = 0; i < messages_.size(); i++) {
size += com.google.protobuf.CodedOutputStream
@@ -317,10 +317,10 @@ private static final long serialVersionUID = 0L;
}
apache.rocketmq.v2.ReceiveMessageResponse other = (apache.rocketmq.v2.ReceiveMessageResponse) obj;
- if (hasCommon() != other.hasCommon()) return false;
- if (hasCommon()) {
- if (!getCommon()
- .equals(other.getCommon())) return false;
+ if (hasStatus() != other.hasStatus()) return false;
+ if (hasStatus()) {
+ if (!getStatus()
+ .equals(other.getStatus())) return false;
}
if (!getMessagesList()
.equals(other.getMessagesList())) return false;
@@ -345,9 +345,9 @@ private static final long serialVersionUID = 0L;
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
- if (hasCommon()) {
- hash = (37 * hash) + COMMON_FIELD_NUMBER;
- hash = (53 * hash) + getCommon().hashCode();
+ if (hasStatus()) {
+ hash = (37 * hash) + STATUS_FIELD_NUMBER;
+ hash = (53 * hash) + getStatus().hashCode();
}
if (getMessagesCount() > 0) {
hash = (37 * hash) + MESSAGES_FIELD_NUMBER;
@@ -495,11 +495,11 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public Builder clear() {
super.clear();
- if (commonBuilder_ == null) {
- common_ = null;
+ if (statusBuilder_ == null) {
+ status_ = null;
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
if (messagesBuilder_ == null) {
messages_ = java.util.Collections.emptyList();
@@ -546,10 +546,10 @@ private static final long serialVersionUID = 0L;
public apache.rocketmq.v2.ReceiveMessageResponse buildPartial() {
apache.rocketmq.v2.ReceiveMessageResponse result = new apache.rocketmq.v2.ReceiveMessageResponse(this);
int from_bitField0_ = bitField0_;
- if (commonBuilder_ == null) {
- result.common_ = common_;
+ if (statusBuilder_ == null) {
+ result.status_ = status_;
} else {
- result.common_ = commonBuilder_.build();
+ result.status_ = statusBuilder_.build();
}
if (messagesBuilder_ == null) {
if (((bitField0_ & 0x00000001) != 0)) {
@@ -618,8 +618,8 @@ private static final long serialVersionUID = 0L;
public Builder mergeFrom(apache.rocketmq.v2.ReceiveMessageResponse other) {
if (other == apache.rocketmq.v2.ReceiveMessageResponse.getDefaultInstance()) return this;
- if (other.hasCommon()) {
- mergeCommon(other.getCommon());
+ if (other.hasStatus()) {
+ mergeStatus(other.getStatus());
}
if (messagesBuilder_ == null) {
if (!other.messages_.isEmpty()) {
@@ -683,123 +683,123 @@ private static final long serialVersionUID = 0L;
}
private int bitField0_;
- private apache.rocketmq.v2.ResponseCommon common_;
+ private apache.rocketmq.v2.Status status_;
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder> commonBuilder_;
+ apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> statusBuilder_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- public boolean hasCommon() {
- return commonBuilder_ != null || common_ != null;
+ public boolean hasStatus() {
+ return statusBuilder_ != null || status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- if (commonBuilder_ == null) {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ if (statusBuilder_ == null) {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
} else {
- return commonBuilder_.getMessage();
+ return statusBuilder_.getMessage();
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
+ public Builder setStatus(apache.rocketmq.v2.Status value) {
+ if (statusBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
- common_ = value;
+ status_ = value;
onChanged();
} else {
- commonBuilder_.setMessage(value);
+ statusBuilder_.setMessage(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(
- apache.rocketmq.v2.ResponseCommon.Builder builderForValue) {
- if (commonBuilder_ == null) {
- common_ = builderForValue.build();
+ public Builder setStatus(
+ apache.rocketmq.v2.Status.Builder builderForValue) {
+ if (statusBuilder_ == null) {
+ status_ = builderForValue.build();
onChanged();
} else {
- commonBuilder_.setMessage(builderForValue.build());
+ statusBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder mergeCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
- if (common_ != null) {
- common_ =
- apache.rocketmq.v2.ResponseCommon.newBuilder(common_).mergeFrom(value).buildPartial();
+ 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 {
- common_ = value;
+ status_ = value;
}
onChanged();
} else {
- commonBuilder_.mergeFrom(value);
+ statusBuilder_.mergeFrom(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder clearCommon() {
- if (commonBuilder_ == null) {
- common_ = null;
+ public Builder clearStatus() {
+ if (statusBuilder_ == null) {
+ status_ = null;
onChanged();
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommon.Builder getCommonBuilder() {
+ public apache.rocketmq.v2.Status.Builder getStatusBuilder() {
onChanged();
- return getCommonFieldBuilder().getBuilder();
+ return getStatusFieldBuilder().getBuilder();
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- if (commonBuilder_ != null) {
- return commonBuilder_.getMessageOrBuilder();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ if (statusBuilder_ != null) {
+ return statusBuilder_.getMessageOrBuilder();
} else {
- return common_ == null ?
- apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ return status_ == null ?
+ apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>
- getCommonFieldBuilder() {
- if (commonBuilder_ == null) {
- commonBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>(
- getCommon(),
+ 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());
- common_ = null;
+ status_ = null;
}
- return commonBuilder_;
+ return statusBuilder_;
}
private java.util.List<apache.rocketmq.v2.Message> messages_ =
diff --git a/src/main/java/apache/rocketmq/v2/ReceiveMessageResponseOrBuilder.java b/src/main/java/apache/rocketmq/v2/ReceiveMessageResponseOrBuilder.java
index eae52d8..4502816 100644
--- a/src/main/java/apache/rocketmq/v2/ReceiveMessageResponseOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/ReceiveMessageResponseOrBuilder.java
@@ -8,19 +8,19 @@ public interface ReceiveMessageResponseOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- boolean hasCommon();
+ boolean hasStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- apache.rocketmq.v2.ResponseCommon getCommon();
+ apache.rocketmq.v2.Status getStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder();
+ apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder();
/**
* <code>repeated .apache.rocketmq.v2.Message messages = 2;</code>
diff --git a/src/main/java/apache/rocketmq/v2/ResponseCode.java b/src/main/java/apache/rocketmq/v2/ResponseCode.java
index 719b6e3..101254c 100644
--- a/src/main/java/apache/rocketmq/v2/ResponseCode.java
+++ b/src/main/java/apache/rocketmq/v2/ResponseCode.java
@@ -18,7 +18,7 @@ public enum ResponseCode
OK(0),
/**
* <pre>
- * Aceess point in not specified in request.
+ * Format of access point is illegal.
* </pre>
*
* <code>ILLEGAL_ACCESS_POINT = 1;</code>
@@ -130,15 +130,15 @@ public enum ResponseCode
CONSUMER_GROUP_DOES_NOT_EXIST(14),
/**
* <pre>
- * Current operation is not supported by responder.
+ * Not allowed to verify message.
* </pre>
*
- * <code>OPERATION_NOT_SUPPORTED = 15;</code>
+ * <code>VERIFY_MESSAGE_NOT_ALLOWED = 15;</code>
*/
- OPERATION_NOT_SUPPORTED(15),
+ VERIFY_MESSAGE_NOT_ALLOWED(15),
/**
* <pre>
- * Failure to consume message.
+ * Failed to consume message.
* </pre>
*
* <code>FAILED_TO_CONSUME_MESSAGE = 16;</code>
@@ -157,25 +157,25 @@ public enum ResponseCode
* Flow control.
* </pre>
*
- * <code>FLOW_CONTROL = 18;</code>
+ * <code>REQUEST_FLOW_CONTROL = 18;</code>
*/
- FLOW_CONTROL(18),
+ REQUEST_FLOW_CONTROL(18),
/**
* <pre>
- * Request is expired.
+ * Ack request is expired.
* </pre>
*
- * <code>REQUEST_EXPIRED = 19;</code>
+ * <code>ACKNOWLEDGEMENT_EXPIRED = 19;</code>
*/
- REQUEST_EXPIRED(19),
+ ACKNOWLEDGEMENT_EXPIRED(19),
/**
* <pre>
- * Message type is not matched.
+ * Message property is not match the message type.
* </pre>
*
- * <code>MESSAGE_TYPE_NOT_MATCHED = 20;</code>
+ * <code>MESSAGE_PROPERTY_DOES_NOT_MATCH_MESSAGE_TYPE = 20;</code>
*/
- MESSAGE_TYPE_NOT_MATCHED(20),
+ MESSAGE_PROPERTY_DOES_NOT_MATCH_MESSAGE_TYPE(20),
UNRECOGNIZED(-1),
;
@@ -189,7 +189,7 @@ public enum ResponseCode
public static final int OK_VALUE = 0;
/**
* <pre>
- * Aceess point in not specified in request.
+ * Format of access point is illegal.
* </pre>
*
* <code>ILLEGAL_ACCESS_POINT = 1;</code>
@@ -301,15 +301,15 @@ public enum ResponseCode
public static final int CONSUMER_GROUP_DOES_NOT_EXIST_VALUE = 14;
/**
* <pre>
- * Current operation is not supported by responder.
+ * Not allowed to verify message.
* </pre>
*
- * <code>OPERATION_NOT_SUPPORTED = 15;</code>
+ * <code>VERIFY_MESSAGE_NOT_ALLOWED = 15;</code>
*/
- public static final int OPERATION_NOT_SUPPORTED_VALUE = 15;
+ public static final int VERIFY_MESSAGE_NOT_ALLOWED_VALUE = 15;
/**
* <pre>
- * Failure to consume message.
+ * Failed to consume message.
* </pre>
*
* <code>FAILED_TO_CONSUME_MESSAGE = 16;</code>
@@ -328,25 +328,25 @@ public enum ResponseCode
* Flow control.
* </pre>
*
- * <code>FLOW_CONTROL = 18;</code>
+ * <code>REQUEST_FLOW_CONTROL = 18;</code>
*/
- public static final int FLOW_CONTROL_VALUE = 18;
+ public static final int REQUEST_FLOW_CONTROL_VALUE = 18;
/**
* <pre>
- * Request is expired.
+ * Ack request is expired.
* </pre>
*
- * <code>REQUEST_EXPIRED = 19;</code>
+ * <code>ACKNOWLEDGEMENT_EXPIRED = 19;</code>
*/
- public static final int REQUEST_EXPIRED_VALUE = 19;
+ public static final int ACKNOWLEDGEMENT_EXPIRED_VALUE = 19;
/**
* <pre>
- * Message type is not matched.
+ * Message property is not match the message type.
* </pre>
*
- * <code>MESSAGE_TYPE_NOT_MATCHED = 20;</code>
+ * <code>MESSAGE_PROPERTY_DOES_NOT_MATCH_MESSAGE_TYPE = 20;</code>
*/
- public static final int MESSAGE_TYPE_NOT_MATCHED_VALUE = 20;
+ public static final int MESSAGE_PROPERTY_DOES_NOT_MATCH_MESSAGE_TYPE_VALUE = 20;
public final int getNumber() {
@@ -388,12 +388,12 @@ public enum ResponseCode
case 12: return REQUEST_AUTHENTICATION_FAILURE;
case 13: return TOPIC_DOES_NOT_EXIST;
case 14: return CONSUMER_GROUP_DOES_NOT_EXIST;
- case 15: return OPERATION_NOT_SUPPORTED;
+ case 15: return VERIFY_MESSAGE_NOT_ALLOWED;
case 16: return FAILED_TO_CONSUME_MESSAGE;
case 17: return MESSAGE_CORRUPTED;
- case 18: return FLOW_CONTROL;
- case 19: return REQUEST_EXPIRED;
- case 20: return MESSAGE_TYPE_NOT_MATCHED;
+ case 18: return REQUEST_FLOW_CONTROL;
+ case 19: return ACKNOWLEDGEMENT_EXPIRED;
+ case 20: return MESSAGE_PROPERTY_DOES_NOT_MATCH_MESSAGE_TYPE;
default: return null;
}
}
diff --git a/src/main/java/apache/rocketmq/v2/SendMessageResponse.java b/src/main/java/apache/rocketmq/v2/SendMessageResponse.java
index cd80ba0..5caa899 100644
--- a/src/main/java/apache/rocketmq/v2/SendMessageResponse.java
+++ b/src/main/java/apache/rocketmq/v2/SendMessageResponse.java
@@ -51,14 +51,14 @@ private static final long serialVersionUID = 0L;
done = true;
break;
case 10: {
- apache.rocketmq.v2.ResponseCommon.Builder subBuilder = null;
- if (common_ != null) {
- subBuilder = common_.toBuilder();
+ apache.rocketmq.v2.Status.Builder subBuilder = null;
+ if (status_ != null) {
+ subBuilder = status_.toBuilder();
}
- common_ = input.readMessage(apache.rocketmq.v2.ResponseCommon.parser(), extensionRegistry);
+ status_ = input.readMessage(apache.rocketmq.v2.Status.parser(), extensionRegistry);
if (subBuilder != null) {
- subBuilder.mergeFrom(common_);
- common_ = subBuilder.buildPartial();
+ subBuilder.mergeFrom(status_);
+ status_ = subBuilder.buildPartial();
}
break;
@@ -107,30 +107,30 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.SendMessageResponse.class, apache.rocketmq.v2.SendMessageResponse.Builder.class);
}
- public static final int COMMON_FIELD_NUMBER = 1;
- private apache.rocketmq.v2.ResponseCommon common_;
+ public static final int STATUS_FIELD_NUMBER = 1;
+ private apache.rocketmq.v2.Status status_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
@java.lang.Override
- public boolean hasCommon() {
- return common_ != null;
+ public boolean hasStatus() {
+ return status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- return getCommon();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ return getStatus();
}
public static final int RECEIPTS_FIELD_NUMBER = 2;
@@ -187,8 +187,8 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
- if (common_ != null) {
- output.writeMessage(1, getCommon());
+ if (status_ != null) {
+ output.writeMessage(1, getStatus());
}
for (int i = 0; i < receipts_.size(); i++) {
output.writeMessage(2, receipts_.get(i));
@@ -202,9 +202,9 @@ private static final long serialVersionUID = 0L;
if (size != -1) return size;
size = 0;
- if (common_ != null) {
+ if (status_ != null) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(1, getCommon());
+ .computeMessageSize(1, getStatus());
}
for (int i = 0; i < receipts_.size(); i++) {
size += com.google.protobuf.CodedOutputStream
@@ -225,10 +225,10 @@ private static final long serialVersionUID = 0L;
}
apache.rocketmq.v2.SendMessageResponse other = (apache.rocketmq.v2.SendMessageResponse) obj;
- if (hasCommon() != other.hasCommon()) return false;
- if (hasCommon()) {
- if (!getCommon()
- .equals(other.getCommon())) return false;
+ if (hasStatus() != other.hasStatus()) return false;
+ if (hasStatus()) {
+ if (!getStatus()
+ .equals(other.getStatus())) return false;
}
if (!getReceiptsList()
.equals(other.getReceiptsList())) return false;
@@ -243,9 +243,9 @@ private static final long serialVersionUID = 0L;
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
- if (hasCommon()) {
- hash = (37 * hash) + COMMON_FIELD_NUMBER;
- hash = (53 * hash) + getCommon().hashCode();
+ if (hasStatus()) {
+ hash = (37 * hash) + STATUS_FIELD_NUMBER;
+ hash = (53 * hash) + getStatus().hashCode();
}
if (getReceiptsCount() > 0) {
hash = (37 * hash) + RECEIPTS_FIELD_NUMBER;
@@ -385,11 +385,11 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public Builder clear() {
super.clear();
- if (commonBuilder_ == null) {
- common_ = null;
+ if (statusBuilder_ == null) {
+ status_ = null;
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
if (receiptsBuilder_ == null) {
receipts_ = java.util.Collections.emptyList();
@@ -424,10 +424,10 @@ private static final long serialVersionUID = 0L;
public apache.rocketmq.v2.SendMessageResponse buildPartial() {
apache.rocketmq.v2.SendMessageResponse result = new apache.rocketmq.v2.SendMessageResponse(this);
int from_bitField0_ = bitField0_;
- if (commonBuilder_ == null) {
- result.common_ = common_;
+ if (statusBuilder_ == null) {
+ result.status_ = status_;
} else {
- result.common_ = commonBuilder_.build();
+ result.status_ = statusBuilder_.build();
}
if (receiptsBuilder_ == null) {
if (((bitField0_ & 0x00000001) != 0)) {
@@ -486,8 +486,8 @@ private static final long serialVersionUID = 0L;
public Builder mergeFrom(apache.rocketmq.v2.SendMessageResponse other) {
if (other == apache.rocketmq.v2.SendMessageResponse.getDefaultInstance()) return this;
- if (other.hasCommon()) {
- mergeCommon(other.getCommon());
+ if (other.hasStatus()) {
+ mergeStatus(other.getStatus());
}
if (receiptsBuilder_ == null) {
if (!other.receipts_.isEmpty()) {
@@ -545,123 +545,123 @@ private static final long serialVersionUID = 0L;
}
private int bitField0_;
- private apache.rocketmq.v2.ResponseCommon common_;
+ private apache.rocketmq.v2.Status status_;
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder> commonBuilder_;
+ apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> statusBuilder_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- public boolean hasCommon() {
- return commonBuilder_ != null || common_ != null;
+ public boolean hasStatus() {
+ return statusBuilder_ != null || status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- if (commonBuilder_ == null) {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ if (statusBuilder_ == null) {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
} else {
- return commonBuilder_.getMessage();
+ return statusBuilder_.getMessage();
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
+ public Builder setStatus(apache.rocketmq.v2.Status value) {
+ if (statusBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
- common_ = value;
+ status_ = value;
onChanged();
} else {
- commonBuilder_.setMessage(value);
+ statusBuilder_.setMessage(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder setCommon(
- apache.rocketmq.v2.ResponseCommon.Builder builderForValue) {
- if (commonBuilder_ == null) {
- common_ = builderForValue.build();
+ public Builder setStatus(
+ apache.rocketmq.v2.Status.Builder builderForValue) {
+ if (statusBuilder_ == null) {
+ status_ = builderForValue.build();
onChanged();
} else {
- commonBuilder_.setMessage(builderForValue.build());
+ statusBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder mergeCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
- if (common_ != null) {
- common_ =
- apache.rocketmq.v2.ResponseCommon.newBuilder(common_).mergeFrom(value).buildPartial();
+ 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 {
- common_ = value;
+ status_ = value;
}
onChanged();
} else {
- commonBuilder_.mergeFrom(value);
+ statusBuilder_.mergeFrom(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public Builder clearCommon() {
- if (commonBuilder_ == null) {
- common_ = null;
+ public Builder clearStatus() {
+ if (statusBuilder_ == null) {
+ status_ = null;
onChanged();
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommon.Builder getCommonBuilder() {
+ public apache.rocketmq.v2.Status.Builder getStatusBuilder() {
onChanged();
- return getCommonFieldBuilder().getBuilder();
+ return getStatusFieldBuilder().getBuilder();
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- if (commonBuilder_ != null) {
- return commonBuilder_.getMessageOrBuilder();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ if (statusBuilder_ != null) {
+ return statusBuilder_.getMessageOrBuilder();
} else {
- return common_ == null ?
- apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ return status_ == null ?
+ apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>
- getCommonFieldBuilder() {
- if (commonBuilder_ == null) {
- commonBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>(
- getCommon(),
+ 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());
- common_ = null;
+ status_ = null;
}
- return commonBuilder_;
+ return statusBuilder_;
}
private java.util.List<apache.rocketmq.v2.SendReceipt> receipts_ =
diff --git a/src/main/java/apache/rocketmq/v2/SendMessageResponseOrBuilder.java b/src/main/java/apache/rocketmq/v2/SendMessageResponseOrBuilder.java
index 27db180..31201ec 100644
--- a/src/main/java/apache/rocketmq/v2/SendMessageResponseOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/SendMessageResponseOrBuilder.java
@@ -8,19 +8,19 @@ public interface SendMessageResponseOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return Whether the status field is set.
*/
- boolean hasCommon();
+ boolean hasStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
+ * @return The status.
*/
- apache.rocketmq.v2.ResponseCommon getCommon();
+ apache.rocketmq.v2.Status getStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 1;</code>
+ * <code>.apache.rocketmq.v2.Status status = 1;</code>
*/
- apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder();
+ apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder();
/**
* <code>repeated .apache.rocketmq.v2.SendReceipt receipts = 2;</code>
diff --git a/src/main/java/apache/rocketmq/v2/ResponseCommon.java b/src/main/java/apache/rocketmq/v2/Status.java
similarity index 82%
rename from src/main/java/apache/rocketmq/v2/ResponseCommon.java
rename to src/main/java/apache/rocketmq/v2/Status.java
index 6312973..246014d 100644
--- a/src/main/java/apache/rocketmq/v2/ResponseCommon.java
+++ b/src/main/java/apache/rocketmq/v2/Status.java
@@ -4,18 +4,18 @@
package apache.rocketmq.v2;
/**
- * Protobuf type {@code apache.rocketmq.v2.ResponseCommon}
+ * Protobuf type {@code apache.rocketmq.v2.Status}
*/
-public final class ResponseCommon extends
+public final class Status extends
com.google.protobuf.GeneratedMessageV3 implements
- // @@protoc_insertion_point(message_implements:apache.rocketmq.v2.ResponseCommon)
- ResponseCommonOrBuilder {
+ // @@protoc_insertion_point(message_implements:apache.rocketmq.v2.Status)
+ StatusOrBuilder {
private static final long serialVersionUID = 0L;
- // Use ResponseCommon.newBuilder() to construct.
- private ResponseCommon(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
+ // Use Status.newBuilder() to construct.
+ private Status(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
super(builder);
}
- private ResponseCommon() {
+ private Status() {
code_ = 0;
message_ = "";
}
@@ -24,7 +24,7 @@ private static final long serialVersionUID = 0L;
@SuppressWarnings({"unused"})
protected java.lang.Object newInstance(
UnusedPrivateParameter unused) {
- return new ResponseCommon();
+ return new Status();
}
@java.lang.Override
@@ -32,7 +32,7 @@ private static final long serialVersionUID = 0L;
getUnknownFields() {
return this.unknownFields;
}
- private ResponseCommon(
+ private Status(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
@@ -83,15 +83,15 @@ private static final long serialVersionUID = 0L;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_ResponseCommon_descriptor;
+ return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Status_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_ResponseCommon_fieldAccessorTable
+ return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Status_fieldAccessorTable
.ensureFieldAccessorsInitialized(
- apache.rocketmq.v2.ResponseCommon.class, apache.rocketmq.v2.ResponseCommon.Builder.class);
+ apache.rocketmq.v2.Status.class, apache.rocketmq.v2.Status.Builder.class);
}
public static final int CODE_FIELD_NUMBER = 1;
@@ -197,10 +197,10 @@ private static final long serialVersionUID = 0L;
if (obj == this) {
return true;
}
- if (!(obj instanceof apache.rocketmq.v2.ResponseCommon)) {
+ if (!(obj instanceof apache.rocketmq.v2.Status)) {
return super.equals(obj);
}
- apache.rocketmq.v2.ResponseCommon other = (apache.rocketmq.v2.ResponseCommon) obj;
+ apache.rocketmq.v2.Status other = (apache.rocketmq.v2.Status) obj;
if (code_ != other.code_) return false;
if (!getMessage()
@@ -225,69 +225,69 @@ private static final long serialVersionUID = 0L;
return hash;
}
- public static apache.rocketmq.v2.ResponseCommon parseFrom(
+ public static apache.rocketmq.v2.Status parseFrom(
java.nio.ByteBuffer data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
- public static apache.rocketmq.v2.ResponseCommon parseFrom(
+ public static apache.rocketmq.v2.Status parseFrom(
java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
- public static apache.rocketmq.v2.ResponseCommon parseFrom(
+ public static apache.rocketmq.v2.Status parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
- public static apache.rocketmq.v2.ResponseCommon parseFrom(
+ public static apache.rocketmq.v2.Status parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
- public static apache.rocketmq.v2.ResponseCommon parseFrom(byte[] data)
+ public static apache.rocketmq.v2.Status parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
- public static apache.rocketmq.v2.ResponseCommon parseFrom(
+ public static apache.rocketmq.v2.Status parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
- public static apache.rocketmq.v2.ResponseCommon parseFrom(java.io.InputStream input)
+ public static apache.rocketmq.v2.Status parseFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
- public static apache.rocketmq.v2.ResponseCommon parseFrom(
+ public static apache.rocketmq.v2.Status parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input, extensionRegistry);
}
- public static apache.rocketmq.v2.ResponseCommon parseDelimitedFrom(java.io.InputStream input)
+ public static apache.rocketmq.v2.Status parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input);
}
- public static apache.rocketmq.v2.ResponseCommon parseDelimitedFrom(
+ public static apache.rocketmq.v2.Status parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input, extensionRegistry);
}
- public static apache.rocketmq.v2.ResponseCommon parseFrom(
+ public static apache.rocketmq.v2.Status parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
- public static apache.rocketmq.v2.ResponseCommon parseFrom(
+ public static apache.rocketmq.v2.Status parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@@ -300,7 +300,7 @@ private static final long serialVersionUID = 0L;
public static Builder newBuilder() {
return DEFAULT_INSTANCE.toBuilder();
}
- public static Builder newBuilder(apache.rocketmq.v2.ResponseCommon prototype) {
+ public static Builder newBuilder(apache.rocketmq.v2.Status prototype) {
return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
}
@java.lang.Override
@@ -316,26 +316,26 @@ private static final long serialVersionUID = 0L;
return builder;
}
/**
- * Protobuf type {@code apache.rocketmq.v2.ResponseCommon}
+ * Protobuf type {@code apache.rocketmq.v2.Status}
*/
public static final class Builder extends
com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
- // @@protoc_insertion_point(builder_implements:apache.rocketmq.v2.ResponseCommon)
- apache.rocketmq.v2.ResponseCommonOrBuilder {
+ // @@protoc_insertion_point(builder_implements:apache.rocketmq.v2.Status)
+ apache.rocketmq.v2.StatusOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_ResponseCommon_descriptor;
+ return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Status_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_ResponseCommon_fieldAccessorTable
+ return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Status_fieldAccessorTable
.ensureFieldAccessorsInitialized(
- apache.rocketmq.v2.ResponseCommon.class, apache.rocketmq.v2.ResponseCommon.Builder.class);
+ apache.rocketmq.v2.Status.class, apache.rocketmq.v2.Status.Builder.class);
}
- // Construct using apache.rocketmq.v2.ResponseCommon.newBuilder()
+ // Construct using apache.rocketmq.v2.Status.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
@@ -363,17 +363,17 @@ private static final long serialVersionUID = 0L;
@java.lang.Override
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_ResponseCommon_descriptor;
+ return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Status_descriptor;
}
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon getDefaultInstanceForType() {
- return apache.rocketmq.v2.ResponseCommon.getDefaultInstance();
+ public apache.rocketmq.v2.Status getDefaultInstanceForType() {
+ return apache.rocketmq.v2.Status.getDefaultInstance();
}
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon build() {
- apache.rocketmq.v2.ResponseCommon result = buildPartial();
+ public apache.rocketmq.v2.Status build() {
+ apache.rocketmq.v2.Status result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
@@ -381,8 +381,8 @@ private static final long serialVersionUID = 0L;
}
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon buildPartial() {
- apache.rocketmq.v2.ResponseCommon result = new apache.rocketmq.v2.ResponseCommon(this);
+ public apache.rocketmq.v2.Status buildPartial() {
+ apache.rocketmq.v2.Status result = new apache.rocketmq.v2.Status(this);
result.code_ = code_;
result.message_ = message_;
onBuilt();
@@ -423,16 +423,16 @@ private static final long serialVersionUID = 0L;
}
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof apache.rocketmq.v2.ResponseCommon) {
- return mergeFrom((apache.rocketmq.v2.ResponseCommon)other);
+ if (other instanceof apache.rocketmq.v2.Status) {
+ return mergeFrom((apache.rocketmq.v2.Status)other);
} else {
super.mergeFrom(other);
return this;
}
}
- public Builder mergeFrom(apache.rocketmq.v2.ResponseCommon other) {
- if (other == apache.rocketmq.v2.ResponseCommon.getDefaultInstance()) return this;
+ public Builder mergeFrom(apache.rocketmq.v2.Status other) {
+ if (other == apache.rocketmq.v2.Status.getDefaultInstance()) return this;
if (other.code_ != 0) {
setCodeValue(other.getCodeValue());
}
@@ -455,11 +455,11 @@ private static final long serialVersionUID = 0L;
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
- apache.rocketmq.v2.ResponseCommon parsedMessage = null;
+ apache.rocketmq.v2.Status parsedMessage = null;
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
- parsedMessage = (apache.rocketmq.v2.ResponseCommon) e.getUnfinishedMessage();
+ parsedMessage = (apache.rocketmq.v2.Status) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
@@ -611,41 +611,41 @@ private static final long serialVersionUID = 0L;
}
- // @@protoc_insertion_point(builder_scope:apache.rocketmq.v2.ResponseCommon)
+ // @@protoc_insertion_point(builder_scope:apache.rocketmq.v2.Status)
}
- // @@protoc_insertion_point(class_scope:apache.rocketmq.v2.ResponseCommon)
- private static final apache.rocketmq.v2.ResponseCommon DEFAULT_INSTANCE;
+ // @@protoc_insertion_point(class_scope:apache.rocketmq.v2.Status)
+ private static final apache.rocketmq.v2.Status DEFAULT_INSTANCE;
static {
- DEFAULT_INSTANCE = new apache.rocketmq.v2.ResponseCommon();
+ DEFAULT_INSTANCE = new apache.rocketmq.v2.Status();
}
- public static apache.rocketmq.v2.ResponseCommon getDefaultInstance() {
+ public static apache.rocketmq.v2.Status getDefaultInstance() {
return DEFAULT_INSTANCE;
}
- private static final com.google.protobuf.Parser<ResponseCommon>
- PARSER = new com.google.protobuf.AbstractParser<ResponseCommon>() {
+ private static final com.google.protobuf.Parser<Status>
+ PARSER = new com.google.protobuf.AbstractParser<Status>() {
@java.lang.Override
- public ResponseCommon parsePartialFrom(
+ public Status parsePartialFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
- return new ResponseCommon(input, extensionRegistry);
+ return new Status(input, extensionRegistry);
}
};
- public static com.google.protobuf.Parser<ResponseCommon> parser() {
+ public static com.google.protobuf.Parser<Status> parser() {
return PARSER;
}
@java.lang.Override
- public com.google.protobuf.Parser<ResponseCommon> getParserForType() {
+ public com.google.protobuf.Parser<Status> getParserForType() {
return PARSER;
}
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon getDefaultInstanceForType() {
+ public apache.rocketmq.v2.Status getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
diff --git a/src/main/java/apache/rocketmq/v2/ResponseCommonOrBuilder.java b/src/main/java/apache/rocketmq/v2/StatusOrBuilder.java
similarity index 91%
rename from src/main/java/apache/rocketmq/v2/ResponseCommonOrBuilder.java
rename to src/main/java/apache/rocketmq/v2/StatusOrBuilder.java
index 58a18e6..7d2c042 100644
--- a/src/main/java/apache/rocketmq/v2/ResponseCommonOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/StatusOrBuilder.java
@@ -3,8 +3,8 @@
package apache.rocketmq.v2;
-public interface ResponseCommonOrBuilder extends
- // @@protoc_insertion_point(interface_extends:apache.rocketmq.v2.ResponseCommon)
+public interface StatusOrBuilder extends
+ // @@protoc_insertion_point(interface_extends:apache.rocketmq.v2.Status)
com.google.protobuf.MessageOrBuilder {
/**
diff --git a/src/main/java/apache/rocketmq/v2/VerifyMessageResult.java b/src/main/java/apache/rocketmq/v2/VerifyMessageResult.java
index 4edfb99..47ece4a 100644
--- a/src/main/java/apache/rocketmq/v2/VerifyMessageResult.java
+++ b/src/main/java/apache/rocketmq/v2/VerifyMessageResult.java
@@ -54,14 +54,14 @@ private static final long serialVersionUID = 0L;
break;
}
case 18: {
- apache.rocketmq.v2.ResponseCommon.Builder subBuilder = null;
- if (common_ != null) {
- subBuilder = common_.toBuilder();
+ apache.rocketmq.v2.Status.Builder subBuilder = null;
+ if (status_ != null) {
+ subBuilder = status_.toBuilder();
}
- common_ = input.readMessage(apache.rocketmq.v2.ResponseCommon.parser(), extensionRegistry);
+ status_ = input.readMessage(apache.rocketmq.v2.Status.parser(), extensionRegistry);
if (subBuilder != null) {
- subBuilder.mergeFrom(common_);
- common_ = subBuilder.buildPartial();
+ subBuilder.mergeFrom(status_);
+ status_ = subBuilder.buildPartial();
}
break;
@@ -109,30 +109,30 @@ private static final long serialVersionUID = 0L;
return commandId_;
}
- public static final int COMMON_FIELD_NUMBER = 2;
- private apache.rocketmq.v2.ResponseCommon common_;
+ public static final int STATUS_FIELD_NUMBER = 2;
+ private apache.rocketmq.v2.Status status_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 2;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 2;</code>
+ * @return Whether the status field is set.
*/
@java.lang.Override
- public boolean hasCommon() {
- return common_ != null;
+ public boolean hasStatus() {
+ return status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 2;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 2;</code>
+ * @return The status.
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 2;</code>
+ * <code>.apache.rocketmq.v2.Status status = 2;</code>
*/
@java.lang.Override
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- return getCommon();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ return getStatus();
}
private byte memoizedIsInitialized = -1;
@@ -152,8 +152,8 @@ private static final long serialVersionUID = 0L;
if (commandId_ != 0L) {
output.writeInt64(1, commandId_);
}
- if (common_ != null) {
- output.writeMessage(2, getCommon());
+ if (status_ != null) {
+ output.writeMessage(2, getStatus());
}
unknownFields.writeTo(output);
}
@@ -168,9 +168,9 @@ private static final long serialVersionUID = 0L;
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(1, commandId_);
}
- if (common_ != null) {
+ if (status_ != null) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(2, getCommon());
+ .computeMessageSize(2, getStatus());
}
size += unknownFields.getSerializedSize();
memoizedSize = size;
@@ -189,10 +189,10 @@ private static final long serialVersionUID = 0L;
if (getCommandId()
!= other.getCommandId()) return false;
- if (hasCommon() != other.hasCommon()) return false;
- if (hasCommon()) {
- if (!getCommon()
- .equals(other.getCommon())) return false;
+ if (hasStatus() != other.hasStatus()) return false;
+ if (hasStatus()) {
+ if (!getStatus()
+ .equals(other.getStatus())) return false;
}
if (!unknownFields.equals(other.unknownFields)) return false;
return true;
@@ -208,9 +208,9 @@ private static final long serialVersionUID = 0L;
hash = (37 * hash) + COMMAND_ID_FIELD_NUMBER;
hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
getCommandId());
- if (hasCommon()) {
- hash = (37 * hash) + COMMON_FIELD_NUMBER;
- hash = (53 * hash) + getCommon().hashCode();
+ if (hasStatus()) {
+ hash = (37 * hash) + STATUS_FIELD_NUMBER;
+ hash = (53 * hash) + getStatus().hashCode();
}
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
@@ -347,11 +347,11 @@ private static final long serialVersionUID = 0L;
super.clear();
commandId_ = 0L;
- if (commonBuilder_ == null) {
- common_ = null;
+ if (statusBuilder_ == null) {
+ status_ = null;
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
@@ -380,10 +380,10 @@ private static final long serialVersionUID = 0L;
public apache.rocketmq.v2.VerifyMessageResult buildPartial() {
apache.rocketmq.v2.VerifyMessageResult result = new apache.rocketmq.v2.VerifyMessageResult(this);
result.commandId_ = commandId_;
- if (commonBuilder_ == null) {
- result.common_ = common_;
+ if (statusBuilder_ == null) {
+ result.status_ = status_;
} else {
- result.common_ = commonBuilder_.build();
+ result.status_ = statusBuilder_.build();
}
onBuilt();
return result;
@@ -436,8 +436,8 @@ private static final long serialVersionUID = 0L;
if (other.getCommandId() != 0L) {
setCommandId(other.getCommandId());
}
- if (other.hasCommon()) {
- mergeCommon(other.getCommon());
+ if (other.hasStatus()) {
+ mergeStatus(other.getStatus());
}
this.mergeUnknownFields(other.unknownFields);
onChanged();
@@ -499,123 +499,123 @@ private static final long serialVersionUID = 0L;
return this;
}
- private apache.rocketmq.v2.ResponseCommon common_;
+ private apache.rocketmq.v2.Status status_;
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder> commonBuilder_;
+ apache.rocketmq.v2.Status, apache.rocketmq.v2.Status.Builder, apache.rocketmq.v2.StatusOrBuilder> statusBuilder_;
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 2;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 2;</code>
+ * @return Whether the status field is set.
*/
- public boolean hasCommon() {
- return commonBuilder_ != null || common_ != null;
+ public boolean hasStatus() {
+ return statusBuilder_ != null || status_ != null;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 2;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 2;</code>
+ * @return The status.
*/
- public apache.rocketmq.v2.ResponseCommon getCommon() {
- if (commonBuilder_ == null) {
- return common_ == null ? apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ public apache.rocketmq.v2.Status getStatus() {
+ if (statusBuilder_ == null) {
+ return status_ == null ? apache.rocketmq.v2.Status.getDefaultInstance() : status_;
} else {
- return commonBuilder_.getMessage();
+ return statusBuilder_.getMessage();
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 2;</code>
+ * <code>.apache.rocketmq.v2.Status status = 2;</code>
*/
- public Builder setCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
+ public Builder setStatus(apache.rocketmq.v2.Status value) {
+ if (statusBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
- common_ = value;
+ status_ = value;
onChanged();
} else {
- commonBuilder_.setMessage(value);
+ statusBuilder_.setMessage(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 2;</code>
+ * <code>.apache.rocketmq.v2.Status status = 2;</code>
*/
- public Builder setCommon(
- apache.rocketmq.v2.ResponseCommon.Builder builderForValue) {
- if (commonBuilder_ == null) {
- common_ = builderForValue.build();
+ public Builder setStatus(
+ apache.rocketmq.v2.Status.Builder builderForValue) {
+ if (statusBuilder_ == null) {
+ status_ = builderForValue.build();
onChanged();
} else {
- commonBuilder_.setMessage(builderForValue.build());
+ statusBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 2;</code>
+ * <code>.apache.rocketmq.v2.Status status = 2;</code>
*/
- public Builder mergeCommon(apache.rocketmq.v2.ResponseCommon value) {
- if (commonBuilder_ == null) {
- if (common_ != null) {
- common_ =
- apache.rocketmq.v2.ResponseCommon.newBuilder(common_).mergeFrom(value).buildPartial();
+ 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 {
- common_ = value;
+ status_ = value;
}
onChanged();
} else {
- commonBuilder_.mergeFrom(value);
+ statusBuilder_.mergeFrom(value);
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 2;</code>
+ * <code>.apache.rocketmq.v2.Status status = 2;</code>
*/
- public Builder clearCommon() {
- if (commonBuilder_ == null) {
- common_ = null;
+ public Builder clearStatus() {
+ if (statusBuilder_ == null) {
+ status_ = null;
onChanged();
} else {
- common_ = null;
- commonBuilder_ = null;
+ status_ = null;
+ statusBuilder_ = null;
}
return this;
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 2;</code>
+ * <code>.apache.rocketmq.v2.Status status = 2;</code>
*/
- public apache.rocketmq.v2.ResponseCommon.Builder getCommonBuilder() {
+ public apache.rocketmq.v2.Status.Builder getStatusBuilder() {
onChanged();
- return getCommonFieldBuilder().getBuilder();
+ return getStatusFieldBuilder().getBuilder();
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 2;</code>
+ * <code>.apache.rocketmq.v2.Status status = 2;</code>
*/
- public apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder() {
- if (commonBuilder_ != null) {
- return commonBuilder_.getMessageOrBuilder();
+ public apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder() {
+ if (statusBuilder_ != null) {
+ return statusBuilder_.getMessageOrBuilder();
} else {
- return common_ == null ?
- apache.rocketmq.v2.ResponseCommon.getDefaultInstance() : common_;
+ return status_ == null ?
+ apache.rocketmq.v2.Status.getDefaultInstance() : status_;
}
}
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 2;</code>
+ * <code>.apache.rocketmq.v2.Status status = 2;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>
- getCommonFieldBuilder() {
- if (commonBuilder_ == null) {
- commonBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- apache.rocketmq.v2.ResponseCommon, apache.rocketmq.v2.ResponseCommon.Builder, apache.rocketmq.v2.ResponseCommonOrBuilder>(
- getCommon(),
+ 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());
- common_ = null;
+ status_ = null;
}
- return commonBuilder_;
+ return statusBuilder_;
}
@java.lang.Override
public final Builder setUnknownFields(
diff --git a/src/main/java/apache/rocketmq/v2/VerifyMessageResultOrBuilder.java b/src/main/java/apache/rocketmq/v2/VerifyMessageResultOrBuilder.java
index b9ac18f..1dc8f95 100644
--- a/src/main/java/apache/rocketmq/v2/VerifyMessageResultOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/VerifyMessageResultOrBuilder.java
@@ -14,17 +14,17 @@ public interface VerifyMessageResultOrBuilder extends
long getCommandId();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 2;</code>
- * @return Whether the common field is set.
+ * <code>.apache.rocketmq.v2.Status status = 2;</code>
+ * @return Whether the status field is set.
*/
- boolean hasCommon();
+ boolean hasStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 2;</code>
- * @return The common.
+ * <code>.apache.rocketmq.v2.Status status = 2;</code>
+ * @return The status.
*/
- apache.rocketmq.v2.ResponseCommon getCommon();
+ apache.rocketmq.v2.Status getStatus();
/**
- * <code>.apache.rocketmq.v2.ResponseCommon common = 2;</code>
+ * <code>.apache.rocketmq.v2.Status status = 2;</code>
*/
- apache.rocketmq.v2.ResponseCommonOrBuilder getCommonOrBuilder();
+ apache.rocketmq.v2.StatusOrBuilder getStatusOrBuilder();
}
diff --git a/src/main/resources/proto/apache/rocketmq/v2/service.proto b/src/main/resources/proto/apache/rocketmq/v2/service.proto
index 6cd2a94..643b45c 100644
--- a/src/main/resources/proto/apache/rocketmq/v2/service.proto
+++ b/src/main/resources/proto/apache/rocketmq/v2/service.proto
@@ -17,8 +17,6 @@ syntax = "proto3";
import "google/protobuf/duration.proto";
import "google/protobuf/timestamp.proto";
-import "google/rpc/error_details.proto";
-import "google/rpc/status.proto";
import "apache/rocketmq/v2/definition.proto";