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