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 10fdc3b9846bd553c7b4bfe8c0b52b9b8d66a256 Author: 凌楚 <[email protected]> AuthorDate: Thu May 26 17:07:19 2022 +0800 Apply IDL update --- src/main/java/apache/rocketmq/v2/MQService.java | 154 +++++++++---------- src/main/java/apache/rocketmq/v2/Metric.java | 170 ++++++++++----------- .../java/apache/rocketmq/v2/MetricOrBuilder.java | 16 +- .../proto/apache/rocketmq/v2/service.proto | 3 +- 4 files changed, 172 insertions(+), 171 deletions(-) diff --git a/src/main/java/apache/rocketmq/v2/MQService.java b/src/main/java/apache/rocketmq/v2/MQService.java index 7d7e3bf..319d4f0 100644 --- a/src/main/java/apache/rocketmq/v2/MQService.java +++ b/src/main/java/apache/rocketmq/v2/MQService.java @@ -279,82 +279,82 @@ public final class MQService { "ze\030\004 \001(\005H\002\210\001\001\022<\n\024long_polling_timeout\030\005 " + "\001(\0132\031.google.protobuf.DurationH\003\210\001\001B\010\n\006_" + "groupB\007\n\005_fifoB\025\n\023_receive_batch_sizeB\027\n" + - "\025_long_polling_timeout\"g\n\006Metric\022\n\n\002on\030\001" + - " \001(\010\022<\n\020metric_endpoints\030\002 \001(\0132\035.apache." + - "rocketmq.v2.EndpointsH\000\210\001\001B\023\n\021_metric_en" + - "dpoints\"\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.v" + - "2.EndpointsH\002\210\001\001\022<\n\016backoff_policy\030\003 \001(\013" + - "2\037.apache.rocketmq.v2.RetryPolicyH\003\210\001\001\0227" + - "\n\017request_timeout\030\004 \001(\0132\031.google.protobu" + - "f.DurationH\004\210\001\001\0224\n\npublishing\030\005 \001(\0132\036.ap" + - "ache.rocketmq.v2.PublishingH\000\0228\n\014subscri" + - "ption\030\006 \001(\0132 .apache.rocketmq.v2.Subscri" + - "ptionH\000\022*\n\nuser_agent\030\007 \001(\0132\026.apache.roc" + - "ketmq.v2.UA\022*\n\006metric\030\010 \001(\0132\032.apache.roc" + - "ketmq.v2.MetricB\t\n\007pub_subB\016\n\014_client_ty" + - "peB\017\n\r_access_pointB\021\n\017_backoff_policyB\022" + - "\n\020_request_timeout\"\252\004\n\020TelemetryCommand\022" + - "/\n\006status\030\001 \001(\0132\032.apache.rocketmq.v2.Sta" + - "tusH\001\210\001\001\0220\n\010settings\030\002 \001(\0132\034.apache.rock" + - "etmq.v2.SettingsH\000\022B\n\022thread_stack_trace" + - "\030\003 \001(\0132$.apache.rocketmq.v2.ThreadStackT" + - "raceH\000\022H\n\025verify_message_result\030\004 \001(\0132\'." + - "apache.rocketmq.v2.VerifyMessageResultH\000" + - "\022e\n$recover_orphaned_transaction_command" + - "\030\005 \001(\01325.apache.rocketmq.v2.RecoverOrpha" + - "nedTransactionCommandH\000\022\\\n print_thread_" + - "stack_trace_command\030\006 \001(\01320.apache.rocke" + - "tmq.v2.PrintThreadStackTraceCommandH\000\022J\n" + - "\026verify_message_command\030\007 \001(\0132(.apache.r" + - "ocketmq.v2.VerifyMessageCommandH\000B\t\n\007com" + - "mandB\t\n\007_status\"\\\n\036NotifyClientTerminati" + - "onRequest\0220\n\005group\030\001 \001(\0132\034.apache.rocket" + - "mq.v2.ResourceH\000\210\001\001B\010\n\006_group\"M\n\037NotifyC" + - "lientTerminationResponse\022*\n\006status\030\001 \001(\013" + - "2\032.apache.rocketmq.v2.Status\"\335\001\n\036ChangeI" + - "nvisibleDurationRequest\022+\n\005group\030\001 \001(\0132\034" + - ".apache.rocketmq.v2.Resource\022+\n\005topic\030\002 " + - "\001(\0132\034.apache.rocketmq.v2.Resource\022\026\n\016rec" + - "eipt_handle\030\003 \001(\t\0225\n\022invisible_duration\030" + - "\004 \001(\0132\031.google.protobuf.Duration\022\022\n\nmess" + - "age_id\030\005 \001(\t\"e\n\037ChangeInvisibleDurationR" + - "esponse\022*\n\006status\030\001 \001(\0132\032.apache.rocketm" + - "q.v2.Status\022\026\n\016receipt_handle\030\002 \001(\t2\340\t\n\020" + - "MessagingService\022]\n\nQueryRoute\022%.apache." + - "rocketmq.v2.QueryRouteRequest\032&.apache.r" + - "ocketmq.v2.QueryRouteResponse\"\000\022Z\n\tHeart" + - "beat\022$.apache.rocketmq.v2.HeartbeatReque" + - "st\032%.apache.rocketmq.v2.HeartbeatRespons" + - "e\"\000\022`\n\013SendMessage\022&.apache.rocketmq.v2." + - "SendMessageRequest\032\'.apache.rocketmq.v2." + - "SendMessageResponse\"\000\022l\n\017QueryAssignment" + - "\022*.apache.rocketmq.v2.QueryAssignmentReq" + - "uest\032+.apache.rocketmq.v2.QueryAssignmen" + - "tResponse\"\000\022k\n\016ReceiveMessage\022).apache.r" + - "ocketmq.v2.ReceiveMessageRequest\032*.apach" + - "e.rocketmq.v2.ReceiveMessageResponse\"\0000\001" + - "\022]\n\nAckMessage\022%.apache.rocketmq.v2.AckM" + - "essageRequest\032&.apache.rocketmq.v2.AckMe" + - "ssageResponse\"\000\022\234\001\n\037ForwardMessageToDead" + - "LetterQueue\022:.apache.rocketmq.v2.Forward" + - "MessageToDeadLetterQueueRequest\032;.apache" + - ".rocketmq.v2.ForwardMessageToDeadLetterQ" + - "ueueResponse\"\000\022i\n\016EndTransaction\022).apach" + - "e.rocketmq.v2.EndTransactionRequest\032*.ap" + - "ache.rocketmq.v2.EndTransactionResponse\"" + - "\000\022]\n\tTelemetry\022$.apache.rocketmq.v2.Tele" + - "metryCommand\032$.apache.rocketmq.v2.Teleme" + - "tryCommand\"\000(\0010\001\022\204\001\n\027NotifyClientTermina" + - "tion\0222.apache.rocketmq.v2.NotifyClientTe" + - "rminationRequest\0323.apache.rocketmq.v2.No" + - "tifyClientTerminationResponse\"\000\022\204\001\n\027Chan" + - "geInvisibleDuration\0222.apache.rocketmq.v2" + - ".ChangeInvisibleDurationRequest\0323.apache" + - ".rocketmq.v2.ChangeInvisibleDurationResp" + - "onse\"\000B<\n\022apache.rocketmq.v2B\tMQServiceP" + - "\001\240\001\001\330\001\001\252\002\022Apache.Rocketmq.V2b\006proto3" + "\025_long_polling_timeout\"Y\n\006Metric\022\n\n\002on\030\001" + + " \001(\010\0225\n\tendpoints\030\002 \001(\0132\035.apache.rocketm" + + "q.v2.EndpointsH\000\210\001\001B\014\n\n_endpoints\"\220\004\n\010Se" + + "ttings\0228\n\013client_type\030\001 \001(\0162\036.apache.roc" + + "ketmq.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.rock" + + "etmq.v2.RetryPolicyH\003\210\001\001\0227\n\017request_time" + + "out\030\004 \001(\0132\031.google.protobuf.DurationH\004\210\001" + + "\001\0224\n\npublishing\030\005 \001(\0132\036.apache.rocketmq." + + "v2.PublishingH\000\0228\n\014subscription\030\006 \001(\0132 ." + + "apache.rocketmq.v2.SubscriptionH\000\022*\n\nuse" + + "r_agent\030\007 \001(\0132\026.apache.rocketmq.v2.UA\022*\n" + + "\006metric\030\010 \001(\0132\032.apache.rocketmq.v2.Metri" + + "cB\t\n\007pub_subB\016\n\014_client_typeB\017\n\r_access_" + + "pointB\021\n\017_backoff_policyB\022\n\020_request_tim" + + "eout\"\252\004\n\020TelemetryCommand\022/\n\006status\030\001 \001(" + + "\0132\032.apache.rocketmq.v2.StatusH\001\210\001\001\0220\n\010se" + + "ttings\030\002 \001(\0132\034.apache.rocketmq.v2.Settin" + + "gsH\000\022B\n\022thread_stack_trace\030\003 \001(\0132$.apach" + + "e.rocketmq.v2.ThreadStackTraceH\000\022H\n\025veri" + + "fy_message_result\030\004 \001(\0132\'.apache.rocketm" + + "q.v2.VerifyMessageResultH\000\022e\n$recover_or" + + "phaned_transaction_command\030\005 \001(\01325.apach" + + "e.rocketmq.v2.RecoverOrphanedTransaction" + + "CommandH\000\022\\\n print_thread_stack_trace_co" + + "mmand\030\006 \001(\01320.apache.rocketmq.v2.PrintTh" + + "readStackTraceCommandH\000\022J\n\026verify_messag" + + "e_command\030\007 \001(\0132(.apache.rocketmq.v2.Ver" + + "ifyMessageCommandH\000B\t\n\007commandB\t\n\007_statu" + + "s\"\\\n\036NotifyClientTerminationRequest\0220\n\005g" + + "roup\030\001 \001(\0132\034.apache.rocketmq.v2.Resource" + + "H\000\210\001\001B\010\n\006_group\"M\n\037NotifyClientTerminati" + + "onResponse\022*\n\006status\030\001 \001(\0132\032.apache.rock" + + "etmq.v2.Status\"\335\001\n\036ChangeInvisibleDurati" + + "onRequest\022+\n\005group\030\001 \001(\0132\034.apache.rocket" + + "mq.v2.Resource\022+\n\005topic\030\002 \001(\0132\034.apache.r" + + "ocketmq.v2.Resource\022\026\n\016receipt_handle\030\003 " + + "\001(\t\0225\n\022invisible_duration\030\004 \001(\0132\031.google" + + ".protobuf.Duration\022\022\n\nmessage_id\030\005 \001(\t\"e" + + "\n\037ChangeInvisibleDurationResponse\022*\n\006sta" + + "tus\030\001 \001(\0132\032.apache.rocketmq.v2.Status\022\026\n" + + "\016receipt_handle\030\002 \001(\t2\340\t\n\020MessagingServi" + + "ce\022]\n\nQueryRoute\022%.apache.rocketmq.v2.Qu" + + "eryRouteRequest\032&.apache.rocketmq.v2.Que" + + "ryRouteResponse\"\000\022Z\n\tHeartbeat\022$.apache." + + "rocketmq.v2.HeartbeatRequest\032%.apache.ro" + + "cketmq.v2.HeartbeatResponse\"\000\022`\n\013SendMes" + + "sage\022&.apache.rocketmq.v2.SendMessageReq" + + "uest\032\'.apache.rocketmq.v2.SendMessageRes" + + "ponse\"\000\022l\n\017QueryAssignment\022*.apache.rock" + + "etmq.v2.QueryAssignmentRequest\032+.apache." + + "rocketmq.v2.QueryAssignmentResponse\"\000\022k\n" + + "\016ReceiveMessage\022).apache.rocketmq.v2.Rec" + + "eiveMessageRequest\032*.apache.rocketmq.v2." + + "ReceiveMessageResponse\"\0000\001\022]\n\nAckMessage" + + "\022%.apache.rocketmq.v2.AckMessageRequest\032" + + "&.apache.rocketmq.v2.AckMessageResponse\"" + + "\000\022\234\001\n\037ForwardMessageToDeadLetterQueue\022:." + + "apache.rocketmq.v2.ForwardMessageToDeadL" + + "etterQueueRequest\032;.apache.rocketmq.v2.F" + + "orwardMessageToDeadLetterQueueResponse\"\000" + + "\022i\n\016EndTransaction\022).apache.rocketmq.v2." + + "EndTransactionRequest\032*.apache.rocketmq." + + "v2.EndTransactionResponse\"\000\022]\n\tTelemetry" + + "\022$.apache.rocketmq.v2.TelemetryCommand\032$" + + ".apache.rocketmq.v2.TelemetryCommand\"\000(\001" + + "0\001\022\204\001\n\027NotifyClientTermination\0222.apache." + + "rocketmq.v2.NotifyClientTerminationReque" + + "st\0323.apache.rocketmq.v2.NotifyClientTerm" + + "inationResponse\"\000\022\204\001\n\027ChangeInvisibleDur" + + "ation\0222.apache.rocketmq.v2.ChangeInvisib" + + "leDurationRequest\0323.apache.rocketmq.v2.C" + + "hangeInvisibleDurationResponse\"\000B<\n\022apac" + + "he.rocketmq.v2B\tMQServiceP\001\240\001\001\330\001\001\252\002\022Apac" + + "he.Rocketmq.V2b\006proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor .internalBuildGeneratedFileFrom(descriptorData, @@ -523,7 +523,7 @@ public final class MQService { 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", "MetricEndpoints", "MetricEndpoints", }); + 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 diff --git a/src/main/java/apache/rocketmq/v2/Metric.java b/src/main/java/apache/rocketmq/v2/Metric.java index 4fed424..d96c59e 100644 --- a/src/main/java/apache/rocketmq/v2/Metric.java +++ b/src/main/java/apache/rocketmq/v2/Metric.java @@ -57,12 +57,12 @@ private static final long serialVersionUID = 0L; case 18: { apache.rocketmq.v2.Endpoints.Builder subBuilder = null; if (((bitField0_ & 0x00000001) != 0)) { - subBuilder = metricEndpoints_.toBuilder(); + subBuilder = endpoints_.toBuilder(); } - metricEndpoints_ = input.readMessage(apache.rocketmq.v2.Endpoints.parser(), extensionRegistry); + endpoints_ = input.readMessage(apache.rocketmq.v2.Endpoints.parser(), extensionRegistry); if (subBuilder != null) { - subBuilder.mergeFrom(metricEndpoints_); - metricEndpoints_ = subBuilder.buildPartial(); + subBuilder.mergeFrom(endpoints_); + endpoints_ = subBuilder.buildPartial(); } bitField0_ |= 0x00000001; break; @@ -115,18 +115,18 @@ private static final long serialVersionUID = 0L; return on_; } - public static final int METRIC_ENDPOINTS_FIELD_NUMBER = 2; - private apache.rocketmq.v2.Endpoints metricEndpoints_; + public static final int ENDPOINTS_FIELD_NUMBER = 2; + private apache.rocketmq.v2.Endpoints endpoints_; /** * <pre> * The endpoint that client metrics should be exported to, which is required if the switch is on. * </pre> * - * <code>optional .apache.rocketmq.v2.Endpoints metric_endpoints = 2;</code> - * @return Whether the metricEndpoints field is set. + * <code>optional .apache.rocketmq.v2.Endpoints endpoints = 2;</code> + * @return Whether the endpoints field is set. */ @java.lang.Override - public boolean hasMetricEndpoints() { + public boolean hasEndpoints() { return ((bitField0_ & 0x00000001) != 0); } /** @@ -134,23 +134,23 @@ private static final long serialVersionUID = 0L; * The endpoint that client metrics should be exported to, which is required if the switch is on. * </pre> * - * <code>optional .apache.rocketmq.v2.Endpoints metric_endpoints = 2;</code> - * @return The metricEndpoints. + * <code>optional .apache.rocketmq.v2.Endpoints endpoints = 2;</code> + * @return The endpoints. */ @java.lang.Override - public apache.rocketmq.v2.Endpoints getMetricEndpoints() { - return metricEndpoints_ == null ? apache.rocketmq.v2.Endpoints.getDefaultInstance() : metricEndpoints_; + public apache.rocketmq.v2.Endpoints getEndpoints() { + return endpoints_ == null ? apache.rocketmq.v2.Endpoints.getDefaultInstance() : endpoints_; } /** * <pre> * The endpoint that client metrics should be exported to, which is required if the switch is on. * </pre> * - * <code>optional .apache.rocketmq.v2.Endpoints metric_endpoints = 2;</code> + * <code>optional .apache.rocketmq.v2.Endpoints endpoints = 2;</code> */ @java.lang.Override - public apache.rocketmq.v2.EndpointsOrBuilder getMetricEndpointsOrBuilder() { - return metricEndpoints_ == null ? apache.rocketmq.v2.Endpoints.getDefaultInstance() : metricEndpoints_; + public apache.rocketmq.v2.EndpointsOrBuilder getEndpointsOrBuilder() { + return endpoints_ == null ? apache.rocketmq.v2.Endpoints.getDefaultInstance() : endpoints_; } private byte memoizedIsInitialized = -1; @@ -171,7 +171,7 @@ private static final long serialVersionUID = 0L; output.writeBool(1, on_); } if (((bitField0_ & 0x00000001) != 0)) { - output.writeMessage(2, getMetricEndpoints()); + output.writeMessage(2, getEndpoints()); } unknownFields.writeTo(output); } @@ -188,7 +188,7 @@ private static final long serialVersionUID = 0L; } if (((bitField0_ & 0x00000001) != 0)) { size += com.google.protobuf.CodedOutputStream - .computeMessageSize(2, getMetricEndpoints()); + .computeMessageSize(2, getEndpoints()); } size += unknownFields.getSerializedSize(); memoizedSize = size; @@ -207,10 +207,10 @@ private static final long serialVersionUID = 0L; if (getOn() != other.getOn()) return false; - if (hasMetricEndpoints() != other.hasMetricEndpoints()) return false; - if (hasMetricEndpoints()) { - if (!getMetricEndpoints() - .equals(other.getMetricEndpoints())) return false; + if (hasEndpoints() != other.hasEndpoints()) return false; + if (hasEndpoints()) { + if (!getEndpoints() + .equals(other.getEndpoints())) return false; } if (!unknownFields.equals(other.unknownFields)) return false; return true; @@ -226,9 +226,9 @@ private static final long serialVersionUID = 0L; hash = (37 * hash) + ON_FIELD_NUMBER; hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean( getOn()); - if (hasMetricEndpoints()) { - hash = (37 * hash) + METRIC_ENDPOINTS_FIELD_NUMBER; - hash = (53 * hash) + getMetricEndpoints().hashCode(); + if (hasEndpoints()) { + hash = (37 * hash) + ENDPOINTS_FIELD_NUMBER; + hash = (53 * hash) + getEndpoints().hashCode(); } hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; @@ -358,7 +358,7 @@ private static final long serialVersionUID = 0L; private void maybeForceBuilderInitialization() { if (com.google.protobuf.GeneratedMessageV3 .alwaysUseFieldBuilders) { - getMetricEndpointsFieldBuilder(); + getEndpointsFieldBuilder(); } } @java.lang.Override @@ -366,10 +366,10 @@ private static final long serialVersionUID = 0L; super.clear(); on_ = false; - if (metricEndpointsBuilder_ == null) { - metricEndpoints_ = null; + if (endpointsBuilder_ == null) { + endpoints_ = null; } else { - metricEndpointsBuilder_.clear(); + endpointsBuilder_.clear(); } bitField0_ = (bitField0_ & ~0x00000001); return this; @@ -402,10 +402,10 @@ private static final long serialVersionUID = 0L; int to_bitField0_ = 0; result.on_ = on_; if (((from_bitField0_ & 0x00000001) != 0)) { - if (metricEndpointsBuilder_ == null) { - result.metricEndpoints_ = metricEndpoints_; + if (endpointsBuilder_ == null) { + result.endpoints_ = endpoints_; } else { - result.metricEndpoints_ = metricEndpointsBuilder_.build(); + result.endpoints_ = endpointsBuilder_.build(); } to_bitField0_ |= 0x00000001; } @@ -461,8 +461,8 @@ private static final long serialVersionUID = 0L; if (other.getOn() != false) { setOn(other.getOn()); } - if (other.hasMetricEndpoints()) { - mergeMetricEndpoints(other.getMetricEndpoints()); + if (other.hasEndpoints()) { + mergeEndpoints(other.getEndpoints()); } this.mergeUnknownFields(other.unknownFields); onChanged(); @@ -537,18 +537,18 @@ private static final long serialVersionUID = 0L; return this; } - private apache.rocketmq.v2.Endpoints metricEndpoints_; + private apache.rocketmq.v2.Endpoints endpoints_; private com.google.protobuf.SingleFieldBuilderV3< - apache.rocketmq.v2.Endpoints, apache.rocketmq.v2.Endpoints.Builder, apache.rocketmq.v2.EndpointsOrBuilder> metricEndpointsBuilder_; + apache.rocketmq.v2.Endpoints, apache.rocketmq.v2.Endpoints.Builder, apache.rocketmq.v2.EndpointsOrBuilder> endpointsBuilder_; /** * <pre> * The endpoint that client metrics should be exported to, which is required if the switch is on. * </pre> * - * <code>optional .apache.rocketmq.v2.Endpoints metric_endpoints = 2;</code> - * @return Whether the metricEndpoints field is set. + * <code>optional .apache.rocketmq.v2.Endpoints endpoints = 2;</code> + * @return Whether the endpoints field is set. */ - public boolean hasMetricEndpoints() { + public boolean hasEndpoints() { return ((bitField0_ & 0x00000001) != 0); } /** @@ -556,14 +556,14 @@ private static final long serialVersionUID = 0L; * The endpoint that client metrics should be exported to, which is required if the switch is on. * </pre> * - * <code>optional .apache.rocketmq.v2.Endpoints metric_endpoints = 2;</code> - * @return The metricEndpoints. + * <code>optional .apache.rocketmq.v2.Endpoints endpoints = 2;</code> + * @return The endpoints. */ - public apache.rocketmq.v2.Endpoints getMetricEndpoints() { - if (metricEndpointsBuilder_ == null) { - return metricEndpoints_ == null ? apache.rocketmq.v2.Endpoints.getDefaultInstance() : metricEndpoints_; + public apache.rocketmq.v2.Endpoints getEndpoints() { + if (endpointsBuilder_ == null) { + return endpoints_ == null ? apache.rocketmq.v2.Endpoints.getDefaultInstance() : endpoints_; } else { - return metricEndpointsBuilder_.getMessage(); + return endpointsBuilder_.getMessage(); } } /** @@ -571,17 +571,17 @@ private static final long serialVersionUID = 0L; * The endpoint that client metrics should be exported to, which is required if the switch is on. * </pre> * - * <code>optional .apache.rocketmq.v2.Endpoints metric_endpoints = 2;</code> + * <code>optional .apache.rocketmq.v2.Endpoints endpoints = 2;</code> */ - public Builder setMetricEndpoints(apache.rocketmq.v2.Endpoints value) { - if (metricEndpointsBuilder_ == null) { + public Builder setEndpoints(apache.rocketmq.v2.Endpoints value) { + if (endpointsBuilder_ == null) { if (value == null) { throw new NullPointerException(); } - metricEndpoints_ = value; + endpoints_ = value; onChanged(); } else { - metricEndpointsBuilder_.setMessage(value); + endpointsBuilder_.setMessage(value); } bitField0_ |= 0x00000001; return this; @@ -591,15 +591,15 @@ private static final long serialVersionUID = 0L; * The endpoint that client metrics should be exported to, which is required if the switch is on. * </pre> * - * <code>optional .apache.rocketmq.v2.Endpoints metric_endpoints = 2;</code> + * <code>optional .apache.rocketmq.v2.Endpoints endpoints = 2;</code> */ - public Builder setMetricEndpoints( + public Builder setEndpoints( apache.rocketmq.v2.Endpoints.Builder builderForValue) { - if (metricEndpointsBuilder_ == null) { - metricEndpoints_ = builderForValue.build(); + if (endpointsBuilder_ == null) { + endpoints_ = builderForValue.build(); onChanged(); } else { - metricEndpointsBuilder_.setMessage(builderForValue.build()); + endpointsBuilder_.setMessage(builderForValue.build()); } bitField0_ |= 0x00000001; return this; @@ -609,21 +609,21 @@ private static final long serialVersionUID = 0L; * The endpoint that client metrics should be exported to, which is required if the switch is on. * </pre> * - * <code>optional .apache.rocketmq.v2.Endpoints metric_endpoints = 2;</code> + * <code>optional .apache.rocketmq.v2.Endpoints endpoints = 2;</code> */ - public Builder mergeMetricEndpoints(apache.rocketmq.v2.Endpoints value) { - if (metricEndpointsBuilder_ == null) { + public Builder mergeEndpoints(apache.rocketmq.v2.Endpoints value) { + if (endpointsBuilder_ == null) { if (((bitField0_ & 0x00000001) != 0) && - metricEndpoints_ != null && - metricEndpoints_ != apache.rocketmq.v2.Endpoints.getDefaultInstance()) { - metricEndpoints_ = - apache.rocketmq.v2.Endpoints.newBuilder(metricEndpoints_).mergeFrom(value).buildPartial(); + endpoints_ != null && + endpoints_ != apache.rocketmq.v2.Endpoints.getDefaultInstance()) { + endpoints_ = + apache.rocketmq.v2.Endpoints.newBuilder(endpoints_).mergeFrom(value).buildPartial(); } else { - metricEndpoints_ = value; + endpoints_ = value; } onChanged(); } else { - metricEndpointsBuilder_.mergeFrom(value); + endpointsBuilder_.mergeFrom(value); } bitField0_ |= 0x00000001; return this; @@ -633,14 +633,14 @@ private static final long serialVersionUID = 0L; * The endpoint that client metrics should be exported to, which is required if the switch is on. * </pre> * - * <code>optional .apache.rocketmq.v2.Endpoints metric_endpoints = 2;</code> + * <code>optional .apache.rocketmq.v2.Endpoints endpoints = 2;</code> */ - public Builder clearMetricEndpoints() { - if (metricEndpointsBuilder_ == null) { - metricEndpoints_ = null; + public Builder clearEndpoints() { + if (endpointsBuilder_ == null) { + endpoints_ = null; onChanged(); } else { - metricEndpointsBuilder_.clear(); + endpointsBuilder_.clear(); } bitField0_ = (bitField0_ & ~0x00000001); return this; @@ -650,26 +650,26 @@ private static final long serialVersionUID = 0L; * The endpoint that client metrics should be exported to, which is required if the switch is on. * </pre> * - * <code>optional .apache.rocketmq.v2.Endpoints metric_endpoints = 2;</code> + * <code>optional .apache.rocketmq.v2.Endpoints endpoints = 2;</code> */ - public apache.rocketmq.v2.Endpoints.Builder getMetricEndpointsBuilder() { + public apache.rocketmq.v2.Endpoints.Builder getEndpointsBuilder() { bitField0_ |= 0x00000001; onChanged(); - return getMetricEndpointsFieldBuilder().getBuilder(); + return getEndpointsFieldBuilder().getBuilder(); } /** * <pre> * The endpoint that client metrics should be exported to, which is required if the switch is on. * </pre> * - * <code>optional .apache.rocketmq.v2.Endpoints metric_endpoints = 2;</code> + * <code>optional .apache.rocketmq.v2.Endpoints endpoints = 2;</code> */ - public apache.rocketmq.v2.EndpointsOrBuilder getMetricEndpointsOrBuilder() { - if (metricEndpointsBuilder_ != null) { - return metricEndpointsBuilder_.getMessageOrBuilder(); + public apache.rocketmq.v2.EndpointsOrBuilder getEndpointsOrBuilder() { + if (endpointsBuilder_ != null) { + return endpointsBuilder_.getMessageOrBuilder(); } else { - return metricEndpoints_ == null ? - apache.rocketmq.v2.Endpoints.getDefaultInstance() : metricEndpoints_; + return endpoints_ == null ? + apache.rocketmq.v2.Endpoints.getDefaultInstance() : endpoints_; } } /** @@ -677,20 +677,20 @@ private static final long serialVersionUID = 0L; * The endpoint that client metrics should be exported to, which is required if the switch is on. * </pre> * - * <code>optional .apache.rocketmq.v2.Endpoints metric_endpoints = 2;</code> + * <code>optional .apache.rocketmq.v2.Endpoints endpoints = 2;</code> */ private com.google.protobuf.SingleFieldBuilderV3< apache.rocketmq.v2.Endpoints, apache.rocketmq.v2.Endpoints.Builder, apache.rocketmq.v2.EndpointsOrBuilder> - getMetricEndpointsFieldBuilder() { - if (metricEndpointsBuilder_ == null) { - metricEndpointsBuilder_ = new com.google.protobuf.SingleFieldBuilderV3< + getEndpointsFieldBuilder() { + if (endpointsBuilder_ == null) { + endpointsBuilder_ = new com.google.protobuf.SingleFieldBuilderV3< apache.rocketmq.v2.Endpoints, apache.rocketmq.v2.Endpoints.Builder, apache.rocketmq.v2.EndpointsOrBuilder>( - getMetricEndpoints(), + getEndpoints(), getParentForChildren(), isClean()); - metricEndpoints_ = null; + endpoints_ = null; } - return metricEndpointsBuilder_; + return endpointsBuilder_; } @java.lang.Override public final Builder setUnknownFields( diff --git a/src/main/java/apache/rocketmq/v2/MetricOrBuilder.java b/src/main/java/apache/rocketmq/v2/MetricOrBuilder.java index 5e2e185..577bf9c 100644 --- a/src/main/java/apache/rocketmq/v2/MetricOrBuilder.java +++ b/src/main/java/apache/rocketmq/v2/MetricOrBuilder.java @@ -22,25 +22,25 @@ public interface MetricOrBuilder extends * The endpoint that client metrics should be exported to, which is required if the switch is on. * </pre> * - * <code>optional .apache.rocketmq.v2.Endpoints metric_endpoints = 2;</code> - * @return Whether the metricEndpoints field is set. + * <code>optional .apache.rocketmq.v2.Endpoints endpoints = 2;</code> + * @return Whether the endpoints field is set. */ - boolean hasMetricEndpoints(); + boolean hasEndpoints(); /** * <pre> * The endpoint that client metrics should be exported to, which is required if the switch is on. * </pre> * - * <code>optional .apache.rocketmq.v2.Endpoints metric_endpoints = 2;</code> - * @return The metricEndpoints. + * <code>optional .apache.rocketmq.v2.Endpoints endpoints = 2;</code> + * @return The endpoints. */ - apache.rocketmq.v2.Endpoints getMetricEndpoints(); + apache.rocketmq.v2.Endpoints getEndpoints(); /** * <pre> * The endpoint that client metrics should be exported to, which is required if the switch is on. * </pre> * - * <code>optional .apache.rocketmq.v2.Endpoints metric_endpoints = 2;</code> + * <code>optional .apache.rocketmq.v2.Endpoints endpoints = 2;</code> */ - apache.rocketmq.v2.EndpointsOrBuilder getMetricEndpointsOrBuilder(); + apache.rocketmq.v2.EndpointsOrBuilder getEndpointsOrBuilder(); } diff --git a/src/main/resources/proto/apache/rocketmq/v2/service.proto b/src/main/resources/proto/apache/rocketmq/v2/service.proto index 63fcb5d..386c897 100644 --- a/src/main/resources/proto/apache/rocketmq/v2/service.proto +++ b/src/main/resources/proto/apache/rocketmq/v2/service.proto @@ -237,8 +237,9 @@ message Subscription { 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 metric_endpoints = 2; + optional Endpoints endpoints = 2; } message Settings {
