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: 凌楚 <[email protected]> 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;
