You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2022/07/15 03:28:09 UTC
[rocketmq-apis] 36/38: Update maven dependencies
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 da2831fae169623acf5321e69ef5149f7537ab21
Author: 凌楚 <ya...@alibaba-inc.com>
AuthorDate: Fri Jul 15 11:08:11 2022 +0800
Update maven dependencies
---
pom.xml | 10 +++++-----
.../java/apache/rocketmq/v1/AckMessageRequest.java | 2 ++
.../java/apache/rocketmq/v1/AckMessageResponse.java | 2 ++
src/main/java/apache/rocketmq/v1/Address.java | 2 ++
src/main/java/apache/rocketmq/v1/AdminGrpc.java | 2 +-
src/main/java/apache/rocketmq/v1/Assignment.java | 2 ++
src/main/java/apache/rocketmq/v1/Broker.java | 2 ++
.../rocketmq/v1/ChangeInvisibleDurationRequest.java | 2 ++
.../rocketmq/v1/ChangeInvisibleDurationResponse.java | 2 ++
.../apache/rocketmq/v1/ChangeLogLevelRequest.java | 2 ++
.../apache/rocketmq/v1/ChangeLogLevelResponse.java | 2 ++
src/main/java/apache/rocketmq/v1/ConsumerData.java | 2 ++
.../java/apache/rocketmq/v1/DeadLetterPolicy.java | 2 ++
src/main/java/apache/rocketmq/v1/Digest.java | 2 ++
.../apache/rocketmq/v1/EndTransactionRequest.java | 2 ++
.../apache/rocketmq/v1/EndTransactionResponse.java | 2 ++
src/main/java/apache/rocketmq/v1/Endpoints.java | 2 ++
.../java/apache/rocketmq/v1/FilterExpression.java | 2 ++
.../v1/ForwardMessageToDeadLetterQueueRequest.java | 2 ++
.../v1/ForwardMessageToDeadLetterQueueResponse.java | 2 ++
.../java/apache/rocketmq/v1/HealthCheckRequest.java | 2 ++
.../java/apache/rocketmq/v1/HealthCheckResponse.java | 2 ++
.../java/apache/rocketmq/v1/HeartbeatRequest.java | 8 ++++++--
.../java/apache/rocketmq/v1/HeartbeatResponse.java | 2 ++
src/main/java/apache/rocketmq/v1/Message.java | 2 ++
.../java/apache/rocketmq/v1/MessageOrBuilder.java | 6 ++++--
.../apache/rocketmq/v1/MessagingServiceGrpc.java | 2 +-
.../java/apache/rocketmq/v1/NackMessageRequest.java | 2 ++
.../java/apache/rocketmq/v1/NackMessageResponse.java | 2 ++
src/main/java/apache/rocketmq/v1/NoopCommand.java | 2 ++
.../rocketmq/v1/NotifyClientTerminationRequest.java | 8 ++++++--
.../rocketmq/v1/NotifyClientTerminationResponse.java | 2 ++
src/main/java/apache/rocketmq/v1/Partition.java | 6 ++++--
.../java/apache/rocketmq/v1/PollCommandRequest.java | 8 ++++++--
.../java/apache/rocketmq/v1/PollCommandResponse.java | 14 ++++++++++----
.../rocketmq/v1/PrintThreadStackTraceCommand.java | 2 ++
src/main/java/apache/rocketmq/v1/ProducerData.java | 2 ++
.../java/apache/rocketmq/v1/PullMessageRequest.java | 2 ++
.../java/apache/rocketmq/v1/PullMessageResponse.java | 2 ++
.../apache/rocketmq/v1/QueryAssignmentRequest.java | 2 ++
.../apache/rocketmq/v1/QueryAssignmentResponse.java | 2 ++
.../java/apache/rocketmq/v1/QueryOffsetRequest.java | 2 ++
.../java/apache/rocketmq/v1/QueryOffsetResponse.java | 2 ++
.../java/apache/rocketmq/v1/QueryRouteRequest.java | 2 ++
.../java/apache/rocketmq/v1/QueryRouteResponse.java | 2 ++
.../apache/rocketmq/v1/ReceiveMessageRequest.java | 2 ++
.../apache/rocketmq/v1/ReceiveMessageResponse.java | 2 ++
.../v1/RecoverOrphanedTransactionCommand.java | 2 ++
.../v1/ReportMessageConsumptionResultRequest.java | 2 ++
.../v1/ReportMessageConsumptionResultResponse.java | 2 ++
.../rocketmq/v1/ReportThreadStackTraceRequest.java | 2 ++
.../rocketmq/v1/ReportThreadStackTraceResponse.java | 2 ++
src/main/java/apache/rocketmq/v1/Resource.java | 2 ++
src/main/java/apache/rocketmq/v1/ResponseCommon.java | 2 ++
.../java/apache/rocketmq/v1/SendMessageRequest.java | 2 ++
.../java/apache/rocketmq/v1/SendMessageResponse.java | 2 ++
.../java/apache/rocketmq/v1/SubscriptionEntry.java | 2 ++
.../java/apache/rocketmq/v1/SystemAttribute.java | 5 ++++-
.../rocketmq/v1/VerifyMessageConsumptionCommand.java | 2 ++
.../java/apache/rocketmq/v2/AckMessageEntry.java | 2 ++
.../java/apache/rocketmq/v2/AckMessageRequest.java | 2 ++
.../java/apache/rocketmq/v2/AckMessageResponse.java | 2 ++
.../apache/rocketmq/v2/AckMessageResultEntry.java | 2 ++
src/main/java/apache/rocketmq/v2/Address.java | 2 ++
src/main/java/apache/rocketmq/v2/AdminGrpc.java | 2 +-
src/main/java/apache/rocketmq/v2/Assignment.java | 2 ++
src/main/java/apache/rocketmq/v2/Broker.java | 2 ++
.../rocketmq/v2/ChangeInvisibleDurationRequest.java | 2 ++
.../rocketmq/v2/ChangeInvisibleDurationResponse.java | 2 ++
.../apache/rocketmq/v2/ChangeLogLevelRequest.java | 2 ++
.../apache/rocketmq/v2/ChangeLogLevelResponse.java | 2 ++
.../java/apache/rocketmq/v2/CustomizedBackoff.java | 2 ++
src/main/java/apache/rocketmq/v2/Digest.java | 2 ++
.../apache/rocketmq/v2/EndTransactionRequest.java | 2 ++
.../apache/rocketmq/v2/EndTransactionResponse.java | 2 ++
src/main/java/apache/rocketmq/v2/Endpoints.java | 2 ++
.../java/apache/rocketmq/v2/ExponentialBackoff.java | 2 ++
.../java/apache/rocketmq/v2/FilterExpression.java | 2 ++
.../v2/ForwardMessageToDeadLetterQueueRequest.java | 2 ++
.../v2/ForwardMessageToDeadLetterQueueResponse.java | 2 ++
.../java/apache/rocketmq/v2/HeartbeatRequest.java | 2 ++
.../java/apache/rocketmq/v2/HeartbeatResponse.java | 2 ++
src/main/java/apache/rocketmq/v2/Message.java | 2 ++
.../java/apache/rocketmq/v2/MessageOrBuilder.java | 6 ++++--
src/main/java/apache/rocketmq/v2/MessageQueue.java | 6 ++++--
.../apache/rocketmq/v2/MessagingServiceGrpc.java | 2 +-
src/main/java/apache/rocketmq/v2/Metric.java | 2 ++
.../rocketmq/v2/NotifyClientTerminationRequest.java | 2 ++
.../rocketmq/v2/NotifyClientTerminationResponse.java | 2 ++
.../rocketmq/v2/PrintThreadStackTraceCommand.java | 2 ++
src/main/java/apache/rocketmq/v2/Publishing.java | 2 ++
.../apache/rocketmq/v2/QueryAssignmentRequest.java | 2 ++
.../apache/rocketmq/v2/QueryAssignmentResponse.java | 2 ++
.../java/apache/rocketmq/v2/QueryRouteRequest.java | 2 ++
.../java/apache/rocketmq/v2/QueryRouteResponse.java | 2 ++
.../apache/rocketmq/v2/ReceiveMessageRequest.java | 2 ++
.../apache/rocketmq/v2/ReceiveMessageResponse.java | 11 ++++++++---
.../v2/RecoverOrphanedTransactionCommand.java | 2 ++
src/main/java/apache/rocketmq/v2/Resource.java | 2 ++
src/main/java/apache/rocketmq/v2/RetryPolicy.java | 8 ++++++--
.../java/apache/rocketmq/v2/SendMessageRequest.java | 2 ++
.../java/apache/rocketmq/v2/SendMessageResponse.java | 2 ++
.../java/apache/rocketmq/v2/SendResultEntry.java | 2 ++
src/main/java/apache/rocketmq/v2/Settings.java | 8 ++++++--
src/main/java/apache/rocketmq/v2/Status.java | 2 ++
src/main/java/apache/rocketmq/v2/Subscription.java | 2 ++
.../java/apache/rocketmq/v2/SubscriptionEntry.java | 2 ++
.../java/apache/rocketmq/v2/SystemProperties.java | 2 ++
.../java/apache/rocketmq/v2/TelemetryCommand.java | 20 ++++++++++++++------
.../java/apache/rocketmq/v2/ThreadStackTrace.java | 2 ++
src/main/java/apache/rocketmq/v2/UA.java | 2 ++
.../apache/rocketmq/v2/VerifyMessageCommand.java | 2 ++
.../java/apache/rocketmq/v2/VerifyMessageResult.java | 2 ++
113 files changed, 281 insertions(+), 41 deletions(-)
diff --git a/pom.xml b/pom.xml
index 2cac10c..ebaae81 100644
--- a/pom.xml
+++ b/pom.xml
@@ -14,9 +14,9 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
- <grpc.version>1.45.0</grpc.version>
- <protobuf.version>3.19.4</protobuf.version>
- <annotation-api.version>1.3.2</annotation-api.version>
+ <grpc.version>1.47.0</grpc.version>
+ <protobuf.version>3.21.1</protobuf.version>
+ <annotation-api.version>6.0.53</annotation-api.version>
<maven-compiler-plugin.version>3.8.0</maven-compiler-plugin.version>
<protobuf-maven-plugin.version>0.6.1</protobuf-maven-plugin.version>
@@ -45,8 +45,8 @@
<!-- For jdk11 -->
<dependency>
- <groupId>javax.annotation</groupId>
- <artifactId>javax.annotation-api</artifactId>
+ <groupId>org.apache.tomcat</groupId>
+ <artifactId>annotations-api</artifactId>
<version>${annotation-api.version}</version>
</dependency>
</dependencies>
diff --git a/src/main/java/apache/rocketmq/v1/AckMessageRequest.java b/src/main/java/apache/rocketmq/v1/AckMessageRequest.java
index f1dc79d..1d74bc3 100644
--- a/src/main/java/apache/rocketmq/v1/AckMessageRequest.java
+++ b/src/main/java/apache/rocketmq/v1/AckMessageRequest.java
@@ -110,6 +110,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/AckMessageResponse.java b/src/main/java/apache/rocketmq/v1/AckMessageResponse.java
index 65a47ae..a8f54ad 100644
--- a/src/main/java/apache/rocketmq/v1/AckMessageResponse.java
+++ b/src/main/java/apache/rocketmq/v1/AckMessageResponse.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/Address.java b/src/main/java/apache/rocketmq/v1/Address.java
index 58f54f3..b8d7aa3 100644
--- a/src/main/java/apache/rocketmq/v1/Address.java
+++ b/src/main/java/apache/rocketmq/v1/Address.java
@@ -71,6 +71,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/AdminGrpc.java b/src/main/java/apache/rocketmq/v1/AdminGrpc.java
index c629330..518ca58 100644
--- a/src/main/java/apache/rocketmq/v1/AdminGrpc.java
+++ b/src/main/java/apache/rocketmq/v1/AdminGrpc.java
@@ -5,7 +5,7 @@ import static io.grpc.MethodDescriptor.generateFullMethodName;
/**
*/
@javax.annotation.Generated(
- value = "by gRPC proto compiler (version 1.45.0)",
+ value = "by gRPC proto compiler (version 1.47.0)",
comments = "Source: apache/rocketmq/v1/admin.proto")
@io.grpc.stub.annotations.GrpcGenerated
public final class AdminGrpc {
diff --git a/src/main/java/apache/rocketmq/v1/Assignment.java b/src/main/java/apache/rocketmq/v1/Assignment.java
index eca4b56..13f5ff9 100644
--- a/src/main/java/apache/rocketmq/v1/Assignment.java
+++ b/src/main/java/apache/rocketmq/v1/Assignment.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/Broker.java b/src/main/java/apache/rocketmq/v1/Broker.java
index 1f072e2..3f2ff4d 100644
--- a/src/main/java/apache/rocketmq/v1/Broker.java
+++ b/src/main/java/apache/rocketmq/v1/Broker.java
@@ -84,6 +84,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/ChangeInvisibleDurationRequest.java b/src/main/java/apache/rocketmq/v1/ChangeInvisibleDurationRequest.java
index fded7f3..23bb33b 100644
--- a/src/main/java/apache/rocketmq/v1/ChangeInvisibleDurationRequest.java
+++ b/src/main/java/apache/rocketmq/v1/ChangeInvisibleDurationRequest.java
@@ -105,6 +105,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/ChangeInvisibleDurationResponse.java b/src/main/java/apache/rocketmq/v1/ChangeInvisibleDurationResponse.java
index d29218c..837aac6 100644
--- a/src/main/java/apache/rocketmq/v1/ChangeInvisibleDurationResponse.java
+++ b/src/main/java/apache/rocketmq/v1/ChangeInvisibleDurationResponse.java
@@ -79,6 +79,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/ChangeLogLevelRequest.java b/src/main/java/apache/rocketmq/v1/ChangeLogLevelRequest.java
index 940e94b..3098cb8 100644
--- a/src/main/java/apache/rocketmq/v1/ChangeLogLevelRequest.java
+++ b/src/main/java/apache/rocketmq/v1/ChangeLogLevelRequest.java
@@ -66,6 +66,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/ChangeLogLevelResponse.java b/src/main/java/apache/rocketmq/v1/ChangeLogLevelResponse.java
index 42f5c7b..adc30d5 100644
--- a/src/main/java/apache/rocketmq/v1/ChangeLogLevelResponse.java
+++ b/src/main/java/apache/rocketmq/v1/ChangeLogLevelResponse.java
@@ -66,6 +66,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/ConsumerData.java b/src/main/java/apache/rocketmq/v1/ConsumerData.java
index bfbe451..bbcc844 100644
--- a/src/main/java/apache/rocketmq/v1/ConsumerData.java
+++ b/src/main/java/apache/rocketmq/v1/ConsumerData.java
@@ -117,6 +117,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/DeadLetterPolicy.java b/src/main/java/apache/rocketmq/v1/DeadLetterPolicy.java
index 565f33e..94c27e6 100644
--- a/src/main/java/apache/rocketmq/v1/DeadLetterPolicy.java
+++ b/src/main/java/apache/rocketmq/v1/DeadLetterPolicy.java
@@ -71,6 +71,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/Digest.java b/src/main/java/apache/rocketmq/v1/Digest.java
index d1c163a..eae7128 100644
--- a/src/main/java/apache/rocketmq/v1/Digest.java
+++ b/src/main/java/apache/rocketmq/v1/Digest.java
@@ -88,6 +88,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/EndTransactionRequest.java b/src/main/java/apache/rocketmq/v1/EndTransactionRequest.java
index e62a660..e2cc593 100644
--- a/src/main/java/apache/rocketmq/v1/EndTransactionRequest.java
+++ b/src/main/java/apache/rocketmq/v1/EndTransactionRequest.java
@@ -107,6 +107,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/EndTransactionResponse.java b/src/main/java/apache/rocketmq/v1/EndTransactionResponse.java
index e00889f..27a9080 100644
--- a/src/main/java/apache/rocketmq/v1/EndTransactionResponse.java
+++ b/src/main/java/apache/rocketmq/v1/EndTransactionResponse.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/Endpoints.java b/src/main/java/apache/rocketmq/v1/Endpoints.java
index f4ec5bc..d4fed4a 100644
--- a/src/main/java/apache/rocketmq/v1/Endpoints.java
+++ b/src/main/java/apache/rocketmq/v1/Endpoints.java
@@ -77,6 +77,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/FilterExpression.java b/src/main/java/apache/rocketmq/v1/FilterExpression.java
index cd0e325..b00af78 100644
--- a/src/main/java/apache/rocketmq/v1/FilterExpression.java
+++ b/src/main/java/apache/rocketmq/v1/FilterExpression.java
@@ -73,6 +73,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/ForwardMessageToDeadLetterQueueRequest.java b/src/main/java/apache/rocketmq/v1/ForwardMessageToDeadLetterQueueRequest.java
index f083653..8ea888f 100644
--- a/src/main/java/apache/rocketmq/v1/ForwardMessageToDeadLetterQueueRequest.java
+++ b/src/main/java/apache/rocketmq/v1/ForwardMessageToDeadLetterQueueRequest.java
@@ -116,6 +116,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/ForwardMessageToDeadLetterQueueResponse.java b/src/main/java/apache/rocketmq/v1/ForwardMessageToDeadLetterQueueResponse.java
index 05228df..058de07 100644
--- a/src/main/java/apache/rocketmq/v1/ForwardMessageToDeadLetterQueueResponse.java
+++ b/src/main/java/apache/rocketmq/v1/ForwardMessageToDeadLetterQueueResponse.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/HealthCheckRequest.java b/src/main/java/apache/rocketmq/v1/HealthCheckRequest.java
index 7312666..f8c891d 100644
--- a/src/main/java/apache/rocketmq/v1/HealthCheckRequest.java
+++ b/src/main/java/apache/rocketmq/v1/HealthCheckRequest.java
@@ -79,6 +79,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/HealthCheckResponse.java b/src/main/java/apache/rocketmq/v1/HealthCheckResponse.java
index 59b0aea..9daf8d5 100644
--- a/src/main/java/apache/rocketmq/v1/HealthCheckResponse.java
+++ b/src/main/java/apache/rocketmq/v1/HealthCheckResponse.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/HeartbeatRequest.java b/src/main/java/apache/rocketmq/v1/HeartbeatRequest.java
index 4f6fee0..d65eb6b 100644
--- a/src/main/java/apache/rocketmq/v1/HeartbeatRequest.java
+++ b/src/main/java/apache/rocketmq/v1/HeartbeatRequest.java
@@ -99,6 +99,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -826,8 +828,9 @@ private static final long serialVersionUID = 0L;
} else {
if (clientDataCase_ == 2) {
producerDataBuilder_.mergeFrom(value);
+ } else {
+ producerDataBuilder_.setMessage(value);
}
- producerDataBuilder_.setMessage(value);
}
clientDataCase_ = 2;
return this;
@@ -967,8 +970,9 @@ private static final long serialVersionUID = 0L;
} else {
if (clientDataCase_ == 3) {
consumerDataBuilder_.mergeFrom(value);
+ } else {
+ consumerDataBuilder_.setMessage(value);
}
- consumerDataBuilder_.setMessage(value);
}
clientDataCase_ = 3;
return this;
diff --git a/src/main/java/apache/rocketmq/v1/HeartbeatResponse.java b/src/main/java/apache/rocketmq/v1/HeartbeatResponse.java
index 9a14c66..f88d827 100644
--- a/src/main/java/apache/rocketmq/v1/HeartbeatResponse.java
+++ b/src/main/java/apache/rocketmq/v1/HeartbeatResponse.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/Message.java b/src/main/java/apache/rocketmq/v1/Message.java
index 3dc9ff6..f65e3b5 100644
--- a/src/main/java/apache/rocketmq/v1/Message.java
+++ b/src/main/java/apache/rocketmq/v1/Message.java
@@ -105,6 +105,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/MessageOrBuilder.java b/src/main/java/apache/rocketmq/v1/MessageOrBuilder.java
index a85e8f0..273d692 100644
--- a/src/main/java/apache/rocketmq/v1/MessageOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v1/MessageOrBuilder.java
@@ -78,9 +78,11 @@ public interface MessageOrBuilder extends
* <code>map<string, string> user_attribute = 2;</code>
*/
- java.lang.String getUserAttributeOrDefault(
+ /* nullable */
+java.lang.String getUserAttributeOrDefault(
java.lang.String key,
- java.lang.String defaultValue);
+ /* nullable */
+java.lang.String defaultValue);
/**
* <pre>
* User defined key-value pairs.
diff --git a/src/main/java/apache/rocketmq/v1/MessagingServiceGrpc.java b/src/main/java/apache/rocketmq/v1/MessagingServiceGrpc.java
index 53cbe4f..a851f98 100644
--- a/src/main/java/apache/rocketmq/v1/MessagingServiceGrpc.java
+++ b/src/main/java/apache/rocketmq/v1/MessagingServiceGrpc.java
@@ -16,7 +16,7 @@ import static io.grpc.MethodDescriptor.generateFullMethodName;
* </pre>
*/
@javax.annotation.Generated(
- value = "by gRPC proto compiler (version 1.45.0)",
+ value = "by gRPC proto compiler (version 1.47.0)",
comments = "Source: apache/rocketmq/v1/service.proto")
@io.grpc.stub.annotations.GrpcGenerated
public final class MessagingServiceGrpc {
diff --git a/src/main/java/apache/rocketmq/v1/NackMessageRequest.java b/src/main/java/apache/rocketmq/v1/NackMessageRequest.java
index ee7b4cc..40d8e31 100644
--- a/src/main/java/apache/rocketmq/v1/NackMessageRequest.java
+++ b/src/main/java/apache/rocketmq/v1/NackMessageRequest.java
@@ -116,6 +116,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/NackMessageResponse.java b/src/main/java/apache/rocketmq/v1/NackMessageResponse.java
index 5bc7318..610efc2 100644
--- a/src/main/java/apache/rocketmq/v1/NackMessageResponse.java
+++ b/src/main/java/apache/rocketmq/v1/NackMessageResponse.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/NoopCommand.java b/src/main/java/apache/rocketmq/v1/NoopCommand.java
index b7a20e6..4960336 100644
--- a/src/main/java/apache/rocketmq/v1/NoopCommand.java
+++ b/src/main/java/apache/rocketmq/v1/NoopCommand.java
@@ -59,6 +59,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/NotifyClientTerminationRequest.java b/src/main/java/apache/rocketmq/v1/NotifyClientTerminationRequest.java
index b22927d..c1fb19d 100644
--- a/src/main/java/apache/rocketmq/v1/NotifyClientTerminationRequest.java
+++ b/src/main/java/apache/rocketmq/v1/NotifyClientTerminationRequest.java
@@ -94,6 +94,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -716,8 +718,9 @@ private static final long serialVersionUID = 0L;
} else {
if (groupCase_ == 1) {
producerGroupBuilder_.mergeFrom(value);
+ } else {
+ producerGroupBuilder_.setMessage(value);
}
- producerGroupBuilder_.setMessage(value);
}
groupCase_ = 1;
return this;
@@ -857,8 +860,9 @@ private static final long serialVersionUID = 0L;
} else {
if (groupCase_ == 2) {
consumerGroupBuilder_.mergeFrom(value);
+ } else {
+ consumerGroupBuilder_.setMessage(value);
}
- consumerGroupBuilder_.setMessage(value);
}
groupCase_ = 2;
return this;
diff --git a/src/main/java/apache/rocketmq/v1/NotifyClientTerminationResponse.java b/src/main/java/apache/rocketmq/v1/NotifyClientTerminationResponse.java
index c3cf3d3..bee97ce 100644
--- a/src/main/java/apache/rocketmq/v1/NotifyClientTerminationResponse.java
+++ b/src/main/java/apache/rocketmq/v1/NotifyClientTerminationResponse.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/Partition.java b/src/main/java/apache/rocketmq/v1/Partition.java
index 9a3e46f..8bc311f 100644
--- a/src/main/java/apache/rocketmq/v1/Partition.java
+++ b/src/main/java/apache/rocketmq/v1/Partition.java
@@ -122,6 +122,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -1134,8 +1136,8 @@ private static final long serialVersionUID = 0L;
}
/**
* <code>repeated .apache.rocketmq.v1.MessageType accept_message_types = 5;</code>
- * @param index The index of the value to return.
- * @return The enum numeric value on the wire of acceptMessageTypes at the given index.
+ * @param index The index to set the value at.
+ * @param value The enum numeric value on the wire for acceptMessageTypes to set.
* @return This builder for chaining.
*/
public Builder setAcceptMessageTypesValue(
diff --git a/src/main/java/apache/rocketmq/v1/PollCommandRequest.java b/src/main/java/apache/rocketmq/v1/PollCommandRequest.java
index 1c32e49..255d52d 100644
--- a/src/main/java/apache/rocketmq/v1/PollCommandRequest.java
+++ b/src/main/java/apache/rocketmq/v1/PollCommandRequest.java
@@ -105,6 +105,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -1143,8 +1145,9 @@ private static final long serialVersionUID = 0L;
} else {
if (groupCase_ == 3) {
producerGroupBuilder_.mergeFrom(value);
+ } else {
+ producerGroupBuilder_.setMessage(value);
}
- producerGroupBuilder_.setMessage(value);
}
groupCase_ = 3;
return this;
@@ -1284,8 +1287,9 @@ private static final long serialVersionUID = 0L;
} else {
if (groupCase_ == 4) {
consumerGroupBuilder_.mergeFrom(value);
+ } else {
+ consumerGroupBuilder_.setMessage(value);
}
- consumerGroupBuilder_.setMessage(value);
}
groupCase_ = 4;
return this;
diff --git a/src/main/java/apache/rocketmq/v1/PollCommandResponse.java b/src/main/java/apache/rocketmq/v1/PollCommandResponse.java
index 95a076f..ecf15bf 100644
--- a/src/main/java/apache/rocketmq/v1/PollCommandResponse.java
+++ b/src/main/java/apache/rocketmq/v1/PollCommandResponse.java
@@ -115,6 +115,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -868,8 +870,9 @@ private static final long serialVersionUID = 0L;
} else {
if (typeCase_ == 1) {
noopCommandBuilder_.mergeFrom(value);
+ } else {
+ noopCommandBuilder_.setMessage(value);
}
- noopCommandBuilder_.setMessage(value);
}
typeCase_ = 1;
return this;
@@ -1045,8 +1048,9 @@ private static final long serialVersionUID = 0L;
} else {
if (typeCase_ == 2) {
printThreadStackTraceCommandBuilder_.mergeFrom(value);
+ } else {
+ printThreadStackTraceCommandBuilder_.setMessage(value);
}
- printThreadStackTraceCommandBuilder_.setMessage(value);
}
typeCase_ = 2;
return this;
@@ -1222,8 +1226,9 @@ private static final long serialVersionUID = 0L;
} else {
if (typeCase_ == 3) {
verifyMessageConsumptionCommandBuilder_.mergeFrom(value);
+ } else {
+ verifyMessageConsumptionCommandBuilder_.setMessage(value);
}
- verifyMessageConsumptionCommandBuilder_.setMessage(value);
}
typeCase_ = 3;
return this;
@@ -1399,8 +1404,9 @@ private static final long serialVersionUID = 0L;
} else {
if (typeCase_ == 4) {
recoverOrphanedTransactionCommandBuilder_.mergeFrom(value);
+ } else {
+ recoverOrphanedTransactionCommandBuilder_.setMessage(value);
}
- recoverOrphanedTransactionCommandBuilder_.setMessage(value);
}
typeCase_ = 4;
return this;
diff --git a/src/main/java/apache/rocketmq/v1/PrintThreadStackTraceCommand.java b/src/main/java/apache/rocketmq/v1/PrintThreadStackTraceCommand.java
index 130c2b5..3c413d1 100644
--- a/src/main/java/apache/rocketmq/v1/PrintThreadStackTraceCommand.java
+++ b/src/main/java/apache/rocketmq/v1/PrintThreadStackTraceCommand.java
@@ -66,6 +66,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/ProducerData.java b/src/main/java/apache/rocketmq/v1/ProducerData.java
index a39ebb0..2b33f13 100644
--- a/src/main/java/apache/rocketmq/v1/ProducerData.java
+++ b/src/main/java/apache/rocketmq/v1/ProducerData.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/PullMessageRequest.java b/src/main/java/apache/rocketmq/v1/PullMessageRequest.java
index 32c6dbc..dfc1d54 100644
--- a/src/main/java/apache/rocketmq/v1/PullMessageRequest.java
+++ b/src/main/java/apache/rocketmq/v1/PullMessageRequest.java
@@ -128,6 +128,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/PullMessageResponse.java b/src/main/java/apache/rocketmq/v1/PullMessageResponse.java
index 7694863..af034be 100644
--- a/src/main/java/apache/rocketmq/v1/PullMessageResponse.java
+++ b/src/main/java/apache/rocketmq/v1/PullMessageResponse.java
@@ -98,6 +98,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/QueryAssignmentRequest.java b/src/main/java/apache/rocketmq/v1/QueryAssignmentRequest.java
index 83d6d06..c0a2c3c 100644
--- a/src/main/java/apache/rocketmq/v1/QueryAssignmentRequest.java
+++ b/src/main/java/apache/rocketmq/v1/QueryAssignmentRequest.java
@@ -105,6 +105,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/QueryAssignmentResponse.java b/src/main/java/apache/rocketmq/v1/QueryAssignmentResponse.java
index 8859630..0a1b73c 100644
--- a/src/main/java/apache/rocketmq/v1/QueryAssignmentResponse.java
+++ b/src/main/java/apache/rocketmq/v1/QueryAssignmentResponse.java
@@ -83,6 +83,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/QueryOffsetRequest.java b/src/main/java/apache/rocketmq/v1/QueryOffsetRequest.java
index a359bf5..817fe90 100644
--- a/src/main/java/apache/rocketmq/v1/QueryOffsetRequest.java
+++ b/src/main/java/apache/rocketmq/v1/QueryOffsetRequest.java
@@ -92,6 +92,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/QueryOffsetResponse.java b/src/main/java/apache/rocketmq/v1/QueryOffsetResponse.java
index 8c75eda..8f70041 100644
--- a/src/main/java/apache/rocketmq/v1/QueryOffsetResponse.java
+++ b/src/main/java/apache/rocketmq/v1/QueryOffsetResponse.java
@@ -77,6 +77,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/QueryRouteRequest.java b/src/main/java/apache/rocketmq/v1/QueryRouteRequest.java
index 4211754..dbbf74e 100644
--- a/src/main/java/apache/rocketmq/v1/QueryRouteRequest.java
+++ b/src/main/java/apache/rocketmq/v1/QueryRouteRequest.java
@@ -102,6 +102,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/QueryRouteResponse.java b/src/main/java/apache/rocketmq/v1/QueryRouteResponse.java
index bf89a01..2f5a2ba 100644
--- a/src/main/java/apache/rocketmq/v1/QueryRouteResponse.java
+++ b/src/main/java/apache/rocketmq/v1/QueryRouteResponse.java
@@ -83,6 +83,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/ReceiveMessageRequest.java b/src/main/java/apache/rocketmq/v1/ReceiveMessageRequest.java
index b6688c0..22ec378 100644
--- a/src/main/java/apache/rocketmq/v1/ReceiveMessageRequest.java
+++ b/src/main/java/apache/rocketmq/v1/ReceiveMessageRequest.java
@@ -161,6 +161,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/ReceiveMessageResponse.java b/src/main/java/apache/rocketmq/v1/ReceiveMessageResponse.java
index 2303e7f..5322b41 100644
--- a/src/main/java/apache/rocketmq/v1/ReceiveMessageResponse.java
+++ b/src/main/java/apache/rocketmq/v1/ReceiveMessageResponse.java
@@ -109,6 +109,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/RecoverOrphanedTransactionCommand.java b/src/main/java/apache/rocketmq/v1/RecoverOrphanedTransactionCommand.java
index c19276a..432d10a 100644
--- a/src/main/java/apache/rocketmq/v1/RecoverOrphanedTransactionCommand.java
+++ b/src/main/java/apache/rocketmq/v1/RecoverOrphanedTransactionCommand.java
@@ -79,6 +79,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/ReportMessageConsumptionResultRequest.java b/src/main/java/apache/rocketmq/v1/ReportMessageConsumptionResultRequest.java
index 9ac767a..45420af 100644
--- a/src/main/java/apache/rocketmq/v1/ReportMessageConsumptionResultRequest.java
+++ b/src/main/java/apache/rocketmq/v1/ReportMessageConsumptionResultRequest.java
@@ -79,6 +79,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/ReportMessageConsumptionResultResponse.java b/src/main/java/apache/rocketmq/v1/ReportMessageConsumptionResultResponse.java
index 9876de5..603901b 100644
--- a/src/main/java/apache/rocketmq/v1/ReportMessageConsumptionResultResponse.java
+++ b/src/main/java/apache/rocketmq/v1/ReportMessageConsumptionResultResponse.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/ReportThreadStackTraceRequest.java b/src/main/java/apache/rocketmq/v1/ReportThreadStackTraceRequest.java
index 67b20b1..ee7f94d 100644
--- a/src/main/java/apache/rocketmq/v1/ReportThreadStackTraceRequest.java
+++ b/src/main/java/apache/rocketmq/v1/ReportThreadStackTraceRequest.java
@@ -73,6 +73,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/ReportThreadStackTraceResponse.java b/src/main/java/apache/rocketmq/v1/ReportThreadStackTraceResponse.java
index 29b9b75..27eedd6 100644
--- a/src/main/java/apache/rocketmq/v1/ReportThreadStackTraceResponse.java
+++ b/src/main/java/apache/rocketmq/v1/ReportThreadStackTraceResponse.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/Resource.java b/src/main/java/apache/rocketmq/v1/Resource.java
index 344245c..4da8ccc 100644
--- a/src/main/java/apache/rocketmq/v1/Resource.java
+++ b/src/main/java/apache/rocketmq/v1/Resource.java
@@ -73,6 +73,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/ResponseCommon.java b/src/main/java/apache/rocketmq/v1/ResponseCommon.java
index 2b32396..a080cd7 100644
--- a/src/main/java/apache/rocketmq/v1/ResponseCommon.java
+++ b/src/main/java/apache/rocketmq/v1/ResponseCommon.java
@@ -137,6 +137,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/SendMessageRequest.java b/src/main/java/apache/rocketmq/v1/SendMessageRequest.java
index 74af1fb..74a44ac 100644
--- a/src/main/java/apache/rocketmq/v1/SendMessageRequest.java
+++ b/src/main/java/apache/rocketmq/v1/SendMessageRequest.java
@@ -85,6 +85,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/SendMessageResponse.java b/src/main/java/apache/rocketmq/v1/SendMessageResponse.java
index 2003a87..3e0851c 100644
--- a/src/main/java/apache/rocketmq/v1/SendMessageResponse.java
+++ b/src/main/java/apache/rocketmq/v1/SendMessageResponse.java
@@ -86,6 +86,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/SubscriptionEntry.java b/src/main/java/apache/rocketmq/v1/SubscriptionEntry.java
index c23d9ca..ec0e428 100644
--- a/src/main/java/apache/rocketmq/v1/SubscriptionEntry.java
+++ b/src/main/java/apache/rocketmq/v1/SubscriptionEntry.java
@@ -85,6 +85,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v1/SystemAttribute.java b/src/main/java/apache/rocketmq/v1/SystemAttribute.java
index 2889e9c..b1bf945 100644
--- a/src/main/java/apache/rocketmq/v1/SystemAttribute.java
+++ b/src/main/java/apache/rocketmq/v1/SystemAttribute.java
@@ -245,6 +245,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -3124,8 +3126,9 @@ private static final long serialVersionUID = 0L;
} else {
if (timedDeliveryCase_ == 11) {
deliveryTimestampBuilder_.mergeFrom(value);
+ } else {
+ deliveryTimestampBuilder_.setMessage(value);
}
- deliveryTimestampBuilder_.setMessage(value);
}
timedDeliveryCase_ = 11;
return this;
diff --git a/src/main/java/apache/rocketmq/v1/VerifyMessageConsumptionCommand.java b/src/main/java/apache/rocketmq/v1/VerifyMessageConsumptionCommand.java
index b900905..aea8a85 100644
--- a/src/main/java/apache/rocketmq/v1/VerifyMessageConsumptionCommand.java
+++ b/src/main/java/apache/rocketmq/v1/VerifyMessageConsumptionCommand.java
@@ -79,6 +79,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/AckMessageEntry.java b/src/main/java/apache/rocketmq/v2/AckMessageEntry.java
index 21ab30a..e4f96b9 100644
--- a/src/main/java/apache/rocketmq/v2/AckMessageEntry.java
+++ b/src/main/java/apache/rocketmq/v2/AckMessageEntry.java
@@ -73,6 +73,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/AckMessageRequest.java b/src/main/java/apache/rocketmq/v2/AckMessageRequest.java
index d9db919..2a64773 100644
--- a/src/main/java/apache/rocketmq/v2/AckMessageRequest.java
+++ b/src/main/java/apache/rocketmq/v2/AckMessageRequest.java
@@ -96,6 +96,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/AckMessageResponse.java b/src/main/java/apache/rocketmq/v2/AckMessageResponse.java
index 90d8738..85493e5 100644
--- a/src/main/java/apache/rocketmq/v2/AckMessageResponse.java
+++ b/src/main/java/apache/rocketmq/v2/AckMessageResponse.java
@@ -83,6 +83,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/AckMessageResultEntry.java b/src/main/java/apache/rocketmq/v2/AckMessageResultEntry.java
index baf3c21..4c8e459 100644
--- a/src/main/java/apache/rocketmq/v2/AckMessageResultEntry.java
+++ b/src/main/java/apache/rocketmq/v2/AckMessageResultEntry.java
@@ -86,6 +86,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/Address.java b/src/main/java/apache/rocketmq/v2/Address.java
index 92f536b..b00867c 100644
--- a/src/main/java/apache/rocketmq/v2/Address.java
+++ b/src/main/java/apache/rocketmq/v2/Address.java
@@ -71,6 +71,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/AdminGrpc.java b/src/main/java/apache/rocketmq/v2/AdminGrpc.java
index d509da5..8a9a847 100644
--- a/src/main/java/apache/rocketmq/v2/AdminGrpc.java
+++ b/src/main/java/apache/rocketmq/v2/AdminGrpc.java
@@ -5,7 +5,7 @@ import static io.grpc.MethodDescriptor.generateFullMethodName;
/**
*/
@javax.annotation.Generated(
- value = "by gRPC proto compiler (version 1.45.0)",
+ value = "by gRPC proto compiler (version 1.47.0)",
comments = "Source: apache/rocketmq/v2/admin.proto")
@io.grpc.stub.annotations.GrpcGenerated
public final class AdminGrpc {
diff --git a/src/main/java/apache/rocketmq/v2/Assignment.java b/src/main/java/apache/rocketmq/v2/Assignment.java
index 7f9a45c..d6a3c02 100644
--- a/src/main/java/apache/rocketmq/v2/Assignment.java
+++ b/src/main/java/apache/rocketmq/v2/Assignment.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/Broker.java b/src/main/java/apache/rocketmq/v2/Broker.java
index 78c4810..09d4879 100644
--- a/src/main/java/apache/rocketmq/v2/Broker.java
+++ b/src/main/java/apache/rocketmq/v2/Broker.java
@@ -84,6 +84,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationRequest.java b/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationRequest.java
index 281e50d..d5fa90b 100644
--- a/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationRequest.java
+++ b/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationRequest.java
@@ -112,6 +112,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationResponse.java b/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationResponse.java
index abb49e1..f27a28e 100644
--- a/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationResponse.java
+++ b/src/main/java/apache/rocketmq/v2/ChangeInvisibleDurationResponse.java
@@ -79,6 +79,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/ChangeLogLevelRequest.java b/src/main/java/apache/rocketmq/v2/ChangeLogLevelRequest.java
index b404e49..a6c2c3b 100644
--- a/src/main/java/apache/rocketmq/v2/ChangeLogLevelRequest.java
+++ b/src/main/java/apache/rocketmq/v2/ChangeLogLevelRequest.java
@@ -66,6 +66,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/ChangeLogLevelResponse.java b/src/main/java/apache/rocketmq/v2/ChangeLogLevelResponse.java
index 5544c5b..2af7c0d 100644
--- a/src/main/java/apache/rocketmq/v2/ChangeLogLevelResponse.java
+++ b/src/main/java/apache/rocketmq/v2/ChangeLogLevelResponse.java
@@ -66,6 +66,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/CustomizedBackoff.java b/src/main/java/apache/rocketmq/v2/CustomizedBackoff.java
index c764d74..00ec61f 100644
--- a/src/main/java/apache/rocketmq/v2/CustomizedBackoff.java
+++ b/src/main/java/apache/rocketmq/v2/CustomizedBackoff.java
@@ -70,6 +70,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/Digest.java b/src/main/java/apache/rocketmq/v2/Digest.java
index 4c906fd..03056b0 100644
--- a/src/main/java/apache/rocketmq/v2/Digest.java
+++ b/src/main/java/apache/rocketmq/v2/Digest.java
@@ -88,6 +88,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/EndTransactionRequest.java b/src/main/java/apache/rocketmq/v2/EndTransactionRequest.java
index f88277b..355f0c3 100644
--- a/src/main/java/apache/rocketmq/v2/EndTransactionRequest.java
+++ b/src/main/java/apache/rocketmq/v2/EndTransactionRequest.java
@@ -107,6 +107,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/EndTransactionResponse.java b/src/main/java/apache/rocketmq/v2/EndTransactionResponse.java
index 7aa6a1e..c5162b0 100644
--- a/src/main/java/apache/rocketmq/v2/EndTransactionResponse.java
+++ b/src/main/java/apache/rocketmq/v2/EndTransactionResponse.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/Endpoints.java b/src/main/java/apache/rocketmq/v2/Endpoints.java
index c4b38cf..1a01afd 100644
--- a/src/main/java/apache/rocketmq/v2/Endpoints.java
+++ b/src/main/java/apache/rocketmq/v2/Endpoints.java
@@ -77,6 +77,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/ExponentialBackoff.java b/src/main/java/apache/rocketmq/v2/ExponentialBackoff.java
index 9bc0756..acb8730 100644
--- a/src/main/java/apache/rocketmq/v2/ExponentialBackoff.java
+++ b/src/main/java/apache/rocketmq/v2/ExponentialBackoff.java
@@ -94,6 +94,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/FilterExpression.java b/src/main/java/apache/rocketmq/v2/FilterExpression.java
index ddd811b..68601a8 100644
--- a/src/main/java/apache/rocketmq/v2/FilterExpression.java
+++ b/src/main/java/apache/rocketmq/v2/FilterExpression.java
@@ -73,6 +73,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueRequest.java b/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueRequest.java
index e78cdb5..f1c35a4 100644
--- a/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueRequest.java
+++ b/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueRequest.java
@@ -109,6 +109,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueResponse.java b/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueResponse.java
index cf83cf1..dc1019d 100644
--- a/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueResponse.java
+++ b/src/main/java/apache/rocketmq/v2/ForwardMessageToDeadLetterQueueResponse.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/HeartbeatRequest.java b/src/main/java/apache/rocketmq/v2/HeartbeatRequest.java
index 3a8786c..93eb5f8 100644
--- a/src/main/java/apache/rocketmq/v2/HeartbeatRequest.java
+++ b/src/main/java/apache/rocketmq/v2/HeartbeatRequest.java
@@ -80,6 +80,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/HeartbeatResponse.java b/src/main/java/apache/rocketmq/v2/HeartbeatResponse.java
index c7456c7..36b7ec2 100644
--- a/src/main/java/apache/rocketmq/v2/HeartbeatResponse.java
+++ b/src/main/java/apache/rocketmq/v2/HeartbeatResponse.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/Message.java b/src/main/java/apache/rocketmq/v2/Message.java
index cd44582..846fc75 100644
--- a/src/main/java/apache/rocketmq/v2/Message.java
+++ b/src/main/java/apache/rocketmq/v2/Message.java
@@ -105,6 +105,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/MessageOrBuilder.java b/src/main/java/apache/rocketmq/v2/MessageOrBuilder.java
index adeceef..a3e1491 100644
--- a/src/main/java/apache/rocketmq/v2/MessageOrBuilder.java
+++ b/src/main/java/apache/rocketmq/v2/MessageOrBuilder.java
@@ -78,9 +78,11 @@ public interface MessageOrBuilder extends
* <code>map<string, string> user_properties = 2;</code>
*/
- java.lang.String getUserPropertiesOrDefault(
+ /* nullable */
+java.lang.String getUserPropertiesOrDefault(
java.lang.String key,
- java.lang.String defaultValue);
+ /* nullable */
+java.lang.String defaultValue);
/**
* <pre>
* User defined key-value pairs.
diff --git a/src/main/java/apache/rocketmq/v2/MessageQueue.java b/src/main/java/apache/rocketmq/v2/MessageQueue.java
index 41fbcdd..8326a4b 100644
--- a/src/main/java/apache/rocketmq/v2/MessageQueue.java
+++ b/src/main/java/apache/rocketmq/v2/MessageQueue.java
@@ -122,6 +122,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -1134,8 +1136,8 @@ private static final long serialVersionUID = 0L;
}
/**
* <code>repeated .apache.rocketmq.v2.MessageType accept_message_types = 5;</code>
- * @param index The index of the value to return.
- * @return The enum numeric value on the wire of acceptMessageTypes at the given index.
+ * @param index The index to set the value at.
+ * @param value The enum numeric value on the wire for acceptMessageTypes to set.
* @return This builder for chaining.
*/
public Builder setAcceptMessageTypesValue(
diff --git a/src/main/java/apache/rocketmq/v2/MessagingServiceGrpc.java b/src/main/java/apache/rocketmq/v2/MessagingServiceGrpc.java
index 8a9af12..5ce6019 100644
--- a/src/main/java/apache/rocketmq/v2/MessagingServiceGrpc.java
+++ b/src/main/java/apache/rocketmq/v2/MessagingServiceGrpc.java
@@ -16,7 +16,7 @@ import static io.grpc.MethodDescriptor.generateFullMethodName;
* </pre>
*/
@javax.annotation.Generated(
- value = "by gRPC proto compiler (version 1.45.0)",
+ value = "by gRPC proto compiler (version 1.47.0)",
comments = "Source: apache/rocketmq/v2/service.proto")
@io.grpc.stub.annotations.GrpcGenerated
public final class MessagingServiceGrpc {
diff --git a/src/main/java/apache/rocketmq/v2/Metric.java b/src/main/java/apache/rocketmq/v2/Metric.java
index 306f017..88cac12 100644
--- a/src/main/java/apache/rocketmq/v2/Metric.java
+++ b/src/main/java/apache/rocketmq/v2/Metric.java
@@ -78,6 +78,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/NotifyClientTerminationRequest.java b/src/main/java/apache/rocketmq/v2/NotifyClientTerminationRequest.java
index e6056d5..0607fc4 100644
--- a/src/main/java/apache/rocketmq/v2/NotifyClientTerminationRequest.java
+++ b/src/main/java/apache/rocketmq/v2/NotifyClientTerminationRequest.java
@@ -73,6 +73,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/NotifyClientTerminationResponse.java b/src/main/java/apache/rocketmq/v2/NotifyClientTerminationResponse.java
index d7aa44d..01fc9c8 100644
--- a/src/main/java/apache/rocketmq/v2/NotifyClientTerminationResponse.java
+++ b/src/main/java/apache/rocketmq/v2/NotifyClientTerminationResponse.java
@@ -72,6 +72,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/PrintThreadStackTraceCommand.java b/src/main/java/apache/rocketmq/v2/PrintThreadStackTraceCommand.java
index ea5cb74..502b4d6 100644
--- a/src/main/java/apache/rocketmq/v2/PrintThreadStackTraceCommand.java
+++ b/src/main/java/apache/rocketmq/v2/PrintThreadStackTraceCommand.java
@@ -66,6 +66,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/Publishing.java b/src/main/java/apache/rocketmq/v2/Publishing.java
index 51855cd..0c02272 100644
--- a/src/main/java/apache/rocketmq/v2/Publishing.java
+++ b/src/main/java/apache/rocketmq/v2/Publishing.java
@@ -80,6 +80,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/QueryAssignmentRequest.java b/src/main/java/apache/rocketmq/v2/QueryAssignmentRequest.java
index 0ae071f..1e4e6f2 100644
--- a/src/main/java/apache/rocketmq/v2/QueryAssignmentRequest.java
+++ b/src/main/java/apache/rocketmq/v2/QueryAssignmentRequest.java
@@ -98,6 +98,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/QueryAssignmentResponse.java b/src/main/java/apache/rocketmq/v2/QueryAssignmentResponse.java
index 1b87826..308827a 100644
--- a/src/main/java/apache/rocketmq/v2/QueryAssignmentResponse.java
+++ b/src/main/java/apache/rocketmq/v2/QueryAssignmentResponse.java
@@ -83,6 +83,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/QueryRouteRequest.java b/src/main/java/apache/rocketmq/v2/QueryRouteRequest.java
index 361bb6d..9810371 100644
--- a/src/main/java/apache/rocketmq/v2/QueryRouteRequest.java
+++ b/src/main/java/apache/rocketmq/v2/QueryRouteRequest.java
@@ -102,6 +102,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/QueryRouteResponse.java b/src/main/java/apache/rocketmq/v2/QueryRouteResponse.java
index 0b56b7b..e106cb7 100644
--- a/src/main/java/apache/rocketmq/v2/QueryRouteResponse.java
+++ b/src/main/java/apache/rocketmq/v2/QueryRouteResponse.java
@@ -83,6 +83,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/ReceiveMessageRequest.java b/src/main/java/apache/rocketmq/v2/ReceiveMessageRequest.java
index 42f2936..8f19964 100644
--- a/src/main/java/apache/rocketmq/v2/ReceiveMessageRequest.java
+++ b/src/main/java/apache/rocketmq/v2/ReceiveMessageRequest.java
@@ -122,6 +122,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/ReceiveMessageResponse.java b/src/main/java/apache/rocketmq/v2/ReceiveMessageResponse.java
index 7b396de..2f99a7f 100644
--- a/src/main/java/apache/rocketmq/v2/ReceiveMessageResponse.java
+++ b/src/main/java/apache/rocketmq/v2/ReceiveMessageResponse.java
@@ -101,6 +101,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -739,8 +741,9 @@ private static final long serialVersionUID = 0L;
} else {
if (contentCase_ == 1) {
statusBuilder_.mergeFrom(value);
+ } else {
+ statusBuilder_.setMessage(value);
}
- statusBuilder_.setMessage(value);
}
contentCase_ = 1;
return this;
@@ -880,8 +883,9 @@ private static final long serialVersionUID = 0L;
} else {
if (contentCase_ == 2) {
messageBuilder_.mergeFrom(value);
+ } else {
+ messageBuilder_.setMessage(value);
}
- messageBuilder_.setMessage(value);
}
contentCase_ = 2;
return this;
@@ -1041,8 +1045,9 @@ private static final long serialVersionUID = 0L;
} else {
if (contentCase_ == 3) {
deliveryTimestampBuilder_.mergeFrom(value);
+ } else {
+ deliveryTimestampBuilder_.setMessage(value);
}
- deliveryTimestampBuilder_.setMessage(value);
}
contentCase_ = 3;
return this;
diff --git a/src/main/java/apache/rocketmq/v2/RecoverOrphanedTransactionCommand.java b/src/main/java/apache/rocketmq/v2/RecoverOrphanedTransactionCommand.java
index 6b18c19..0d95ad0 100644
--- a/src/main/java/apache/rocketmq/v2/RecoverOrphanedTransactionCommand.java
+++ b/src/main/java/apache/rocketmq/v2/RecoverOrphanedTransactionCommand.java
@@ -79,6 +79,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/Resource.java b/src/main/java/apache/rocketmq/v2/Resource.java
index ceee105..24e6dbc 100644
--- a/src/main/java/apache/rocketmq/v2/Resource.java
+++ b/src/main/java/apache/rocketmq/v2/Resource.java
@@ -73,6 +73,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/RetryPolicy.java b/src/main/java/apache/rocketmq/v2/RetryPolicy.java
index dbc39b8..6ec13ef 100644
--- a/src/main/java/apache/rocketmq/v2/RetryPolicy.java
+++ b/src/main/java/apache/rocketmq/v2/RetryPolicy.java
@@ -92,6 +92,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -718,8 +720,9 @@ private static final long serialVersionUID = 0L;
} else {
if (strategyCase_ == 2) {
exponentialBackoffBuilder_.mergeFrom(value);
+ } else {
+ exponentialBackoffBuilder_.setMessage(value);
}
- exponentialBackoffBuilder_.setMessage(value);
}
strategyCase_ = 2;
return this;
@@ -859,8 +862,9 @@ private static final long serialVersionUID = 0L;
} else {
if (strategyCase_ == 3) {
customizedBackoffBuilder_.mergeFrom(value);
+ } else {
+ customizedBackoffBuilder_.setMessage(value);
}
- customizedBackoffBuilder_.setMessage(value);
}
strategyCase_ = 3;
return this;
diff --git a/src/main/java/apache/rocketmq/v2/SendMessageRequest.java b/src/main/java/apache/rocketmq/v2/SendMessageRequest.java
index 6bfacb3..26addac 100644
--- a/src/main/java/apache/rocketmq/v2/SendMessageRequest.java
+++ b/src/main/java/apache/rocketmq/v2/SendMessageRequest.java
@@ -70,6 +70,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/SendMessageResponse.java b/src/main/java/apache/rocketmq/v2/SendMessageResponse.java
index f6ac84f..114e993 100644
--- a/src/main/java/apache/rocketmq/v2/SendMessageResponse.java
+++ b/src/main/java/apache/rocketmq/v2/SendMessageResponse.java
@@ -83,6 +83,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/SendResultEntry.java b/src/main/java/apache/rocketmq/v2/SendResultEntry.java
index d9de7e1..5264d19 100644
--- a/src/main/java/apache/rocketmq/v2/SendResultEntry.java
+++ b/src/main/java/apache/rocketmq/v2/SendResultEntry.java
@@ -91,6 +91,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/Settings.java b/src/main/java/apache/rocketmq/v2/Settings.java
index 08f7d4f..378e29a 100644
--- a/src/main/java/apache/rocketmq/v2/Settings.java
+++ b/src/main/java/apache/rocketmq/v2/Settings.java
@@ -160,6 +160,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -1723,8 +1725,9 @@ private static final long serialVersionUID = 0L;
} else {
if (pubSubCase_ == 5) {
publishingBuilder_.mergeFrom(value);
+ } else {
+ publishingBuilder_.setMessage(value);
}
- publishingBuilder_.setMessage(value);
}
pubSubCase_ = 5;
return this;
@@ -1864,8 +1867,9 @@ private static final long serialVersionUID = 0L;
} else {
if (pubSubCase_ == 6) {
subscriptionBuilder_.mergeFrom(value);
+ } else {
+ subscriptionBuilder_.setMessage(value);
}
- subscriptionBuilder_.setMessage(value);
}
pubSubCase_ = 6;
return this;
diff --git a/src/main/java/apache/rocketmq/v2/Status.java b/src/main/java/apache/rocketmq/v2/Status.java
index 598a3ff..122cecd 100644
--- a/src/main/java/apache/rocketmq/v2/Status.java
+++ b/src/main/java/apache/rocketmq/v2/Status.java
@@ -73,6 +73,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/Subscription.java b/src/main/java/apache/rocketmq/v2/Subscription.java
index baff4ac..91e2764 100644
--- a/src/main/java/apache/rocketmq/v2/Subscription.java
+++ b/src/main/java/apache/rocketmq/v2/Subscription.java
@@ -106,6 +106,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/SubscriptionEntry.java b/src/main/java/apache/rocketmq/v2/SubscriptionEntry.java
index eeccea0..5361596 100644
--- a/src/main/java/apache/rocketmq/v2/SubscriptionEntry.java
+++ b/src/main/java/apache/rocketmq/v2/SubscriptionEntry.java
@@ -85,6 +85,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/SystemProperties.java b/src/main/java/apache/rocketmq/v2/SystemProperties.java
index eb3475e..91565b3 100644
--- a/src/main/java/apache/rocketmq/v2/SystemProperties.java
+++ b/src/main/java/apache/rocketmq/v2/SystemProperties.java
@@ -226,6 +226,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/TelemetryCommand.java b/src/main/java/apache/rocketmq/v2/TelemetryCommand.java
index 2e63f11..0aa3098 100644
--- a/src/main/java/apache/rocketmq/v2/TelemetryCommand.java
+++ b/src/main/java/apache/rocketmq/v2/TelemetryCommand.java
@@ -157,6 +157,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -1243,8 +1245,9 @@ private static final long serialVersionUID = 0L;
} else {
if (commandCase_ == 2) {
settingsBuilder_.mergeFrom(value);
+ } else {
+ settingsBuilder_.setMessage(value);
}
- settingsBuilder_.setMessage(value);
}
commandCase_ = 2;
return this;
@@ -1425,8 +1428,9 @@ private static final long serialVersionUID = 0L;
} else {
if (commandCase_ == 3) {
threadStackTraceBuilder_.mergeFrom(value);
+ } else {
+ threadStackTraceBuilder_.setMessage(value);
}
- threadStackTraceBuilder_.setMessage(value);
}
commandCase_ = 3;
return this;
@@ -1606,8 +1610,9 @@ private static final long serialVersionUID = 0L;
} else {
if (commandCase_ == 4) {
verifyMessageResultBuilder_.mergeFrom(value);
+ } else {
+ verifyMessageResultBuilder_.setMessage(value);
}
- verifyMessageResultBuilder_.setMessage(value);
}
commandCase_ = 4;
return this;
@@ -1788,8 +1793,9 @@ private static final long serialVersionUID = 0L;
} else {
if (commandCase_ == 5) {
recoverOrphanedTransactionCommandBuilder_.mergeFrom(value);
+ } else {
+ recoverOrphanedTransactionCommandBuilder_.setMessage(value);
}
- recoverOrphanedTransactionCommandBuilder_.setMessage(value);
}
commandCase_ = 5;
return this;
@@ -1969,8 +1975,9 @@ private static final long serialVersionUID = 0L;
} else {
if (commandCase_ == 6) {
printThreadStackTraceCommandBuilder_.mergeFrom(value);
+ } else {
+ printThreadStackTraceCommandBuilder_.setMessage(value);
}
- printThreadStackTraceCommandBuilder_.setMessage(value);
}
commandCase_ = 6;
return this;
@@ -2146,8 +2153,9 @@ private static final long serialVersionUID = 0L;
} else {
if (commandCase_ == 7) {
verifyMessageCommandBuilder_.mergeFrom(value);
+ } else {
+ verifyMessageCommandBuilder_.setMessage(value);
}
- verifyMessageCommandBuilder_.setMessage(value);
}
commandCase_ = 7;
return this;
diff --git a/src/main/java/apache/rocketmq/v2/ThreadStackTrace.java b/src/main/java/apache/rocketmq/v2/ThreadStackTrace.java
index 234fe88..dbf0de5 100644
--- a/src/main/java/apache/rocketmq/v2/ThreadStackTrace.java
+++ b/src/main/java/apache/rocketmq/v2/ThreadStackTrace.java
@@ -74,6 +74,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/UA.java b/src/main/java/apache/rocketmq/v2/UA.java
index 2dfb54c..38bfa54 100644
--- a/src/main/java/apache/rocketmq/v2/UA.java
+++ b/src/main/java/apache/rocketmq/v2/UA.java
@@ -91,6 +91,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/VerifyMessageCommand.java b/src/main/java/apache/rocketmq/v2/VerifyMessageCommand.java
index 2fece70..56a68e2 100644
--- a/src/main/java/apache/rocketmq/v2/VerifyMessageCommand.java
+++ b/src/main/java/apache/rocketmq/v2/VerifyMessageCommand.java
@@ -79,6 +79,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
diff --git a/src/main/java/apache/rocketmq/v2/VerifyMessageResult.java b/src/main/java/apache/rocketmq/v2/VerifyMessageResult.java
index 2921e76..365362d 100644
--- a/src/main/java/apache/rocketmq/v2/VerifyMessageResult.java
+++ b/src/main/java/apache/rocketmq/v2/VerifyMessageResult.java
@@ -66,6 +66,8 @@ private static final long serialVersionUID = 0L;
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);