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:28:08 UTC
[rocketmq-apis] 35/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 e52b75b3edc3d85407036a4535c196c4d23ba2e5
Author: 凌楚 <ya...@alibaba-inc.com>
AuthorDate: Fri Jul 15 11:04:08 2022 +0800
Apply IDL update
---
src/main/java/apache/rocketmq/v2/Language.java | 63 +++++++
src/main/java/apache/rocketmq/v2/MQDomain.java | 182 +++++++++++++------
src/main/java/apache/rocketmq/v2/MQService.java | 202 +++++++--------------
src/main/java/apache/rocketmq/v2/Metric.java | 12 +-
.../java/apache/rocketmq/v2/MetricOrBuilder.java | 2 +-
src/main/java/apache/rocketmq/v2/Publishing.java | 12 +-
.../apache/rocketmq/v2/PublishingOrBuilder.java | 2 +-
src/main/java/apache/rocketmq/v2/Settings.java | 12 +-
.../java/apache/rocketmq/v2/SettingsOrBuilder.java | 2 +-
src/main/java/apache/rocketmq/v2/Subscription.java | 12 +-
.../apache/rocketmq/v2/SubscriptionOrBuilder.java | 2 +-
.../proto/apache/rocketmq/v2/definition.proto | 93 ++++++++++
.../proto/apache/rocketmq/v2/service.proto | 86 ---------
13 files changed, 377 insertions(+), 305 deletions(-)
diff --git a/src/main/java/apache/rocketmq/v2/Language.java b/src/main/java/apache/rocketmq/v2/Language.java
index f9403dc..31d54d8 100644
--- a/src/main/java/apache/rocketmq/v2/Language.java
+++ b/src/main/java/apache/rocketmq/v2/Language.java
@@ -32,6 +32,34 @@ public enum Language
* <code>RUST = 5;</code>
*/
RUST(5),
+ /**
+ * <code>PYTHON = 6;</code>
+ */
+ PYTHON(6),
+ /**
+ * <code>PHP = 7;</code>
+ */
+ PHP(7),
+ /**
+ * <code>NODE_JS = 8;</code>
+ */
+ NODE_JS(8),
+ /**
+ * <code>RUBY = 9;</code>
+ */
+ RUBY(9),
+ /**
+ * <code>OBJECTIVE_C = 10;</code>
+ */
+ OBJECTIVE_C(10),
+ /**
+ * <code>DART = 11;</code>
+ */
+ DART(11),
+ /**
+ * <code>KOTLIN = 12;</code>
+ */
+ KOTLIN(12),
UNRECOGNIZED(-1),
;
@@ -59,6 +87,34 @@ public enum Language
* <code>RUST = 5;</code>
*/
public static final int RUST_VALUE = 5;
+ /**
+ * <code>PYTHON = 6;</code>
+ */
+ public static final int PYTHON_VALUE = 6;
+ /**
+ * <code>PHP = 7;</code>
+ */
+ public static final int PHP_VALUE = 7;
+ /**
+ * <code>NODE_JS = 8;</code>
+ */
+ public static final int NODE_JS_VALUE = 8;
+ /**
+ * <code>RUBY = 9;</code>
+ */
+ public static final int RUBY_VALUE = 9;
+ /**
+ * <code>OBJECTIVE_C = 10;</code>
+ */
+ public static final int OBJECTIVE_C_VALUE = 10;
+ /**
+ * <code>DART = 11;</code>
+ */
+ public static final int DART_VALUE = 11;
+ /**
+ * <code>KOTLIN = 12;</code>
+ */
+ public static final int KOTLIN_VALUE = 12;
public final int getNumber() {
@@ -91,6 +147,13 @@ public enum Language
case 3: return DOT_NET;
case 4: return GOLANG;
case 5: return RUST;
+ case 6: return PYTHON;
+ case 7: return PHP;
+ case 8: return NODE_JS;
+ case 9: return RUBY;
+ case 10: return OBJECTIVE_C;
+ case 11: return DART;
+ case 12: return KOTLIN;
default: return null;
}
}
diff --git a/src/main/java/apache/rocketmq/v2/MQDomain.java b/src/main/java/apache/rocketmq/v2/MQDomain.java
index ce81f77..4f58721 100644
--- a/src/main/java/apache/rocketmq/v2/MQDomain.java
+++ b/src/main/java/apache/rocketmq/v2/MQDomain.java
@@ -99,6 +99,26 @@ public final class MQDomain {
static final
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internal_static_apache_rocketmq_v2_UA_fieldAccessorTable;
+ static final com.google.protobuf.Descriptors.Descriptor
+ internal_static_apache_rocketmq_v2_Settings_descriptor;
+ static final
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internal_static_apache_rocketmq_v2_Settings_fieldAccessorTable;
+ static final com.google.protobuf.Descriptors.Descriptor
+ internal_static_apache_rocketmq_v2_Publishing_descriptor;
+ static final
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internal_static_apache_rocketmq_v2_Publishing_fieldAccessorTable;
+ static final com.google.protobuf.Descriptors.Descriptor
+ internal_static_apache_rocketmq_v2_Subscription_descriptor;
+ static final
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internal_static_apache_rocketmq_v2_Subscription_fieldAccessorTable;
+ static final com.google.protobuf.Descriptors.Descriptor
+ internal_static_apache_rocketmq_v2_Metric_descriptor;
+ static final
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internal_static_apache_rocketmq_v2_Metric_fieldAccessorTable;
public static com.google.protobuf.Descriptors.FileDescriptor
getDescriptor() {
@@ -177,61 +197,89 @@ public final class MQDomain {
".Code\022\017\n\007message\030\002 \001(\t\"i\n\002UA\022.\n\010language" +
"\030\001 \001(\0162\034.apache.rocketmq.v2.Language\022\017\n\007" +
"version\030\002 \001(\t\022\020\n\010platform\030\003 \001(\t\022\020\n\010hostn" +
- "ame\030\004 \001(\t*Y\n\025TransactionResolution\022&\n\"TR" +
- "ANSACTION_RESOLUTION_UNSPECIFIED\020\000\022\n\n\006CO" +
- "MMIT\020\001\022\014\n\010ROLLBACK\020\002*W\n\021TransactionSourc" +
- "e\022\026\n\022SOURCE_UNSPECIFIED\020\000\022\021\n\rSOURCE_CLIE" +
- "NT\020\001\022\027\n\023SOURCE_SERVER_CHECK\020\002*W\n\nPermiss" +
- "ion\022\032\n\026PERMISSION_UNSPECIFIED\020\000\022\010\n\004NONE\020" +
- "\001\022\010\n\004READ\020\002\022\t\n\005WRITE\020\003\022\016\n\nREAD_WRITE\020\004*;" +
- "\n\nFilterType\022\033\n\027FILTER_TYPE_UNSPECIFIED\020" +
- "\000\022\007\n\003TAG\020\001\022\007\n\003SQL\020\002*T\n\rAddressScheme\022\036\n\032" +
- "ADDRESS_SCHEME_UNSPECIFIED\020\000\022\010\n\004IPv4\020\001\022\010" +
- "\n\004IPv6\020\002\022\017\n\013DOMAIN_NAME\020\003*]\n\013MessageType" +
- "\022\034\n\030MESSAGE_TYPE_UNSPECIFIED\020\000\022\n\n\006NORMAL" +
- "\020\001\022\010\n\004FIFO\020\002\022\t\n\005DELAY\020\003\022\017\n\013TRANSACTION\020\004" +
- "*G\n\nDigestType\022\033\n\027DIGEST_TYPE_UNSPECIFIE" +
- "D\020\000\022\t\n\005CRC32\020\001\022\007\n\003MD5\020\002\022\010\n\004SHA1\020\003*_\n\nCli" +
- "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*\342\t\n\004Cod" +
- "e\022\024\n\020CODE_UNSPECIFIED\020\000\022\010\n\002OK\020\240\234\001\022\026\n\020MUL" +
- "TIPLE_RESULTS\020\260\352\001\022\021\n\013BAD_REQUEST\020\300\270\002\022\032\n\024" +
- "ILLEGAL_ACCESS_POINT\020\301\270\002\022\023\n\rILLEGAL_TOPI" +
- "C\020\302\270\002\022\034\n\026ILLEGAL_CONSUMER_GROUP\020\303\270\002\022\031\n\023I" +
- "LLEGAL_MESSAGE_TAG\020\304\270\002\022\031\n\023ILLEGAL_MESSAG" +
- "E_KEY\020\305\270\002\022\033\n\025ILLEGAL_MESSAGE_GROUP\020\306\270\002\022\"" +
- "\n\034ILLEGAL_MESSAGE_PROPERTY_KEY\020\307\270\002\022\034\n\026IN" +
- "VALID_TRANSACTION_ID\020\310\270\002\022\030\n\022ILLEGAL_MESS" +
- "AGE_ID\020\311\270\002\022\037\n\031ILLEGAL_FILTER_EXPRESSION\020" +
- "\312\270\002\022\034\n\026ILLEGAL_INVISIBLE_TIME\020\313\270\002\022\033\n\025ILL" +
- "EGAL_DELIVERY_TIME\020\314\270\002\022\034\n\026INVALID_RECEIP" +
- "T_HANDLE\020\315\270\002\022)\n#MESSAGE_PROPERTY_CONFLIC" +
- "T_WITH_TYPE\020\316\270\002\022\036\n\030UNRECOGNIZED_CLIENT_T" +
- "YPE\020\317\270\002\022\027\n\021MESSAGE_CORRUPTED\020\320\270\002\022\030\n\022CLIE" +
- "NT_ID_REQUIRED\020\321\270\002\022\022\n\014UNAUTHORIZED\020\244\271\002\022\026" +
- "\n\020PAYMENT_REQUIRED\020\210\272\002\022\017\n\tFORBIDDEN\020\354\272\002\022" +
- "\017\n\tNOT_FOUND\020\320\273\002\022\027\n\021MESSAGE_NOT_FOUND\020\321\273" +
- "\002\022\025\n\017TOPIC_NOT_FOUND\020\322\273\002\022\036\n\030CONSUMER_GRO" +
- "UP_NOT_FOUND\020\323\273\002\022\025\n\017REQUEST_TIMEOUT\020\340\276\002\022" +
- "\027\n\021PAYLOAD_TOO_LARGE\020\324\302\002\022\034\n\026MESSAGE_BODY" +
- "_TOO_LARGE\020\325\302\002\022\031\n\023PRECONDITION_FAILED\020\260\316" +
- "\002\022\027\n\021TOO_MANY_REQUESTS\020\224\317\002\022%\n\037REQUEST_HE" +
- "ADER_FIELDS_TOO_LARGE\020\334\320\002\022\"\n\034MESSAGE_PRO" +
- "PERTIES_TOO_LARGE\020\335\320\002\022\024\n\016INTERNAL_ERROR\020" +
- "\320\206\003\022\033\n\025INTERNAL_SERVER_ERROR\020\321\206\003\022\026\n\020HA_N" +
- "OT_AVAILABLE\020\322\206\003\022\025\n\017NOT_IMPLEMENTED\020\264\207\003\022" +
- "\023\n\rPROXY_TIMEOUT\020\340\211\003\022 \n\032MASTER_PERSISTEN" +
- "CE_TIMEOUT\020\341\211\003\022\037\n\031SLAVE_PERSISTENCE_TIME" +
- "OUT\020\342\211\003\022\021\n\013UNSUPPORTED\020\304\212\003\022\031\n\023VERSION_UN" +
- "SUPPORTED\020\305\212\003\022%\n\037VERIFY_FIFO_MESSAGE_UNS" +
- "UPPORTED\020\306\212\003\022\037\n\031FAILED_TO_CONSUME_MESSAG" +
- "E\020\340\324\003*Z\n\010Language\022\030\n\024LANGUAGE_UNSPECIFIE" +
- "D\020\000\022\010\n\004JAVA\020\001\022\007\n\003CPP\020\002\022\013\n\007DOT_NET\020\003\022\n\n\006G" +
- "OLANG\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\006" +
- "proto3"
+ "ame\030\004 \001(\t\"\220\004\n\010Settings\0228\n\013client_type\030\001 " +
+ "\001(\0162\036.apache.rocketmq.v2.ClientTypeH\001\210\001\001" +
+ "\0228\n\014access_point\030\002 \001(\0132\035.apache.rocketmq" +
+ ".v2.EndpointsH\002\210\001\001\022<\n\016backoff_policy\030\003 \001" +
+ "(\0132\037.apache.rocketmq.v2.RetryPolicyH\003\210\001\001" +
+ "\0227\n\017request_timeout\030\004 \001(\0132\031.google.proto" +
+ "buf.DurationH\004\210\001\001\0224\n\npublishing\030\005 \001(\0132\036." +
+ "apache.rocketmq.v2.PublishingH\000\0228\n\014subsc" +
+ "ription\030\006 \001(\0132 .apache.rocketmq.v2.Subsc" +
+ "riptionH\000\022*\n\nuser_agent\030\007 \001(\0132\026.apache.r" +
+ "ocketmq.v2.UA\022*\n\006metric\030\010 \001(\0132\032.apache.r" +
+ "ocketmq.v2.MetricB\t\n\007pub_subB\016\n\014_client_" +
+ "typeB\017\n\r_access_pointB\021\n\017_backoff_policy" +
+ "B\022\n\020_request_timeout\"p\n\nPublishing\022,\n\006to" +
+ "pics\030\001 \003(\0132\034.apache.rocketmq.v2.Resource" +
+ "\022\025\n\rmax_body_size\030\002 \001(\005\022\035\n\025validate_mess" +
+ "age_type\030\003 \001(\010\"\263\002\n\014Subscription\0220\n\005group" +
+ "\030\001 \001(\0132\034.apache.rocketmq.v2.ResourceH\000\210\001" +
+ "\001\022<\n\rsubscriptions\030\002 \003(\0132%.apache.rocket" +
+ "mq.v2.SubscriptionEntry\022\021\n\004fifo\030\003 \001(\010H\001\210" +
+ "\001\001\022\037\n\022receive_batch_size\030\004 \001(\005H\002\210\001\001\022<\n\024l" +
+ "ong_polling_timeout\030\005 \001(\0132\031.google.proto" +
+ "buf.DurationH\003\210\001\001B\010\n\006_groupB\007\n\005_fifoB\025\n\023" +
+ "_receive_batch_sizeB\027\n\025_long_polling_tim" +
+ "eout\"Y\n\006Metric\022\n\n\002on\030\001 \001(\010\0225\n\tendpoints\030" +
+ "\002 \001(\0132\035.apache.rocketmq.v2.EndpointsH\000\210\001" +
+ "\001B\014\n\n_endpoints*Y\n\025TransactionResolution" +
+ "\022&\n\"TRANSACTION_RESOLUTION_UNSPECIFIED\020\000" +
+ "\022\n\n\006COMMIT\020\001\022\014\n\010ROLLBACK\020\002*W\n\021Transactio" +
+ "nSource\022\026\n\022SOURCE_UNSPECIFIED\020\000\022\021\n\rSOURC" +
+ "E_CLIENT\020\001\022\027\n\023SOURCE_SERVER_CHECK\020\002*W\n\nP" +
+ "ermission\022\032\n\026PERMISSION_UNSPECIFIED\020\000\022\010\n" +
+ "\004NONE\020\001\022\010\n\004READ\020\002\022\t\n\005WRITE\020\003\022\016\n\nREAD_WRI" +
+ "TE\020\004*;\n\nFilterType\022\033\n\027FILTER_TYPE_UNSPEC" +
+ "IFIED\020\000\022\007\n\003TAG\020\001\022\007\n\003SQL\020\002*T\n\rAddressSche" +
+ "me\022\036\n\032ADDRESS_SCHEME_UNSPECIFIED\020\000\022\010\n\004IP" +
+ "v4\020\001\022\010\n\004IPv6\020\002\022\017\n\013DOMAIN_NAME\020\003*]\n\013Messa" +
+ "geType\022\034\n\030MESSAGE_TYPE_UNSPECIFIED\020\000\022\n\n\006" +
+ "NORMAL\020\001\022\010\n\004FIFO\020\002\022\t\n\005DELAY\020\003\022\017\n\013TRANSAC" +
+ "TION\020\004*G\n\nDigestType\022\033\n\027DIGEST_TYPE_UNSP" +
+ "ECIFIED\020\000\022\t\n\005CRC32\020\001\022\007\n\003MD5\020\002\022\010\n\004SHA1\020\003*" +
+ "_\n\nClientType\022\033\n\027CLIENT_TYPE_UNSPECIFIED" +
+ "\020\000\022\014\n\010PRODUCER\020\001\022\021\n\rPUSH_CONSUMER\020\002\022\023\n\017S" +
+ "IMPLE_CONSUMER\020\003*<\n\010Encoding\022\030\n\024ENCODING" +
+ "_UNSPECIFIED\020\000\022\014\n\010IDENTITY\020\001\022\010\n\004GZIP\020\002*\342" +
+ "\t\n\004Code\022\024\n\020CODE_UNSPECIFIED\020\000\022\010\n\002OK\020\240\234\001\022" +
+ "\026\n\020MULTIPLE_RESULTS\020\260\352\001\022\021\n\013BAD_REQUEST\020\300" +
+ "\270\002\022\032\n\024ILLEGAL_ACCESS_POINT\020\301\270\002\022\023\n\rILLEGA" +
+ "L_TOPIC\020\302\270\002\022\034\n\026ILLEGAL_CONSUMER_GROUP\020\303\270" +
+ "\002\022\031\n\023ILLEGAL_MESSAGE_TAG\020\304\270\002\022\031\n\023ILLEGAL_" +
+ "MESSAGE_KEY\020\305\270\002\022\033\n\025ILLEGAL_MESSAGE_GROUP" +
+ "\020\306\270\002\022\"\n\034ILLEGAL_MESSAGE_PROPERTY_KEY\020\307\270\002" +
+ "\022\034\n\026INVALID_TRANSACTION_ID\020\310\270\002\022\030\n\022ILLEGA" +
+ "L_MESSAGE_ID\020\311\270\002\022\037\n\031ILLEGAL_FILTER_EXPRE" +
+ "SSION\020\312\270\002\022\034\n\026ILLEGAL_INVISIBLE_TIME\020\313\270\002\022" +
+ "\033\n\025ILLEGAL_DELIVERY_TIME\020\314\270\002\022\034\n\026INVALID_" +
+ "RECEIPT_HANDLE\020\315\270\002\022)\n#MESSAGE_PROPERTY_C" +
+ "ONFLICT_WITH_TYPE\020\316\270\002\022\036\n\030UNRECOGNIZED_CL" +
+ "IENT_TYPE\020\317\270\002\022\027\n\021MESSAGE_CORRUPTED\020\320\270\002\022\030" +
+ "\n\022CLIENT_ID_REQUIRED\020\321\270\002\022\022\n\014UNAUTHORIZED" +
+ "\020\244\271\002\022\026\n\020PAYMENT_REQUIRED\020\210\272\002\022\017\n\tFORBIDDE" +
+ "N\020\354\272\002\022\017\n\tNOT_FOUND\020\320\273\002\022\027\n\021MESSAGE_NOT_FO" +
+ "UND\020\321\273\002\022\025\n\017TOPIC_NOT_FOUND\020\322\273\002\022\036\n\030CONSUM" +
+ "ER_GROUP_NOT_FOUND\020\323\273\002\022\025\n\017REQUEST_TIMEOU" +
+ "T\020\340\276\002\022\027\n\021PAYLOAD_TOO_LARGE\020\324\302\002\022\034\n\026MESSAG" +
+ "E_BODY_TOO_LARGE\020\325\302\002\022\031\n\023PRECONDITION_FAI" +
+ "LED\020\260\316\002\022\027\n\021TOO_MANY_REQUESTS\020\224\317\002\022%\n\037REQU" +
+ "EST_HEADER_FIELDS_TOO_LARGE\020\334\320\002\022\"\n\034MESSA" +
+ "GE_PROPERTIES_TOO_LARGE\020\335\320\002\022\024\n\016INTERNAL_" +
+ "ERROR\020\320\206\003\022\033\n\025INTERNAL_SERVER_ERROR\020\321\206\003\022\026" +
+ "\n\020HA_NOT_AVAILABLE\020\322\206\003\022\025\n\017NOT_IMPLEMENTE" +
+ "D\020\264\207\003\022\023\n\rPROXY_TIMEOUT\020\340\211\003\022 \n\032MASTER_PER" +
+ "SISTENCE_TIMEOUT\020\341\211\003\022\037\n\031SLAVE_PERSISTENC" +
+ "E_TIMEOUT\020\342\211\003\022\021\n\013UNSUPPORTED\020\304\212\003\022\031\n\023VERS" +
+ "ION_UNSUPPORTED\020\305\212\003\022%\n\037VERIFY_FIFO_MESSA" +
+ "GE_UNSUPPORTED\020\306\212\003\022\037\n\031FAILED_TO_CONSUME_" +
+ "MESSAGE\020\340\324\003*\255\001\n\010Language\022\030\n\024LANGUAGE_UNS" +
+ "PECIFIED\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\005\022\n\n\006PYTHON\020\006\022\007\n\003" +
+ "PHP\020\007\022\013\n\007NODE_JS\020\010\022\010\n\004RUBY\020\t\022\017\n\013OBJECTIV" +
+ "E_C\020\n\022\010\n\004DART\020\013\022\n\n\006KOTLIN\020\014B;\n\022apache.ro" +
+ "cketmq.v2B\010MQDomainP\001\240\001\001\330\001\001\252\002\022Apache.Roc" +
+ "ketmq.V2b\006proto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,
@@ -341,6 +389,30 @@ public final class MQDomain {
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_UA_descriptor,
new java.lang.String[] { "Language", "Version", "Platform", "Hostname", });
+ internal_static_apache_rocketmq_v2_Settings_descriptor =
+ getDescriptor().getMessageTypes().get(16);
+ internal_static_apache_rocketmq_v2_Settings_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+ internal_static_apache_rocketmq_v2_Settings_descriptor,
+ new java.lang.String[] { "ClientType", "AccessPoint", "BackoffPolicy", "RequestTimeout", "Publishing", "Subscription", "UserAgent", "Metric", "PubSub", "ClientType", "AccessPoint", "BackoffPolicy", "RequestTimeout", });
+ internal_static_apache_rocketmq_v2_Publishing_descriptor =
+ getDescriptor().getMessageTypes().get(17);
+ internal_static_apache_rocketmq_v2_Publishing_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+ internal_static_apache_rocketmq_v2_Publishing_descriptor,
+ new java.lang.String[] { "Topics", "MaxBodySize", "ValidateMessageType", });
+ internal_static_apache_rocketmq_v2_Subscription_descriptor =
+ getDescriptor().getMessageTypes().get(18);
+ internal_static_apache_rocketmq_v2_Subscription_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+ internal_static_apache_rocketmq_v2_Subscription_descriptor,
+ new java.lang.String[] { "Group", "Subscriptions", "Fifo", "ReceiveBatchSize", "LongPollingTimeout", "Group", "Fifo", "ReceiveBatchSize", "LongPollingTimeout", });
+ internal_static_apache_rocketmq_v2_Metric_descriptor =
+ getDescriptor().getMessageTypes().get(19);
+ internal_static_apache_rocketmq_v2_Metric_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+ internal_static_apache_rocketmq_v2_Metric_descriptor,
+ new java.lang.String[] { "On", "Endpoints", "Endpoints", });
com.google.protobuf.TimestampProto.getDescriptor();
com.google.protobuf.DurationProto.getDescriptor();
}
diff --git a/src/main/java/apache/rocketmq/v2/MQService.java b/src/main/java/apache/rocketmq/v2/MQService.java
index 4fc0398..91da032 100644
--- a/src/main/java/apache/rocketmq/v2/MQService.java
+++ b/src/main/java/apache/rocketmq/v2/MQService.java
@@ -134,26 +134,6 @@ public final class MQService {
static final
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internal_static_apache_rocketmq_v2_RecoverOrphanedTransactionCommand_fieldAccessorTable;
- static final com.google.protobuf.Descriptors.Descriptor
- internal_static_apache_rocketmq_v2_Publishing_descriptor;
- static final
- com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internal_static_apache_rocketmq_v2_Publishing_fieldAccessorTable;
- static final com.google.protobuf.Descriptors.Descriptor
- internal_static_apache_rocketmq_v2_Subscription_descriptor;
- static final
- com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internal_static_apache_rocketmq_v2_Subscription_fieldAccessorTable;
- static final com.google.protobuf.Descriptors.Descriptor
- internal_static_apache_rocketmq_v2_Metric_descriptor;
- static final
- com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internal_static_apache_rocketmq_v2_Metric_fieldAccessorTable;
- static final com.google.protobuf.Descriptors.Descriptor
- internal_static_apache_rocketmq_v2_Settings_descriptor;
- static final
- com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internal_static_apache_rocketmq_v2_Settings_fieldAccessorTable;
static final com.google.protobuf.Descriptors.Descriptor
internal_static_apache_rocketmq_v2_TelemetryCommand_descriptor;
static final
@@ -267,93 +247,67 @@ public final class MQService {
"age\"$\n\023VerifyMessageResult\022\r\n\005nonce\030\001 \001(" +
"\t\"i\n!RecoverOrphanedTransactionCommand\022," +
"\n\007message\030\001 \001(\0132\033.apache.rocketmq.v2.Mes" +
- "sage\022\026\n\016transaction_id\030\002 \001(\t\"p\n\nPublishi" +
- "ng\022,\n\006topics\030\001 \003(\0132\034.apache.rocketmq.v2." +
- "Resource\022\025\n\rmax_body_size\030\002 \001(\005\022\035\n\025valid" +
- "ate_message_type\030\003 \001(\010\"\263\002\n\014Subscription\022" +
- "0\n\005group\030\001 \001(\0132\034.apache.rocketmq.v2.Reso" +
- "urceH\000\210\001\001\022<\n\rsubscriptions\030\002 \003(\0132%.apach" +
- "e.rocketmq.v2.SubscriptionEntry\022\021\n\004fifo\030" +
- "\003 \001(\010H\001\210\001\001\022\037\n\022receive_batch_size\030\004 \001(\005H\002" +
- "\210\001\001\022<\n\024long_polling_timeout\030\005 \001(\0132\031.goog" +
- "le.protobuf.DurationH\003\210\001\001B\010\n\006_groupB\007\n\005_" +
- "fifoB\025\n\023_receive_batch_sizeB\027\n\025_long_pol" +
- "ling_timeout\"Y\n\006Metric\022\n\n\002on\030\001 \001(\010\0225\n\ten" +
- "dpoints\030\002 \001(\0132\035.apache.rocketmq.v2.Endpo" +
- "intsH\000\210\001\001B\014\n\n_endpoints\"\220\004\n\010Settings\0228\n\013" +
- "client_type\030\001 \001(\0162\036.apache.rocketmq.v2.C" +
- "lientTypeH\001\210\001\001\0228\n\014access_point\030\002 \001(\0132\035.a" +
- "pache.rocketmq.v2.EndpointsH\002\210\001\001\022<\n\016back" +
- "off_policy\030\003 \001(\0132\037.apache.rocketmq.v2.Re" +
- "tryPolicyH\003\210\001\001\0227\n\017request_timeout\030\004 \001(\0132" +
- "\031.google.protobuf.DurationH\004\210\001\001\0224\n\npubli" +
- "shing\030\005 \001(\0132\036.apache.rocketmq.v2.Publish" +
- "ingH\000\0228\n\014subscription\030\006 \001(\0132 .apache.roc" +
- "ketmq.v2.SubscriptionH\000\022*\n\nuser_agent\030\007 " +
- "\001(\0132\026.apache.rocketmq.v2.UA\022*\n\006metric\030\010 " +
- "\001(\0132\032.apache.rocketmq.v2.MetricB\t\n\007pub_s" +
- "ubB\016\n\014_client_typeB\017\n\r_access_pointB\021\n\017_" +
- "backoff_policyB\022\n\020_request_timeout\"\252\004\n\020T" +
- "elemetryCommand\022/\n\006status\030\001 \001(\0132\032.apache" +
- ".rocketmq.v2.StatusH\001\210\001\001\0220\n\010settings\030\002 \001" +
- "(\0132\034.apache.rocketmq.v2.SettingsH\000\022B\n\022th" +
- "read_stack_trace\030\003 \001(\0132$.apache.rocketmq" +
- ".v2.ThreadStackTraceH\000\022H\n\025verify_message" +
- "_result\030\004 \001(\0132\'.apache.rocketmq.v2.Verif" +
- "yMessageResultH\000\022e\n$recover_orphaned_tra" +
- "nsaction_command\030\005 \001(\01325.apache.rocketmq" +
- ".v2.RecoverOrphanedTransactionCommandH\000\022" +
- "\\\n print_thread_stack_trace_command\030\006 \001(" +
- "\01320.apache.rocketmq.v2.PrintThreadStackT" +
- "raceCommandH\000\022J\n\026verify_message_command\030" +
- "\007 \001(\0132(.apache.rocketmq.v2.VerifyMessage" +
- "CommandH\000B\t\n\007commandB\t\n\007_status\"\\\n\036Notif" +
- "yClientTerminationRequest\0220\n\005group\030\001 \001(\013" +
- "2\034.apache.rocketmq.v2.ResourceH\000\210\001\001B\010\n\006_" +
- "group\"M\n\037NotifyClientTerminationResponse" +
- "\022*\n\006status\030\001 \001(\0132\032.apache.rocketmq.v2.St" +
- "atus\"\335\001\n\036ChangeInvisibleDurationRequest\022" +
- "+\n\005group\030\001 \001(\0132\034.apache.rocketmq.v2.Reso" +
- "urce\022+\n\005topic\030\002 \001(\0132\034.apache.rocketmq.v2" +
- ".Resource\022\026\n\016receipt_handle\030\003 \001(\t\0225\n\022inv" +
- "isible_duration\030\004 \001(\0132\031.google.protobuf." +
- "Duration\022\022\n\nmessage_id\030\005 \001(\t\"e\n\037ChangeIn" +
- "visibleDurationResponse\022*\n\006status\030\001 \001(\0132" +
- "\032.apache.rocketmq.v2.Status\022\026\n\016receipt_h" +
- "andle\030\002 \001(\t2\340\t\n\020MessagingService\022]\n\nQuer" +
- "yRoute\022%.apache.rocketmq.v2.QueryRouteRe" +
- "quest\032&.apache.rocketmq.v2.QueryRouteRes" +
- "ponse\"\000\022Z\n\tHeartbeat\022$.apache.rocketmq.v" +
- "2.HeartbeatRequest\032%.apache.rocketmq.v2." +
- "HeartbeatResponse\"\000\022`\n\013SendMessage\022&.apa" +
- "che.rocketmq.v2.SendMessageRequest\032\'.apa" +
- "che.rocketmq.v2.SendMessageResponse\"\000\022l\n" +
- "\017QueryAssignment\022*.apache.rocketmq.v2.Qu" +
- "eryAssignmentRequest\032+.apache.rocketmq.v" +
- "2.QueryAssignmentResponse\"\000\022k\n\016ReceiveMe" +
- "ssage\022).apache.rocketmq.v2.ReceiveMessag" +
- "eRequest\032*.apache.rocketmq.v2.ReceiveMes" +
- "sageResponse\"\0000\001\022]\n\nAckMessage\022%.apache." +
- "rocketmq.v2.AckMessageRequest\032&.apache.r" +
- "ocketmq.v2.AckMessageResponse\"\000\022\234\001\n\037Forw" +
- "ardMessageToDeadLetterQueue\022:.apache.roc" +
- "ketmq.v2.ForwardMessageToDeadLetterQueue" +
- "Request\032;.apache.rocketmq.v2.ForwardMess" +
- "ageToDeadLetterQueueResponse\"\000\022i\n\016EndTra" +
- "nsaction\022).apache.rocketmq.v2.EndTransac" +
- "tionRequest\032*.apache.rocketmq.v2.EndTran" +
- "sactionResponse\"\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"
+ "sage\022\026\n\016transaction_id\030\002 \001(\t\"\252\004\n\020Telemet" +
+ "ryCommand\022/\n\006status\030\001 \001(\0132\032.apache.rocke" +
+ "tmq.v2.StatusH\001\210\001\001\0220\n\010settings\030\002 \001(\0132\034.a" +
+ "pache.rocketmq.v2.SettingsH\000\022B\n\022thread_s" +
+ "tack_trace\030\003 \001(\0132$.apache.rocketmq.v2.Th" +
+ "readStackTraceH\000\022H\n\025verify_message_resul" +
+ "t\030\004 \001(\0132\'.apache.rocketmq.v2.VerifyMessa" +
+ "geResultH\000\022e\n$recover_orphaned_transacti" +
+ "on_command\030\005 \001(\01325.apache.rocketmq.v2.Re" +
+ "coverOrphanedTransactionCommandH\000\022\\\n pri" +
+ "nt_thread_stack_trace_command\030\006 \001(\01320.ap" +
+ "ache.rocketmq.v2.PrintThreadStackTraceCo" +
+ "mmandH\000\022J\n\026verify_message_command\030\007 \001(\0132" +
+ "(.apache.rocketmq.v2.VerifyMessageComman" +
+ "dH\000B\t\n\007commandB\t\n\007_status\"\\\n\036NotifyClien" +
+ "tTerminationRequest\0220\n\005group\030\001 \001(\0132\034.apa" +
+ "che.rocketmq.v2.ResourceH\000\210\001\001B\010\n\006_group\"" +
+ "M\n\037NotifyClientTerminationResponse\022*\n\006st" +
+ "atus\030\001 \001(\0132\032.apache.rocketmq.v2.Status\"\335" +
+ "\001\n\036ChangeInvisibleDurationRequest\022+\n\005gro" +
+ "up\030\001 \001(\0132\034.apache.rocketmq.v2.Resource\022+" +
+ "\n\005topic\030\002 \001(\0132\034.apache.rocketmq.v2.Resou" +
+ "rce\022\026\n\016receipt_handle\030\003 \001(\t\0225\n\022invisible" +
+ "_duration\030\004 \001(\0132\031.google.protobuf.Durati" +
+ "on\022\022\n\nmessage_id\030\005 \001(\t\"e\n\037ChangeInvisibl" +
+ "eDurationResponse\022*\n\006status\030\001 \001(\0132\032.apac" +
+ "he.rocketmq.v2.Status\022\026\n\016receipt_handle\030" +
+ "\002 \001(\t2\340\t\n\020MessagingService\022]\n\nQueryRoute" +
+ "\022%.apache.rocketmq.v2.QueryRouteRequest\032" +
+ "&.apache.rocketmq.v2.QueryRouteResponse\"" +
+ "\000\022Z\n\tHeartbeat\022$.apache.rocketmq.v2.Hear" +
+ "tbeatRequest\032%.apache.rocketmq.v2.Heartb" +
+ "eatResponse\"\000\022`\n\013SendMessage\022&.apache.ro" +
+ "cketmq.v2.SendMessageRequest\032\'.apache.ro" +
+ "cketmq.v2.SendMessageResponse\"\000\022l\n\017Query" +
+ "Assignment\022*.apache.rocketmq.v2.QueryAss" +
+ "ignmentRequest\032+.apache.rocketmq.v2.Quer" +
+ "yAssignmentResponse\"\000\022k\n\016ReceiveMessage\022" +
+ ").apache.rocketmq.v2.ReceiveMessageReque" +
+ "st\032*.apache.rocketmq.v2.ReceiveMessageRe" +
+ "sponse\"\0000\001\022]\n\nAckMessage\022%.apache.rocket" +
+ "mq.v2.AckMessageRequest\032&.apache.rocketm" +
+ "q.v2.AckMessageResponse\"\000\022\234\001\n\037ForwardMes" +
+ "sageToDeadLetterQueue\022:.apache.rocketmq." +
+ "v2.ForwardMessageToDeadLetterQueueReques" +
+ "t\032;.apache.rocketmq.v2.ForwardMessageToD" +
+ "eadLetterQueueResponse\"\000\022i\n\016EndTransacti" +
+ "on\022).apache.rocketmq.v2.EndTransactionRe" +
+ "quest\032*.apache.rocketmq.v2.EndTransactio" +
+ "nResponse\"\000\022]\n\tTelemetry\022$.apache.rocket" +
+ "mq.v2.TelemetryCommand\032$.apache.rocketmq" +
+ ".v2.TelemetryCommand\"\000(\0010\001\022\204\001\n\027NotifyCli" +
+ "entTermination\0222.apache.rocketmq.v2.Noti" +
+ "fyClientTerminationRequest\0323.apache.rock" +
+ "etmq.v2.NotifyClientTerminationResponse\"" +
+ "\000\022\204\001\n\027ChangeInvisibleDuration\0222.apache.r" +
+ "ocketmq.v2.ChangeInvisibleDurationReques" +
+ "t\0323.apache.rocketmq.v2.ChangeInvisibleDu" +
+ "rationResponse\"\000B<\n\022apache.rocketmq.v2B\t" +
+ "MQServiceP\001\240\001\001\330\001\001\252\002\022Apache.Rocketmq.V2b\006" +
+ "proto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,
@@ -506,56 +460,32 @@ public final class MQService {
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_RecoverOrphanedTransactionCommand_descriptor,
new java.lang.String[] { "Message", "TransactionId", });
- internal_static_apache_rocketmq_v2_Publishing_descriptor =
- getDescriptor().getMessageTypes().get(24);
- internal_static_apache_rocketmq_v2_Publishing_fieldAccessorTable = new
- com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
- internal_static_apache_rocketmq_v2_Publishing_descriptor,
- new java.lang.String[] { "Topics", "MaxBodySize", "ValidateMessageType", });
- internal_static_apache_rocketmq_v2_Subscription_descriptor =
- getDescriptor().getMessageTypes().get(25);
- internal_static_apache_rocketmq_v2_Subscription_fieldAccessorTable = new
- com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
- internal_static_apache_rocketmq_v2_Subscription_descriptor,
- new java.lang.String[] { "Group", "Subscriptions", "Fifo", "ReceiveBatchSize", "LongPollingTimeout", "Group", "Fifo", "ReceiveBatchSize", "LongPollingTimeout", });
- internal_static_apache_rocketmq_v2_Metric_descriptor =
- getDescriptor().getMessageTypes().get(26);
- internal_static_apache_rocketmq_v2_Metric_fieldAccessorTable = new
- com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
- internal_static_apache_rocketmq_v2_Metric_descriptor,
- new java.lang.String[] { "On", "Endpoints", "Endpoints", });
- internal_static_apache_rocketmq_v2_Settings_descriptor =
- getDescriptor().getMessageTypes().get(27);
- internal_static_apache_rocketmq_v2_Settings_fieldAccessorTable = new
- com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
- internal_static_apache_rocketmq_v2_Settings_descriptor,
- new java.lang.String[] { "ClientType", "AccessPoint", "BackoffPolicy", "RequestTimeout", "Publishing", "Subscription", "UserAgent", "Metric", "PubSub", "ClientType", "AccessPoint", "BackoffPolicy", "RequestTimeout", });
internal_static_apache_rocketmq_v2_TelemetryCommand_descriptor =
- getDescriptor().getMessageTypes().get(28);
+ getDescriptor().getMessageTypes().get(24);
internal_static_apache_rocketmq_v2_TelemetryCommand_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_TelemetryCommand_descriptor,
new java.lang.String[] { "Status", "Settings", "ThreadStackTrace", "VerifyMessageResult", "RecoverOrphanedTransactionCommand", "PrintThreadStackTraceCommand", "VerifyMessageCommand", "Command", "Status", });
internal_static_apache_rocketmq_v2_NotifyClientTerminationRequest_descriptor =
- getDescriptor().getMessageTypes().get(29);
+ getDescriptor().getMessageTypes().get(25);
internal_static_apache_rocketmq_v2_NotifyClientTerminationRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_NotifyClientTerminationRequest_descriptor,
new java.lang.String[] { "Group", "Group", });
internal_static_apache_rocketmq_v2_NotifyClientTerminationResponse_descriptor =
- getDescriptor().getMessageTypes().get(30);
+ getDescriptor().getMessageTypes().get(26);
internal_static_apache_rocketmq_v2_NotifyClientTerminationResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_NotifyClientTerminationResponse_descriptor,
new java.lang.String[] { "Status", });
internal_static_apache_rocketmq_v2_ChangeInvisibleDurationRequest_descriptor =
- getDescriptor().getMessageTypes().get(31);
+ getDescriptor().getMessageTypes().get(27);
internal_static_apache_rocketmq_v2_ChangeInvisibleDurationRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_ChangeInvisibleDurationRequest_descriptor,
new java.lang.String[] { "Group", "Topic", "ReceiptHandle", "InvisibleDuration", "MessageId", });
internal_static_apache_rocketmq_v2_ChangeInvisibleDurationResponse_descriptor =
- getDescriptor().getMessageTypes().get(32);
+ getDescriptor().getMessageTypes().get(28);
internal_static_apache_rocketmq_v2_ChangeInvisibleDurationResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_apache_rocketmq_v2_ChangeInvisibleDurationResponse_descriptor,
diff --git a/src/main/java/apache/rocketmq/v2/Metric.java b/src/main/java/apache/rocketmq/v2/Metric.java
index d96c59e..306f017 100644
--- a/src/main/java/apache/rocketmq/v2/Metric.java
+++ b/src/main/java/apache/rocketmq/v2/Metric.java
@@ -1,5 +1,5 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
-// source: apache/rocketmq/v2/service.proto
+// source: apache/rocketmq/v2/definition.proto
package apache.rocketmq.v2;
@@ -88,13 +88,13 @@ 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_Metric_descriptor;
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Metric_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Metric_fieldAccessorTable
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Metric_fieldAccessorTable
.ensureFieldAccessorsInitialized(
apache.rocketmq.v2.Metric.class, apache.rocketmq.v2.Metric.Builder.class);
}
@@ -334,13 +334,13 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.MetricOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Metric_descriptor;
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Metric_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Metric_fieldAccessorTable
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Metric_fieldAccessorTable
.ensureFieldAccessorsInitialized(
apache.rocketmq.v2.Metric.class, apache.rocketmq.v2.Metric.Builder.class);
}
@@ -378,7 +378,7 @@ 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_Metric_descriptor;
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Metric_descriptor;
}
@java.lang.Override
diff --git a/src/main/java/apache/rocketmq/v2/MetricOrBuilder.java b/src/main/java/apache/rocketmq/v2/MetricOrBuilder.java
index 577bf9c..8ecca71 100644
--- a/src/main/java/apache/rocketmq/v2/MetricOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/MetricOrBuilder.java
@@ -1,5 +1,5 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
-// source: apache/rocketmq/v2/service.proto
+// source: apache/rocketmq/v2/definition.proto
package apache.rocketmq.v2;
diff --git a/src/main/java/apache/rocketmq/v2/Publishing.java b/src/main/java/apache/rocketmq/v2/Publishing.java
index bea77d1..51855cd 100644
--- a/src/main/java/apache/rocketmq/v2/Publishing.java
+++ b/src/main/java/apache/rocketmq/v2/Publishing.java
@@ -1,5 +1,5 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
-// source: apache/rocketmq/v2/service.proto
+// source: apache/rocketmq/v2/definition.proto
package apache.rocketmq.v2;
@@ -93,13 +93,13 @@ 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_Publishing_descriptor;
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Publishing_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Publishing_fieldAccessorTable
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Publishing_fieldAccessorTable
.ensureFieldAccessorsInitialized(
apache.rocketmq.v2.Publishing.class, apache.rocketmq.v2.Publishing.Builder.class);
}
@@ -396,13 +396,13 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.PublishingOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Publishing_descriptor;
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Publishing_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Publishing_fieldAccessorTable
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Publishing_fieldAccessorTable
.ensureFieldAccessorsInitialized(
apache.rocketmq.v2.Publishing.class, apache.rocketmq.v2.Publishing.Builder.class);
}
@@ -442,7 +442,7 @@ 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_Publishing_descriptor;
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Publishing_descriptor;
}
@java.lang.Override
diff --git a/src/main/java/apache/rocketmq/v2/PublishingOrBuilder.java b/src/main/java/apache/rocketmq/v2/PublishingOrBuilder.java
index 4e1dc32..21948d4 100644
--- a/src/main/java/apache/rocketmq/v2/PublishingOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/PublishingOrBuilder.java
@@ -1,5 +1,5 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
-// source: apache/rocketmq/v2/service.proto
+// source: apache/rocketmq/v2/definition.proto
package apache.rocketmq.v2;
diff --git a/src/main/java/apache/rocketmq/v2/Settings.java b/src/main/java/apache/rocketmq/v2/Settings.java
index 9229f97..08f7d4f 100644
--- a/src/main/java/apache/rocketmq/v2/Settings.java
+++ b/src/main/java/apache/rocketmq/v2/Settings.java
@@ -1,5 +1,5 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
-// source: apache/rocketmq/v2/service.proto
+// source: apache/rocketmq/v2/definition.proto
package apache.rocketmq.v2;
@@ -170,13 +170,13 @@ 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_Settings_descriptor;
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Settings_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Settings_fieldAccessorTable
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Settings_fieldAccessorTable
.ensureFieldAccessorsInitialized(
apache.rocketmq.v2.Settings.class, apache.rocketmq.v2.Settings.Builder.class);
}
@@ -797,13 +797,13 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.SettingsOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Settings_descriptor;
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Settings_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Settings_fieldAccessorTable
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Settings_fieldAccessorTable
.ensureFieldAccessorsInitialized(
apache.rocketmq.v2.Settings.class, apache.rocketmq.v2.Settings.Builder.class);
}
@@ -869,7 +869,7 @@ 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_Settings_descriptor;
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Settings_descriptor;
}
@java.lang.Override
diff --git a/src/main/java/apache/rocketmq/v2/SettingsOrBuilder.java b/src/main/java/apache/rocketmq/v2/SettingsOrBuilder.java
index 8c955a7..050e4f2 100644
--- a/src/main/java/apache/rocketmq/v2/SettingsOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/SettingsOrBuilder.java
@@ -1,5 +1,5 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
-// source: apache/rocketmq/v2/service.proto
+// source: apache/rocketmq/v2/definition.proto
package apache.rocketmq.v2;
diff --git a/src/main/java/apache/rocketmq/v2/Subscription.java b/src/main/java/apache/rocketmq/v2/Subscription.java
index 36a32c9..baff4ac 100644
--- a/src/main/java/apache/rocketmq/v2/Subscription.java
+++ b/src/main/java/apache/rocketmq/v2/Subscription.java
@@ -1,5 +1,5 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
-// source: apache/rocketmq/v2/service.proto
+// source: apache/rocketmq/v2/definition.proto
package apache.rocketmq.v2;
@@ -119,13 +119,13 @@ 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_Subscription_descriptor;
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Subscription_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Subscription_fieldAccessorTable
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Subscription_fieldAccessorTable
.ensureFieldAccessorsInitialized(
apache.rocketmq.v2.Subscription.class, apache.rocketmq.v2.Subscription.Builder.class);
}
@@ -571,13 +571,13 @@ private static final long serialVersionUID = 0L;
apache.rocketmq.v2.SubscriptionOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Subscription_descriptor;
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Subscription_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
- return apache.rocketmq.v2.MQService.internal_static_apache_rocketmq_v2_Subscription_fieldAccessorTable
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Subscription_fieldAccessorTable
.ensureFieldAccessorsInitialized(
apache.rocketmq.v2.Subscription.class, apache.rocketmq.v2.Subscription.Builder.class);
}
@@ -631,7 +631,7 @@ 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_Subscription_descriptor;
+ return apache.rocketmq.v2.MQDomain.internal_static_apache_rocketmq_v2_Subscription_descriptor;
}
@java.lang.Override
diff --git a/src/main/java/apache/rocketmq/v2/SubscriptionOrBuilder.java b/src/main/java/apache/rocketmq/v2/SubscriptionOrBuilder.java
index f112d38..41390a9 100644
--- a/src/main/java/apache/rocketmq/v2/SubscriptionOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/SubscriptionOrBuilder.java
@@ -1,5 +1,5 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
-// source: apache/rocketmq/v2/service.proto
+// source: apache/rocketmq/v2/definition.proto
package apache.rocketmq.v2;
diff --git a/src/main/resources/proto/apache/rocketmq/v2/definition.proto b/src/main/resources/proto/apache/rocketmq/v2/definition.proto
index ffc3839..9d573f8 100644
--- a/src/main/resources/proto/apache/rocketmq/v2/definition.proto
+++ b/src/main/resources/proto/apache/rocketmq/v2/definition.proto
@@ -433,6 +433,13 @@ enum Language {
DOT_NET = 3;
GOLANG = 4;
RUST = 5;
+ PYTHON = 6;
+ PHP = 7;
+ NODE_JS = 8;
+ RUBY = 9;
+ OBJECTIVE_C = 10;
+ DART = 11;
+ KOTLIN = 12;
}
// User Agent
@@ -448,4 +455,90 @@ message UA {
// Hostname of the node
string hostname = 4;
+}
+
+message Settings {
+ // Configurations for all clients.
+ optional ClientType client_type = 1;
+
+ optional Endpoints access_point = 2;
+
+ // If publishing of messages encounters throttling or server internal errors,
+ // publishers should implement automatic retries after progressive longer
+ // back-offs for consecutive errors.
+ //
+ // When processing message fails, `backoff_policy` describes an interval
+ // after which the message should be available to consume again.
+ //
+ // For FIFO messages, the interval should be relatively small because
+ // messages of the same message group would not be readily available utill
+ // the prior one depletes its lifecycle.
+ optional RetryPolicy backoff_policy = 3;
+
+ // Request timeout for RPCs excluding long-polling.
+ optional google.protobuf.Duration request_timeout = 4;
+
+ oneof pub_sub {
+ Publishing publishing = 5;
+
+ Subscription subscription = 6;
+ }
+
+ // User agent details
+ UA user_agent = 7;
+
+ Metric metric = 8;
+}
+
+message Publishing {
+ // Publishing settings below here is appointed by client, thus it is
+ // unnecessary for server to push at present.
+ //
+ // List of topics to which messages will publish to.
+ repeated Resource topics = 1;
+
+ // If the message body size exceeds `max_body_size`, broker servers would
+ // reject the request. As a result, it is advisable that Producer performs
+ // client-side check validation.
+ int32 max_body_size = 2;
+
+ // When `validate_message_type` flag set `false`, no need to validate message's type
+ // with messageQueue's `accept_message_types` before publising.
+ bool validate_message_type = 3;
+}
+
+message Subscription {
+ // Subscription settings below here is appointed by client, thus it is
+ // unnecessary for server to push at present.
+ //
+ // Consumer group.
+ optional Resource group = 1;
+
+ // Subscription for consumer.
+ repeated SubscriptionEntry subscriptions = 2;
+
+ // Subscription settings below here are from server, it is essential for
+ // server to push.
+ //
+ // When FIFO flag is `true`, messages of the same message group are processed
+ // in first-in-first-out manner.
+ //
+ // Brokers will not deliver further messages of the same group utill prior
+ // ones are completely acknowledged.
+ optional bool fifo = 3;
+
+ // Message receive batch size here is essential for push consumer.
+ optional int32 receive_batch_size = 4;
+
+ // Long-polling timeout for `ReceiveMessageRequest`, which is essential for
+ // push consumer.
+ optional google.protobuf.Duration long_polling_timeout = 5;
+}
+
+message Metric {
+ // Indicates that if client should export local metrics to server.
+ bool on = 1;
+
+ // The endpoint that client metrics should be exported to, which is required if the switch is on.
+ optional Endpoints endpoints = 2;
}
\ No newline at end of file
diff --git a/src/main/resources/proto/apache/rocketmq/v2/service.proto b/src/main/resources/proto/apache/rocketmq/v2/service.proto
index 6a7456b..8e880e2 100644
--- a/src/main/resources/proto/apache/rocketmq/v2/service.proto
+++ b/src/main/resources/proto/apache/rocketmq/v2/service.proto
@@ -187,92 +187,6 @@ message RecoverOrphanedTransactionCommand {
string transaction_id = 2;
}
-message Publishing {
- // Publishing settings below here is appointed by client, thus it is
- // unnecessary for server to push at present.
- //
- // List of topics to which messages will publish to.
- repeated Resource topics = 1;
-
- // If the message body size exceeds `max_body_size`, broker servers would
- // reject the request. As a result, it is advisable that Producer performs
- // client-side check validation.
- int32 max_body_size = 2;
-
- // When `validate_message_type` flag set `false`, no need to validate message's type
- // with messageQueue's `accept_message_types` before publising.
- bool validate_message_type = 3;
-}
-
-message Subscription {
- // Subscription settings below here is appointed by client, thus it is
- // unnecessary for server to push at present.
- //
- // Consumer group.
- optional Resource group = 1;
-
- // Subscription for consumer.
- repeated SubscriptionEntry subscriptions = 2;
-
- // Subscription settings below here are from server, it is essential for
- // server to push.
- //
- // When FIFO flag is `true`, messages of the same message group are processed
- // in first-in-first-out manner.
- //
- // Brokers will not deliver further messages of the same group utill prior
- // ones are completely acknowledged.
- optional bool fifo = 3;
-
- // Message receive batch size here is essential for push consumer.
- optional int32 receive_batch_size = 4;
-
- // Long-polling timeout for `ReceiveMessageRequest`, which is essential for
- // push consumer.
- optional google.protobuf.Duration long_polling_timeout = 5;
-}
-
-message Metric {
- // Indicates that if client should export local metrics to server.
- bool on = 1;
-
- // The endpoint that client metrics should be exported to, which is required if the switch is on.
- optional Endpoints endpoints = 2;
-}
-
-message Settings {
- // Configurations for all clients.
- optional ClientType client_type = 1;
-
- optional Endpoints access_point = 2;
-
- // If publishing of messages encounters throttling or server internal errors,
- // publishers should implement automatic retries after progressive longer
- // back-offs for consecutive errors.
- //
- // When processing message fails, `backoff_policy` describes an interval
- // after which the message should be available to consume again.
- //
- // For FIFO messages, the interval should be relatively small because
- // messages of the same message group would not be readily available utill
- // the prior one depletes its lifecycle.
- optional RetryPolicy backoff_policy = 3;
-
- // Request timeout for RPCs excluding long-polling.
- optional google.protobuf.Duration request_timeout = 4;
-
- oneof pub_sub {
- Publishing publishing = 5;
-
- Subscription subscription = 6;
- }
-
- // User agent details
- UA user_agent = 7;
-
- Metric metric = 8;
-}
-
message TelemetryCommand {
optional Status status = 1;