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:56 UTC
[rocketmq-apis] 23/38: Apply IDL update
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 765ca0f55f38c6d64c2ede7829e624b09fb582ee
Author: 凌楚 <ya...@alibaba-inc.com>
AuthorDate: Mon May 23 15:29:12 2022 +0800
Apply IDL update
---
src/main/java/apache/rocketmq/v2/Code.java | 17 +++++++++++++++++
src/main/java/apache/rocketmq/v2/MQDomain.java | 17 +++++++++--------
.../resources/proto/apache/rocketmq/v2/definition.proto | 3 +++
3 files changed, 29 insertions(+), 8 deletions(-)
diff --git a/src/main/java/apache/rocketmq/v2/Code.java b/src/main/java/apache/rocketmq/v2/Code.java
index 5694422..51e00cd 100644
--- a/src/main/java/apache/rocketmq/v2/Code.java
+++ b/src/main/java/apache/rocketmq/v2/Code.java
@@ -280,6 +280,14 @@ public enum Code
* <code>UNRECOGNIZED_CLIENT_TYPE = 32;</code>
*/
UNRECOGNIZED_CLIENT_TYPE(32),
+ /**
+ * <pre>
+ * Return different results for entries in composite request.
+ * </pre>
+ *
+ * <code>MULTIPLE_RESULTS = 33;</code>
+ */
+ MULTIPLE_RESULTS(33),
/**
* <pre>
* Code indicates that the server encountered an unexpected condition
@@ -590,6 +598,14 @@ public enum Code
* <code>UNRECOGNIZED_CLIENT_TYPE = 32;</code>
*/
public static final int UNRECOGNIZED_CLIENT_TYPE_VALUE = 32;
+ /**
+ * <pre>
+ * Return different results for entries in composite request.
+ * </pre>
+ *
+ * <code>MULTIPLE_RESULTS = 33;</code>
+ */
+ public static final int MULTIPLE_RESULTS_VALUE = 33;
/**
* <pre>
* Code indicates that the server encountered an unexpected condition
@@ -684,6 +700,7 @@ public enum Code
case 30: return ILLEGAL_MESSAGE_OFFSET;
case 31: return ILLEGAL_MESSAGE;
case 32: return UNRECOGNIZED_CLIENT_TYPE;
+ case 33: return MULTIPLE_RESULTS;
case 500: return INTERNAL_SERVER_ERROR;
case 501: return NOT_IMPLEMENTED;
case 504: return GATEWAY_TIMEOUT;
diff --git a/src/main/java/apache/rocketmq/v2/MQDomain.java b/src/main/java/apache/rocketmq/v2/MQDomain.java
index ddac52b..dee123f 100644
--- a/src/main/java/apache/rocketmq/v2/MQDomain.java
+++ b/src/main/java/apache/rocketmq/v2/MQDomain.java
@@ -195,7 +195,7 @@ public final class MQDomain {
"entType\022\033\n\027CLIENT_TYPE_UNSPECIFIED\020\000\022\014\n\010" +
"PRODUCER\020\001\022\021\n\rPUSH_CONSUMER\020\002\022\023\n\017SIMPLE_" +
"CONSUMER\020\003*<\n\010Encoding\022\030\n\024ENCODING_UNSPE" +
- "CIFIED\020\000\022\014\n\010IDENTITY\020\001\022\010\n\004GZIP\020\002*\272\007\n\004Cod" +
+ "CIFIED\020\000\022\014\n\010IDENTITY\020\001\022\010\n\004GZIP\020\002*\320\007\n\004Cod" +
"e\022\006\n\002OK\020\000\022\030\n\024ILLEGAL_ACCESS_POINT\020\001\022\021\n\rI" +
"LLEGAL_TOPIC\020\002\022\032\n\026ILLEGAL_CONSUMER_GROUP" +
"\020\003\022\027\n\023ILLEGAL_MESSAGE_TAG\020\004\022\027\n\023ILLEGAL_M" +
@@ -217,13 +217,14 @@ public final class MQDomain {
"IMEOUT\020\032\022\024\n\020HA_NOT_AVAILABLE\020\033\022\027\n\023VERSIO" +
"N_UNSUPPORTED\020\034\022\025\n\021MESSAGE_NOT_FOUND\020\035\022\032" +
"\n\026ILLEGAL_MESSAGE_OFFSET\020\036\022\023\n\017ILLEGAL_ME" +
- "SSAGE\020\037\022\034\n\030UNRECOGNIZED_CLIENT_TYPE\020 \022\032\n" +
- "\025INTERNAL_SERVER_ERROR\020\364\003\022\024\n\017NOT_IMPLEME" +
- "NTED\020\365\003\022\024\n\017GATEWAY_TIMEOUT\020\370\003*Z\n\010Languag" +
- "e\022\030\n\024LANGUAGE_UNSPECIFIED\020\000\022\010\n\004JAVA\020\001\022\007\n" +
- "\003CPP\020\002\022\013\n\007DOT_NET\020\003\022\n\n\006GOLANG\020\004\022\010\n\004RUST\020" +
- "\005B;\n\022apache.rocketmq.v2B\010MQDomainP\001\240\001\001\330\001" +
- "\001\252\002\022Apache.Rocketmq.V2b\006proto3"
+ "SSAGE\020\037\022\034\n\030UNRECOGNIZED_CLIENT_TYPE\020 \022\024\n" +
+ "\020MULTIPLE_RESULTS\020!\022\032\n\025INTERNAL_SERVER_E" +
+ "RROR\020\364\003\022\024\n\017NOT_IMPLEMENTED\020\365\003\022\024\n\017GATEWAY" +
+ "_TIMEOUT\020\370\003*Z\n\010Language\022\030\n\024LANGUAGE_UNSP" +
+ "ECIFIED\020\000\022\010\n\004JAVA\020\001\022\007\n\003CPP\020\002\022\013\n\007DOT_NET\020" +
+ "\003\022\n\n\006GOLANG\020\004\022\010\n\004RUST\020\005B;\n\022apache.rocket" +
+ "mq.v2B\010MQDomainP\001\240\001\001\330\001\001\252\002\022Apache.Rocketm" +
+ "q.V2b\006proto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,
diff --git a/src/main/resources/proto/apache/rocketmq/v2/definition.proto b/src/main/resources/proto/apache/rocketmq/v2/definition.proto
index 3153638..21a6321 100644
--- a/src/main/resources/proto/apache/rocketmq/v2/definition.proto
+++ b/src/main/resources/proto/apache/rocketmq/v2/definition.proto
@@ -388,6 +388,9 @@ enum Code {
// Client type could not be recognized.
UNRECOGNIZED_CLIENT_TYPE = 32;
+ // Return different results for entries in composite request.
+ MULTIPLE_RESULTS = 33;
+
// Code indicates that the server encountered an unexpected condition
// that prevented it from fulfilling the request.
// This error response is a generic "catch-all" response.