You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2022/07/15 03:27:58 UTC
[rocketmq-apis] 25/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 10fdc3b9846bd553c7b4bfe8c0b52b9b8d66a256
Author: 凌楚 <ya...@alibaba-inc.com>
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 {