getMsgIdsList();
+ /**
+ * repeated int32 msgIds = 3;
+ * @return The count of msgIds.
+ */
+ int getMsgIdsCount();
+ /**
+ * repeated int32 msgIds = 3;
+ * @param index The index of the element to return.
+ * @return The msgIds at the given index.
+ */
+ int getMsgIds(int index);
+}
diff --git a/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/MessageType.java b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/MessageType.java
new file mode 100644
index 00000000000..6ea1ae6cb5d
--- /dev/null
+++ b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/MessageType.java
@@ -0,0 +1,58 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: messageType.proto
+
+package org.apache.seata.core.serializer.protobuf.generated;
+
+public final class MessageType {
+ private MessageType() {}
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistryLite registry) {
+ }
+
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistry registry) {
+ registerAllExtensions(
+ (com.google.protobuf.ExtensionRegistryLite) registry);
+ }
+
+ public static com.google.protobuf.Descriptors.FileDescriptor
+ getDescriptor() {
+ return descriptor;
+ }
+ private static com.google.protobuf.Descriptors.FileDescriptor
+ descriptor;
+ static {
+ String[] descriptorData = {
+ "\n\021messageType.proto\022\"org.apache.seata.pr" +
+ "otocol.protobuf*\257\006\n\020MessageTypeProto\022\031\n\025" +
+ "TYPE_GLOBAL_PRESERVED\020\000\022\025\n\021TYPE_GLOBAL_B" +
+ "EGIN\020\001\022\034\n\030TYPE_GLOBAL_BEGIN_RESULT\020\002\022\026\n\022" +
+ "TYPE_GLOBAL_COMMIT\020\007\022\035\n\031TYPE_GLOBAL_COMM" +
+ "IT_RESULT\020\010\022\030\n\024TYPE_GLOBAL_ROLLBACK\020\t\022\037\n" +
+ "\033TYPE_GLOBAL_ROLLBACK_RESULT\020\n\022\026\n\022TYPE_G" +
+ "LOBAL_STATUS\020\017\022\035\n\031TYPE_GLOBAL_STATUS_RES" +
+ "ULT\020\020\022\026\n\022TYPE_GLOBAL_REPORT\020\021\022\035\n\031TYPE_GL" +
+ "OBAL_REPORT_RESULT\020\022\022\032\n\026TYPE_GLOBAL_LOCK" +
+ "_QUERY\020\025\022!\n\035TYPE_GLOBAL_LOCK_QUERY_RESUL" +
+ "T\020\026\022\026\n\022TYPE_BRANCH_COMMIT\020\003\022\035\n\031TYPE_BRAN" +
+ "CH_COMMIT_RESULT\020\004\022\030\n\024TYPE_BRANCH_ROLLBA" +
+ "CK\020\005\022\037\n\033TYPE_BRANCH_ROLLBACK_RESULT\020\006\022\030\n" +
+ "\024TYPE_BRANCH_REGISTER\020\013\022\037\n\033TYPE_BRANCH_R" +
+ "EGISTER_RESULT\020\014\022\035\n\031TYPE_BRANCH_STATUS_R" +
+ "EPORT\020\r\022$\n TYPE_BRANCH_STATUS_REPORT_RES" +
+ "ULT\020\016\022\024\n\020TYPE_SEATA_MERGE\020;\022\033\n\027TYPE_SEAT" +
+ "A_MERGE_RESULT\020<\022\020\n\014TYPE_REG_CLT\020e\022\027\n\023TY" +
+ "PE_REG_CLT_RESULT\020f\022\017\n\013TYPE_REG_RM\020g\022\026\n\022" +
+ "TYPE_REG_RM_RESULT\020h\022\030\n\024TYPE_UNDO_LOG_DE" +
+ "LETE\020o\022\031\n\025TYPE_BATCH_RESULT_MSG\020yBD\n3org" +
+ ".apache.seata.core.serializer.protobuf.g" +
+ "eneratedB\013MessageTypeP\001b\006proto3"
+ };
+ descriptor = com.google.protobuf.Descriptors.FileDescriptor
+ .internalBuildGeneratedFileFrom(descriptorData,
+ new com.google.protobuf.Descriptors.FileDescriptor[] {
+ });
+ }
+
+ // @@protoc_insertion_point(outer_class_scope)
+}
diff --git a/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/MessageTypeProto.java b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/MessageTypeProto.java
new file mode 100644
index 00000000000..3a4617142eb
--- /dev/null
+++ b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/MessageTypeProto.java
@@ -0,0 +1,620 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: messageType.proto
+
+package org.apache.seata.core.serializer.protobuf.generated;
+
+/**
+ *
+ * PublishRequest is a publish request.
+ *
+ *
+ * Protobuf enum {@code org.apache.seata.protocol.protobuf.MessageTypeProto}
+ */
+public enum MessageTypeProto
+ implements com.google.protobuf.ProtocolMessageEnum {
+ /**
+ * TYPE_GLOBAL_PRESERVED = 0;
+ */
+ TYPE_GLOBAL_PRESERVED(0),
+ /**
+ * TYPE_GLOBAL_BEGIN = 1;
+ */
+ TYPE_GLOBAL_BEGIN(1),
+ /**
+ * TYPE_GLOBAL_BEGIN_RESULT = 2;
+ */
+ TYPE_GLOBAL_BEGIN_RESULT(2),
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_COMMIT.
+ *
+ *
+ * TYPE_GLOBAL_COMMIT = 7;
+ */
+ TYPE_GLOBAL_COMMIT(7),
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_COMMIT_RESULT.
+ *
+ *
+ * TYPE_GLOBAL_COMMIT_RESULT = 8;
+ */
+ TYPE_GLOBAL_COMMIT_RESULT(8),
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_ROLLBACK.
+ *
+ *
+ * TYPE_GLOBAL_ROLLBACK = 9;
+ */
+ TYPE_GLOBAL_ROLLBACK(9),
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_ROLLBACK_RESULT.
+ *
+ *
+ * TYPE_GLOBAL_ROLLBACK_RESULT = 10;
+ */
+ TYPE_GLOBAL_ROLLBACK_RESULT(10),
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_STATUS.
+ *
+ *
+ * TYPE_GLOBAL_STATUS = 15;
+ */
+ TYPE_GLOBAL_STATUS(15),
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_STATUS_RESULT.
+ *
+ *
+ * TYPE_GLOBAL_STATUS_RESULT = 16;
+ */
+ TYPE_GLOBAL_STATUS_RESULT(16),
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_REPORT.
+ *
+ *
+ * TYPE_GLOBAL_REPORT = 17;
+ */
+ TYPE_GLOBAL_REPORT(17),
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_REPORT_RESULT.
+ *
+ *
+ * TYPE_GLOBAL_REPORT_RESULT = 18;
+ */
+ TYPE_GLOBAL_REPORT_RESULT(18),
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_LOCK_QUERY.
+ *
+ *
+ * TYPE_GLOBAL_LOCK_QUERY = 21;
+ */
+ TYPE_GLOBAL_LOCK_QUERY(21),
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_LOCK_QUERY_RESULT.
+ *
+ *
+ * TYPE_GLOBAL_LOCK_QUERY_RESULT = 22;
+ */
+ TYPE_GLOBAL_LOCK_QUERY_RESULT(22),
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_COMMIT.
+ *
+ *
+ * TYPE_BRANCH_COMMIT = 3;
+ */
+ TYPE_BRANCH_COMMIT(3),
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_COMMIT_RESULT.
+ *
+ *
+ * TYPE_BRANCH_COMMIT_RESULT = 4;
+ */
+ TYPE_BRANCH_COMMIT_RESULT(4),
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_ROLLBACK.
+ *
+ *
+ * TYPE_BRANCH_ROLLBACK = 5;
+ */
+ TYPE_BRANCH_ROLLBACK(5),
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_ROLLBACK_RESULT.
+ *
+ *
+ * TYPE_BRANCH_ROLLBACK_RESULT = 6;
+ */
+ TYPE_BRANCH_ROLLBACK_RESULT(6),
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_REGISTER.
+ *
+ *
+ * TYPE_BRANCH_REGISTER = 11;
+ */
+ TYPE_BRANCH_REGISTER(11),
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_REGISTER_RESULT.
+ *
+ *
+ * TYPE_BRANCH_REGISTER_RESULT = 12;
+ */
+ TYPE_BRANCH_REGISTER_RESULT(12),
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_STATUS_REPORT.
+ *
+ *
+ * TYPE_BRANCH_STATUS_REPORT = 13;
+ */
+ TYPE_BRANCH_STATUS_REPORT(13),
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_STATUS_REPORT_RESULT.
+ *
+ *
+ * TYPE_BRANCH_STATUS_REPORT_RESULT = 14;
+ */
+ TYPE_BRANCH_STATUS_REPORT_RESULT(14),
+ /**
+ *
+ **
+ * The constant TYPE_SEATA_MERGE.
+ *
+ *
+ * TYPE_SEATA_MERGE = 59;
+ */
+ TYPE_SEATA_MERGE(59),
+ /**
+ *
+ **
+ * The constant TYPE_SEATA_MERGE_RESULT.
+ *
+ *
+ * TYPE_SEATA_MERGE_RESULT = 60;
+ */
+ TYPE_SEATA_MERGE_RESULT(60),
+ /**
+ *
+ **
+ * The constant TYPE_REG_CLT.
+ *
+ *
+ * TYPE_REG_CLT = 101;
+ */
+ TYPE_REG_CLT(101),
+ /**
+ *
+ **
+ * The constant TYPE_REG_CLT_RESULT.
+ *
+ *
+ * TYPE_REG_CLT_RESULT = 102;
+ */
+ TYPE_REG_CLT_RESULT(102),
+ /**
+ *
+ **
+ * The constant TYPE_REG_RM.
+ *
+ *
+ * TYPE_REG_RM = 103;
+ */
+ TYPE_REG_RM(103),
+ /**
+ *
+ **
+ * The constant TYPE_REG_RM_RESULT.
+ *
+ *
+ * TYPE_REG_RM_RESULT = 104;
+ */
+ TYPE_REG_RM_RESULT(104),
+ /**
+ *
+ **
+ * The constant TYPE_UNDO_LOG_DELETE.
+ *
+ *
+ * TYPE_UNDO_LOG_DELETE = 111;
+ */
+ TYPE_UNDO_LOG_DELETE(111),
+ /**
+ *
+ **
+ * the constant TYPE_BATCH_RESULT_MSG
+ *
+ *
+ * TYPE_BATCH_RESULT_MSG = 121;
+ */
+ TYPE_BATCH_RESULT_MSG(121),
+ UNRECOGNIZED(-1),
+ ;
+
+ /**
+ * TYPE_GLOBAL_PRESERVED = 0;
+ */
+ public static final int TYPE_GLOBAL_PRESERVED_VALUE = 0;
+ /**
+ * TYPE_GLOBAL_BEGIN = 1;
+ */
+ public static final int TYPE_GLOBAL_BEGIN_VALUE = 1;
+ /**
+ * TYPE_GLOBAL_BEGIN_RESULT = 2;
+ */
+ public static final int TYPE_GLOBAL_BEGIN_RESULT_VALUE = 2;
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_COMMIT.
+ *
+ *
+ * TYPE_GLOBAL_COMMIT = 7;
+ */
+ public static final int TYPE_GLOBAL_COMMIT_VALUE = 7;
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_COMMIT_RESULT.
+ *
+ *
+ * TYPE_GLOBAL_COMMIT_RESULT = 8;
+ */
+ public static final int TYPE_GLOBAL_COMMIT_RESULT_VALUE = 8;
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_ROLLBACK.
+ *
+ *
+ * TYPE_GLOBAL_ROLLBACK = 9;
+ */
+ public static final int TYPE_GLOBAL_ROLLBACK_VALUE = 9;
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_ROLLBACK_RESULT.
+ *
+ *
+ * TYPE_GLOBAL_ROLLBACK_RESULT = 10;
+ */
+ public static final int TYPE_GLOBAL_ROLLBACK_RESULT_VALUE = 10;
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_STATUS.
+ *
+ *
+ * TYPE_GLOBAL_STATUS = 15;
+ */
+ public static final int TYPE_GLOBAL_STATUS_VALUE = 15;
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_STATUS_RESULT.
+ *
+ *
+ * TYPE_GLOBAL_STATUS_RESULT = 16;
+ */
+ public static final int TYPE_GLOBAL_STATUS_RESULT_VALUE = 16;
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_REPORT.
+ *
+ *
+ * TYPE_GLOBAL_REPORT = 17;
+ */
+ public static final int TYPE_GLOBAL_REPORT_VALUE = 17;
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_REPORT_RESULT.
+ *
+ *
+ * TYPE_GLOBAL_REPORT_RESULT = 18;
+ */
+ public static final int TYPE_GLOBAL_REPORT_RESULT_VALUE = 18;
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_LOCK_QUERY.
+ *
+ *
+ * TYPE_GLOBAL_LOCK_QUERY = 21;
+ */
+ public static final int TYPE_GLOBAL_LOCK_QUERY_VALUE = 21;
+ /**
+ *
+ **
+ * The constant TYPE_GLOBAL_LOCK_QUERY_RESULT.
+ *
+ *
+ * TYPE_GLOBAL_LOCK_QUERY_RESULT = 22;
+ */
+ public static final int TYPE_GLOBAL_LOCK_QUERY_RESULT_VALUE = 22;
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_COMMIT.
+ *
+ *
+ * TYPE_BRANCH_COMMIT = 3;
+ */
+ public static final int TYPE_BRANCH_COMMIT_VALUE = 3;
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_COMMIT_RESULT.
+ *
+ *
+ * TYPE_BRANCH_COMMIT_RESULT = 4;
+ */
+ public static final int TYPE_BRANCH_COMMIT_RESULT_VALUE = 4;
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_ROLLBACK.
+ *
+ *
+ * TYPE_BRANCH_ROLLBACK = 5;
+ */
+ public static final int TYPE_BRANCH_ROLLBACK_VALUE = 5;
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_ROLLBACK_RESULT.
+ *
+ *
+ * TYPE_BRANCH_ROLLBACK_RESULT = 6;
+ */
+ public static final int TYPE_BRANCH_ROLLBACK_RESULT_VALUE = 6;
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_REGISTER.
+ *
+ *
+ * TYPE_BRANCH_REGISTER = 11;
+ */
+ public static final int TYPE_BRANCH_REGISTER_VALUE = 11;
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_REGISTER_RESULT.
+ *
+ *
+ * TYPE_BRANCH_REGISTER_RESULT = 12;
+ */
+ public static final int TYPE_BRANCH_REGISTER_RESULT_VALUE = 12;
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_STATUS_REPORT.
+ *
+ *
+ * TYPE_BRANCH_STATUS_REPORT = 13;
+ */
+ public static final int TYPE_BRANCH_STATUS_REPORT_VALUE = 13;
+ /**
+ *
+ **
+ * The constant TYPE_BRANCH_STATUS_REPORT_RESULT.
+ *
+ *
+ * TYPE_BRANCH_STATUS_REPORT_RESULT = 14;
+ */
+ public static final int TYPE_BRANCH_STATUS_REPORT_RESULT_VALUE = 14;
+ /**
+ *
+ **
+ * The constant TYPE_SEATA_MERGE.
+ *
+ *
+ * TYPE_SEATA_MERGE = 59;
+ */
+ public static final int TYPE_SEATA_MERGE_VALUE = 59;
+ /**
+ *
+ **
+ * The constant TYPE_SEATA_MERGE_RESULT.
+ *
+ *
+ * TYPE_SEATA_MERGE_RESULT = 60;
+ */
+ public static final int TYPE_SEATA_MERGE_RESULT_VALUE = 60;
+ /**
+ *
+ **
+ * The constant TYPE_REG_CLT.
+ *
+ *
+ * TYPE_REG_CLT = 101;
+ */
+ public static final int TYPE_REG_CLT_VALUE = 101;
+ /**
+ *
+ **
+ * The constant TYPE_REG_CLT_RESULT.
+ *
+ *
+ * TYPE_REG_CLT_RESULT = 102;
+ */
+ public static final int TYPE_REG_CLT_RESULT_VALUE = 102;
+ /**
+ *
+ **
+ * The constant TYPE_REG_RM.
+ *
+ *
+ * TYPE_REG_RM = 103;
+ */
+ public static final int TYPE_REG_RM_VALUE = 103;
+ /**
+ *
+ **
+ * The constant TYPE_REG_RM_RESULT.
+ *
+ *
+ * TYPE_REG_RM_RESULT = 104;
+ */
+ public static final int TYPE_REG_RM_RESULT_VALUE = 104;
+ /**
+ *
+ **
+ * The constant TYPE_UNDO_LOG_DELETE.
+ *
+ *
+ * TYPE_UNDO_LOG_DELETE = 111;
+ */
+ public static final int TYPE_UNDO_LOG_DELETE_VALUE = 111;
+ /**
+ *
+ **
+ * the constant TYPE_BATCH_RESULT_MSG
+ *
+ *
+ * TYPE_BATCH_RESULT_MSG = 121;
+ */
+ public static final int TYPE_BATCH_RESULT_MSG_VALUE = 121;
+
+
+ public final int getNumber() {
+ if (this == UNRECOGNIZED) {
+ throw new IllegalArgumentException(
+ "Can't get the number of an unknown enum value.");
+ }
+ return value;
+ }
+
+ /**
+ * @param value The numeric wire value of the corresponding enum entry.
+ * @return The enum associated with the given numeric wire value.
+ * @deprecated Use {@link #forNumber(int)} instead.
+ */
+ @Deprecated
+ public static MessageTypeProto valueOf(int value) {
+ return forNumber(value);
+ }
+
+ /**
+ * @param value The numeric wire value of the corresponding enum entry.
+ * @return The enum associated with the given numeric wire value.
+ */
+ public static MessageTypeProto forNumber(int value) {
+ switch (value) {
+ case 0: return TYPE_GLOBAL_PRESERVED;
+ case 1: return TYPE_GLOBAL_BEGIN;
+ case 2: return TYPE_GLOBAL_BEGIN_RESULT;
+ case 7: return TYPE_GLOBAL_COMMIT;
+ case 8: return TYPE_GLOBAL_COMMIT_RESULT;
+ case 9: return TYPE_GLOBAL_ROLLBACK;
+ case 10: return TYPE_GLOBAL_ROLLBACK_RESULT;
+ case 15: return TYPE_GLOBAL_STATUS;
+ case 16: return TYPE_GLOBAL_STATUS_RESULT;
+ case 17: return TYPE_GLOBAL_REPORT;
+ case 18: return TYPE_GLOBAL_REPORT_RESULT;
+ case 21: return TYPE_GLOBAL_LOCK_QUERY;
+ case 22: return TYPE_GLOBAL_LOCK_QUERY_RESULT;
+ case 3: return TYPE_BRANCH_COMMIT;
+ case 4: return TYPE_BRANCH_COMMIT_RESULT;
+ case 5: return TYPE_BRANCH_ROLLBACK;
+ case 6: return TYPE_BRANCH_ROLLBACK_RESULT;
+ case 11: return TYPE_BRANCH_REGISTER;
+ case 12: return TYPE_BRANCH_REGISTER_RESULT;
+ case 13: return TYPE_BRANCH_STATUS_REPORT;
+ case 14: return TYPE_BRANCH_STATUS_REPORT_RESULT;
+ case 59: return TYPE_SEATA_MERGE;
+ case 60: return TYPE_SEATA_MERGE_RESULT;
+ case 101: return TYPE_REG_CLT;
+ case 102: return TYPE_REG_CLT_RESULT;
+ case 103: return TYPE_REG_RM;
+ case 104: return TYPE_REG_RM_RESULT;
+ case 111: return TYPE_UNDO_LOG_DELETE;
+ case 121: return TYPE_BATCH_RESULT_MSG;
+ default: return null;
+ }
+ }
+
+ public static com.google.protobuf.Internal.EnumLiteMap
+ internalGetValueMap() {
+ return internalValueMap;
+ }
+ private static final com.google.protobuf.Internal.EnumLiteMap<
+ MessageTypeProto> internalValueMap =
+ new com.google.protobuf.Internal.EnumLiteMap() {
+ public MessageTypeProto findValueByNumber(int number) {
+ return MessageTypeProto.forNumber(number);
+ }
+ };
+
+ public final com.google.protobuf.Descriptors.EnumValueDescriptor
+ getValueDescriptor() {
+ if (this == UNRECOGNIZED) {
+ throw new IllegalStateException(
+ "Can't get the descriptor of an unrecognized enum value.");
+ }
+ return getDescriptor().getValues().get(ordinal());
+ }
+ public final com.google.protobuf.Descriptors.EnumDescriptor
+ getDescriptorForType() {
+ return getDescriptor();
+ }
+ public static final com.google.protobuf.Descriptors.EnumDescriptor
+ getDescriptor() {
+ return MessageType.getDescriptor().getEnumTypes().get(0);
+ }
+
+ private static final MessageTypeProto[] VALUES = values();
+
+ public static MessageTypeProto valueOf(
+ com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
+ if (desc.getType() != getDescriptor()) {
+ throw new IllegalArgumentException(
+ "EnumValueDescriptor is not for this type.");
+ }
+ if (desc.getIndex() == -1) {
+ return UNRECOGNIZED;
+ }
+ return VALUES[desc.getIndex()];
+ }
+
+ private final int value;
+
+ private MessageTypeProto(int value) {
+ this.value = value;
+ }
+
+ // @@protoc_insertion_point(enum_scope:org.apache.seata.protocol.protobuf.MessageTypeProto)
+}
+
diff --git a/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMRequest.java b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMRequest.java
new file mode 100644
index 00000000000..cf3c8ebcaa2
--- /dev/null
+++ b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMRequest.java
@@ -0,0 +1,56 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: registerRMRequest.proto
+
+package org.apache.seata.core.serializer.protobuf.generated;
+
+public final class RegisterRMRequest {
+ private RegisterRMRequest() {}
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistryLite registry) {
+ }
+
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistry registry) {
+ registerAllExtensions(
+ (com.google.protobuf.ExtensionRegistryLite) registry);
+ }
+ static final com.google.protobuf.Descriptors.Descriptor
+ internal_static_org_apache_seata_protocol_protobuf_RegisterRMRequestProto_descriptor;
+ static final
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internal_static_org_apache_seata_protocol_protobuf_RegisterRMRequestProto_fieldAccessorTable;
+
+ public static com.google.protobuf.Descriptors.FileDescriptor
+ getDescriptor() {
+ return descriptor;
+ }
+ private static com.google.protobuf.Descriptors.FileDescriptor
+ descriptor;
+ static {
+ String[] descriptorData = {
+ "\n\027registerRMRequest.proto\022\"org.apache.se" +
+ "ata.protocol.protobuf\032\035abstractIdentifyR" +
+ "equest.proto\"\220\001\n\026RegisterRMRequestProto\022" +
+ "a\n\027abstractIdentifyRequest\030\001 \001(\0132@.org.a" +
+ "pache.seata.protocol.protobuf.AbstractId" +
+ "entifyRequestProto\022\023\n\013resourceIds\030\002 \001(\tB" +
+ "J\n3org.apache.seata.core.serializer.prot" +
+ "obuf.generatedB\021RegisterRMRequestP\001b\006pro" +
+ "to3"
+ };
+ descriptor = com.google.protobuf.Descriptors.FileDescriptor
+ .internalBuildGeneratedFileFrom(descriptorData,
+ new com.google.protobuf.Descriptors.FileDescriptor[] {
+ AbstractIdentifyRequest.getDescriptor(),
+ });
+ internal_static_org_apache_seata_protocol_protobuf_RegisterRMRequestProto_descriptor =
+ getDescriptor().getMessageTypes().get(0);
+ internal_static_org_apache_seata_protocol_protobuf_RegisterRMRequestProto_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+ internal_static_org_apache_seata_protocol_protobuf_RegisterRMRequestProto_descriptor,
+ new String[] { "AbstractIdentifyRequest", "ResourceIds", });
+ AbstractIdentifyRequest.getDescriptor();
+ }
+
+ // @@protoc_insertion_point(outer_class_scope)
+}
diff --git a/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMRequestProto.java b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMRequestProto.java
new file mode 100644
index 00000000000..178cc220691
--- /dev/null
+++ b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMRequestProto.java
@@ -0,0 +1,755 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: registerRMRequest.proto
+
+package org.apache.seata.core.serializer.protobuf.generated;
+
+/**
+ *
+ * PublishRequest is a publish request.
+ *
+ *
+ * Protobuf type {@code org.apache.seata.protocol.protobuf.RegisterRMRequestProto}
+ */
+public final class RegisterRMRequestProto extends
+ com.google.protobuf.GeneratedMessageV3 implements
+ // @@protoc_insertion_point(message_implements:org.apache.seata.protocol.protobuf.RegisterRMRequestProto)
+ RegisterRMRequestProtoOrBuilder {
+private static final long serialVersionUID = 0L;
+ // Use RegisterRMRequestProto.newBuilder() to construct.
+ private RegisterRMRequestProto(com.google.protobuf.GeneratedMessageV3.Builder builder) {
+ super(builder);
+ }
+ private RegisterRMRequestProto() {
+ resourceIds_ = "";
+ }
+
+ @Override
+ @SuppressWarnings({"unused"})
+ protected Object newInstance(
+ UnusedPrivateParameter unused) {
+ return new RegisterRMRequestProto();
+ }
+
+ @Override
+ public final com.google.protobuf.UnknownFieldSet
+ getUnknownFields() {
+ return this.unknownFields;
+ }
+ private RegisterRMRequestProto(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ this();
+ if (extensionRegistry == null) {
+ throw new NullPointerException();
+ }
+ com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+ com.google.protobuf.UnknownFieldSet.newBuilder();
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ case 10: {
+ AbstractIdentifyRequestProto.Builder subBuilder = null;
+ if (abstractIdentifyRequest_ != null) {
+ subBuilder = abstractIdentifyRequest_.toBuilder();
+ }
+ abstractIdentifyRequest_ = input.readMessage(AbstractIdentifyRequestProto.parser(), extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(abstractIdentifyRequest_);
+ abstractIdentifyRequest_ = subBuilder.buildPartial();
+ }
+
+ break;
+ }
+ case 18: {
+ String s = input.readStringRequireUtf8();
+
+ resourceIds_ = s;
+ break;
+ }
+ default: {
+ if (!parseUnknownField(
+ input, unknownFields, extensionRegistry, tag)) {
+ done = true;
+ }
+ break;
+ }
+ }
+ }
+ } 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);
+ } finally {
+ this.unknownFields = unknownFields.build();
+ makeExtensionsImmutable();
+ }
+ }
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return RegisterRMRequest.internal_static_org_apache_seata_protocol_protobuf_RegisterRMRequestProto_descriptor;
+ }
+
+ @Override
+ protected FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return RegisterRMRequest.internal_static_org_apache_seata_protocol_protobuf_RegisterRMRequestProto_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ RegisterRMRequestProto.class, Builder.class);
+ }
+
+ public static final int ABSTRACTIDENTIFYREQUEST_FIELD_NUMBER = 1;
+ private AbstractIdentifyRequestProto abstractIdentifyRequest_;
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ * @return Whether the abstractIdentifyRequest field is set.
+ */
+ @Override
+ public boolean hasAbstractIdentifyRequest() {
+ return abstractIdentifyRequest_ != null;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ * @return The abstractIdentifyRequest.
+ */
+ @Override
+ public AbstractIdentifyRequestProto getAbstractIdentifyRequest() {
+ return abstractIdentifyRequest_ == null ? AbstractIdentifyRequestProto.getDefaultInstance() : abstractIdentifyRequest_;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ @Override
+ public AbstractIdentifyRequestProtoOrBuilder getAbstractIdentifyRequestOrBuilder() {
+ return getAbstractIdentifyRequest();
+ }
+
+ public static final int RESOURCEIDS_FIELD_NUMBER = 2;
+ private volatile Object resourceIds_;
+ /**
+ * string resourceIds = 2;
+ * @return The resourceIds.
+ */
+ @Override
+ public String getResourceIds() {
+ Object ref = resourceIds_;
+ if (ref instanceof String) {
+ return (String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ resourceIds_ = s;
+ return s;
+ }
+ }
+ /**
+ * string resourceIds = 2;
+ * @return The bytes for resourceIds.
+ */
+ @Override
+ public com.google.protobuf.ByteString
+ getResourceIdsBytes() {
+ Object ref = resourceIds_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ resourceIds_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ private byte memoizedIsInitialized = -1;
+ @Override
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ @Override
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ if (abstractIdentifyRequest_ != null) {
+ output.writeMessage(1, getAbstractIdentifyRequest());
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(resourceIds_)) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 2, resourceIds_);
+ }
+ unknownFields.writeTo(output);
+ }
+
+ @Override
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (abstractIdentifyRequest_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(1, getAbstractIdentifyRequest());
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(resourceIds_)) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, resourceIds_);
+ }
+ size += unknownFields.getSerializedSize();
+ memoizedSize = size;
+ return size;
+ }
+
+ @Override
+ public boolean equals(final Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof RegisterRMRequestProto)) {
+ return super.equals(obj);
+ }
+ RegisterRMRequestProto other = (RegisterRMRequestProto) obj;
+
+ if (hasAbstractIdentifyRequest() != other.hasAbstractIdentifyRequest()) return false;
+ if (hasAbstractIdentifyRequest()) {
+ if (!getAbstractIdentifyRequest()
+ .equals(other.getAbstractIdentifyRequest())) return false;
+ }
+ if (!getResourceIds()
+ .equals(other.getResourceIds())) return false;
+ if (!unknownFields.equals(other.unknownFields)) return false;
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptor().hashCode();
+ if (hasAbstractIdentifyRequest()) {
+ hash = (37 * hash) + ABSTRACTIDENTIFYREQUEST_FIELD_NUMBER;
+ hash = (53 * hash) + getAbstractIdentifyRequest().hashCode();
+ }
+ hash = (37 * hash) + RESOURCEIDS_FIELD_NUMBER;
+ hash = (53 * hash) + getResourceIds().hashCode();
+ hash = (29 * hash) + unknownFields.hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static RegisterRMRequestProto parseFrom(
+ java.nio.ByteBuffer data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static RegisterRMRequestProto parseFrom(
+ java.nio.ByteBuffer data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static RegisterRMRequestProto parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static RegisterRMRequestProto parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static RegisterRMRequestProto parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static RegisterRMRequestProto parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static RegisterRMRequestProto parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static RegisterRMRequestProto parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static RegisterRMRequestProto parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input);
+ }
+ public static RegisterRMRequestProto parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static RegisterRMRequestProto parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static RegisterRMRequestProto parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ @Override
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(RegisterRMRequestProto prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ @Override
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @Override
+ protected Builder newBuilderForType(
+ BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ *
+ * PublishRequest is a publish request.
+ *
+ *
+ * Protobuf type {@code org.apache.seata.protocol.protobuf.RegisterRMRequestProto}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessageV3.Builder implements
+ // @@protoc_insertion_point(builder_implements:org.apache.seata.protocol.protobuf.RegisterRMRequestProto)
+ RegisterRMRequestProtoOrBuilder {
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return RegisterRMRequest.internal_static_org_apache_seata_protocol_protobuf_RegisterRMRequestProto_descriptor;
+ }
+
+ @Override
+ protected FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return RegisterRMRequest.internal_static_org_apache_seata_protocol_protobuf_RegisterRMRequestProto_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ RegisterRMRequestProto.class, Builder.class);
+ }
+
+ // Construct using org.apache.seata.core.serializer.protobuf.generated.RegisterRMRequestProto.newBuilder()
+ private Builder() {
+ maybeForceBuilderInitialization();
+ }
+
+ private Builder(
+ BuilderParent parent) {
+ super(parent);
+ maybeForceBuilderInitialization();
+ }
+ private void maybeForceBuilderInitialization() {
+ if (com.google.protobuf.GeneratedMessageV3
+ .alwaysUseFieldBuilders) {
+ }
+ }
+ @Override
+ public Builder clear() {
+ super.clear();
+ if (abstractIdentifyRequestBuilder_ == null) {
+ abstractIdentifyRequest_ = null;
+ } else {
+ abstractIdentifyRequest_ = null;
+ abstractIdentifyRequestBuilder_ = null;
+ }
+ resourceIds_ = "";
+
+ return this;
+ }
+
+ @Override
+ public com.google.protobuf.Descriptors.Descriptor
+ getDescriptorForType() {
+ return RegisterRMRequest.internal_static_org_apache_seata_protocol_protobuf_RegisterRMRequestProto_descriptor;
+ }
+
+ @Override
+ public RegisterRMRequestProto getDefaultInstanceForType() {
+ return RegisterRMRequestProto.getDefaultInstance();
+ }
+
+ @Override
+ public RegisterRMRequestProto build() {
+ RegisterRMRequestProto result = buildPartial();
+ if (!result.isInitialized()) {
+ throw newUninitializedMessageException(result);
+ }
+ return result;
+ }
+
+ @Override
+ public RegisterRMRequestProto buildPartial() {
+ RegisterRMRequestProto result = new RegisterRMRequestProto(this);
+ if (abstractIdentifyRequestBuilder_ == null) {
+ result.abstractIdentifyRequest_ = abstractIdentifyRequest_;
+ } else {
+ result.abstractIdentifyRequest_ = abstractIdentifyRequestBuilder_.build();
+ }
+ result.resourceIds_ = resourceIds_;
+ onBuilt();
+ return result;
+ }
+
+ @Override
+ public Builder clone() {
+ return super.clone();
+ }
+ @Override
+ public Builder setField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ Object value) {
+ return super.setField(field, value);
+ }
+ @Override
+ public Builder clearField(
+ com.google.protobuf.Descriptors.FieldDescriptor field) {
+ return super.clearField(field);
+ }
+ @Override
+ public Builder clearOneof(
+ com.google.protobuf.Descriptors.OneofDescriptor oneof) {
+ return super.clearOneof(oneof);
+ }
+ @Override
+ public Builder setRepeatedField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ int index, Object value) {
+ return super.setRepeatedField(field, index, value);
+ }
+ @Override
+ public Builder addRepeatedField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ Object value) {
+ return super.addRepeatedField(field, value);
+ }
+ @Override
+ public Builder mergeFrom(com.google.protobuf.Message other) {
+ if (other instanceof RegisterRMRequestProto) {
+ return mergeFrom((RegisterRMRequestProto)other);
+ } else {
+ super.mergeFrom(other);
+ return this;
+ }
+ }
+
+ public Builder mergeFrom(RegisterRMRequestProto other) {
+ if (other == RegisterRMRequestProto.getDefaultInstance()) return this;
+ if (other.hasAbstractIdentifyRequest()) {
+ mergeAbstractIdentifyRequest(other.getAbstractIdentifyRequest());
+ }
+ if (!other.getResourceIds().isEmpty()) {
+ resourceIds_ = other.resourceIds_;
+ onChanged();
+ }
+ this.mergeUnknownFields(other.unknownFields);
+ onChanged();
+ return this;
+ }
+
+ @Override
+ public final boolean isInitialized() {
+ return true;
+ }
+
+ @Override
+ public Builder mergeFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ RegisterRMRequestProto parsedMessage = null;
+ try {
+ parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ parsedMessage = (RegisterRMRequestProto) e.getUnfinishedMessage();
+ throw e.unwrapIOException();
+ } finally {
+ if (parsedMessage != null) {
+ mergeFrom(parsedMessage);
+ }
+ }
+ return this;
+ }
+
+ private AbstractIdentifyRequestProto abstractIdentifyRequest_;
+ private com.google.protobuf.SingleFieldBuilderV3<
+ AbstractIdentifyRequestProto, AbstractIdentifyRequestProto.Builder, AbstractIdentifyRequestProtoOrBuilder> abstractIdentifyRequestBuilder_;
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ * @return Whether the abstractIdentifyRequest field is set.
+ */
+ public boolean hasAbstractIdentifyRequest() {
+ return abstractIdentifyRequestBuilder_ != null || abstractIdentifyRequest_ != null;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ * @return The abstractIdentifyRequest.
+ */
+ public AbstractIdentifyRequestProto getAbstractIdentifyRequest() {
+ if (abstractIdentifyRequestBuilder_ == null) {
+ return abstractIdentifyRequest_ == null ? AbstractIdentifyRequestProto.getDefaultInstance() : abstractIdentifyRequest_;
+ } else {
+ return abstractIdentifyRequestBuilder_.getMessage();
+ }
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ public Builder setAbstractIdentifyRequest(AbstractIdentifyRequestProto value) {
+ if (abstractIdentifyRequestBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ abstractIdentifyRequest_ = value;
+ onChanged();
+ } else {
+ abstractIdentifyRequestBuilder_.setMessage(value);
+ }
+
+ return this;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ public Builder setAbstractIdentifyRequest(
+ AbstractIdentifyRequestProto.Builder builderForValue) {
+ if (abstractIdentifyRequestBuilder_ == null) {
+ abstractIdentifyRequest_ = builderForValue.build();
+ onChanged();
+ } else {
+ abstractIdentifyRequestBuilder_.setMessage(builderForValue.build());
+ }
+
+ return this;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ public Builder mergeAbstractIdentifyRequest(AbstractIdentifyRequestProto value) {
+ if (abstractIdentifyRequestBuilder_ == null) {
+ if (abstractIdentifyRequest_ != null) {
+ abstractIdentifyRequest_ =
+ AbstractIdentifyRequestProto.newBuilder(abstractIdentifyRequest_).mergeFrom(value).buildPartial();
+ } else {
+ abstractIdentifyRequest_ = value;
+ }
+ onChanged();
+ } else {
+ abstractIdentifyRequestBuilder_.mergeFrom(value);
+ }
+
+ return this;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ public Builder clearAbstractIdentifyRequest() {
+ if (abstractIdentifyRequestBuilder_ == null) {
+ abstractIdentifyRequest_ = null;
+ onChanged();
+ } else {
+ abstractIdentifyRequest_ = null;
+ abstractIdentifyRequestBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ public AbstractIdentifyRequestProto.Builder getAbstractIdentifyRequestBuilder() {
+
+ onChanged();
+ return getAbstractIdentifyRequestFieldBuilder().getBuilder();
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ public AbstractIdentifyRequestProtoOrBuilder getAbstractIdentifyRequestOrBuilder() {
+ if (abstractIdentifyRequestBuilder_ != null) {
+ return abstractIdentifyRequestBuilder_.getMessageOrBuilder();
+ } else {
+ return abstractIdentifyRequest_ == null ?
+ AbstractIdentifyRequestProto.getDefaultInstance() : abstractIdentifyRequest_;
+ }
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ private com.google.protobuf.SingleFieldBuilderV3<
+ AbstractIdentifyRequestProto, AbstractIdentifyRequestProto.Builder, AbstractIdentifyRequestProtoOrBuilder>
+ getAbstractIdentifyRequestFieldBuilder() {
+ if (abstractIdentifyRequestBuilder_ == null) {
+ abstractIdentifyRequestBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
+ AbstractIdentifyRequestProto, AbstractIdentifyRequestProto.Builder, AbstractIdentifyRequestProtoOrBuilder>(
+ getAbstractIdentifyRequest(),
+ getParentForChildren(),
+ isClean());
+ abstractIdentifyRequest_ = null;
+ }
+ return abstractIdentifyRequestBuilder_;
+ }
+
+ private Object resourceIds_ = "";
+ /**
+ * string resourceIds = 2;
+ * @return The resourceIds.
+ */
+ public String getResourceIds() {
+ Object ref = resourceIds_;
+ if (!(ref instanceof String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ resourceIds_ = s;
+ return s;
+ } else {
+ return (String) ref;
+ }
+ }
+ /**
+ * string resourceIds = 2;
+ * @return The bytes for resourceIds.
+ */
+ public com.google.protobuf.ByteString
+ getResourceIdsBytes() {
+ Object ref = resourceIds_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ resourceIds_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * string resourceIds = 2;
+ * @param value The resourceIds to set.
+ * @return This builder for chaining.
+ */
+ public Builder setResourceIds(
+ String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ resourceIds_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * string resourceIds = 2;
+ * @return This builder for chaining.
+ */
+ public Builder clearResourceIds() {
+
+ resourceIds_ = getDefaultInstance().getResourceIds();
+ onChanged();
+ return this;
+ }
+ /**
+ * string resourceIds = 2;
+ * @param value The bytes for resourceIds to set.
+ * @return This builder for chaining.
+ */
+ public Builder setResourceIdsBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ resourceIds_ = value;
+ onChanged();
+ return this;
+ }
+ @Override
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.setUnknownFields(unknownFields);
+ }
+
+ @Override
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.mergeUnknownFields(unknownFields);
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:org.apache.seata.protocol.protobuf.RegisterRMRequestProto)
+ }
+
+ // @@protoc_insertion_point(class_scope:org.apache.seata.protocol.protobuf.RegisterRMRequestProto)
+ private static final RegisterRMRequestProto DEFAULT_INSTANCE;
+ static {
+ DEFAULT_INSTANCE = new RegisterRMRequestProto();
+ }
+
+ public static RegisterRMRequestProto getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parser
+ PARSER = new com.google.protobuf.AbstractParser() {
+ @Override
+ public RegisterRMRequestProto parsePartialFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return new RegisterRMRequestProto(input, extensionRegistry);
+ }
+ };
+
+ public static com.google.protobuf.Parser parser() {
+ return PARSER;
+ }
+
+ @Override
+ public com.google.protobuf.Parser getParserForType() {
+ return PARSER;
+ }
+
+ @Override
+ public RegisterRMRequestProto getDefaultInstanceForType() {
+ return DEFAULT_INSTANCE;
+ }
+
+}
+
diff --git a/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMRequestProtoOrBuilder.java b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMRequestProtoOrBuilder.java
new file mode 100644
index 00000000000..087969c347a
--- /dev/null
+++ b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMRequestProtoOrBuilder.java
@@ -0,0 +1,36 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: registerRMRequest.proto
+
+package org.apache.seata.core.serializer.protobuf.generated;
+
+public interface RegisterRMRequestProtoOrBuilder extends
+ // @@protoc_insertion_point(interface_extends:org.apache.seata.protocol.protobuf.RegisterRMRequestProto)
+ com.google.protobuf.MessageOrBuilder {
+
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ * @return Whether the abstractIdentifyRequest field is set.
+ */
+ boolean hasAbstractIdentifyRequest();
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ * @return The abstractIdentifyRequest.
+ */
+ AbstractIdentifyRequestProto getAbstractIdentifyRequest();
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ AbstractIdentifyRequestProtoOrBuilder getAbstractIdentifyRequestOrBuilder();
+
+ /**
+ * string resourceIds = 2;
+ * @return The resourceIds.
+ */
+ String getResourceIds();
+ /**
+ * string resourceIds = 2;
+ * @return The bytes for resourceIds.
+ */
+ com.google.protobuf.ByteString
+ getResourceIdsBytes();
+}
diff --git a/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMResponse.java b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMResponse.java
new file mode 100644
index 00000000000..f05fef75ab9
--- /dev/null
+++ b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMResponse.java
@@ -0,0 +1,55 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: registerRMResponse.proto
+
+package org.apache.seata.core.serializer.protobuf.generated;
+
+public final class RegisterRMResponse {
+ private RegisterRMResponse() {}
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistryLite registry) {
+ }
+
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistry registry) {
+ registerAllExtensions(
+ (com.google.protobuf.ExtensionRegistryLite) registry);
+ }
+ static final com.google.protobuf.Descriptors.Descriptor
+ internal_static_org_apache_seata_protocol_protobuf_RegisterRMResponseProto_descriptor;
+ static final
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internal_static_org_apache_seata_protocol_protobuf_RegisterRMResponseProto_fieldAccessorTable;
+
+ public static com.google.protobuf.Descriptors.FileDescriptor
+ getDescriptor() {
+ return descriptor;
+ }
+ private static com.google.protobuf.Descriptors.FileDescriptor
+ descriptor;
+ static {
+ String[] descriptorData = {
+ "\n\030registerRMResponse.proto\022\"org.apache.s" +
+ "eata.protocol.protobuf\032\036abstractIdentify" +
+ "Response.proto\"~\n\027RegisterRMResponseProt" +
+ "o\022c\n\030abstractIdentifyResponse\030\001 \001(\0132A.or" +
+ "g.apache.seata.protocol.protobuf.Abstrac" +
+ "tIdentifyResponseProtoBK\n3org.apache.sea" +
+ "ta.core.serializer.protobuf.generatedB\022R" +
+ "egisterRMResponseP\001b\006proto3"
+ };
+ descriptor = com.google.protobuf.Descriptors.FileDescriptor
+ .internalBuildGeneratedFileFrom(descriptorData,
+ new com.google.protobuf.Descriptors.FileDescriptor[] {
+ AbstractIdentifyResponse.getDescriptor(),
+ });
+ internal_static_org_apache_seata_protocol_protobuf_RegisterRMResponseProto_descriptor =
+ getDescriptor().getMessageTypes().get(0);
+ internal_static_org_apache_seata_protocol_protobuf_RegisterRMResponseProto_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+ internal_static_org_apache_seata_protocol_protobuf_RegisterRMResponseProto_descriptor,
+ new String[] { "AbstractIdentifyResponse", });
+ AbstractIdentifyResponse.getDescriptor();
+ }
+
+ // @@protoc_insertion_point(outer_class_scope)
+}
diff --git a/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMResponseProto.java b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMResponseProto.java
new file mode 100644
index 00000000000..1d1be68a69d
--- /dev/null
+++ b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMResponseProto.java
@@ -0,0 +1,617 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: registerRMResponse.proto
+
+package org.apache.seata.core.serializer.protobuf.generated;
+
+/**
+ *
+ * PublishRequest is a publish request.
+ *
+ *
+ * Protobuf type {@code org.apache.seata.protocol.protobuf.RegisterRMResponseProto}
+ */
+public final class RegisterRMResponseProto extends
+ com.google.protobuf.GeneratedMessageV3 implements
+ // @@protoc_insertion_point(message_implements:org.apache.seata.protocol.protobuf.RegisterRMResponseProto)
+ RegisterRMResponseProtoOrBuilder {
+private static final long serialVersionUID = 0L;
+ // Use RegisterRMResponseProto.newBuilder() to construct.
+ private RegisterRMResponseProto(com.google.protobuf.GeneratedMessageV3.Builder builder) {
+ super(builder);
+ }
+ private RegisterRMResponseProto() {
+ }
+
+ @Override
+ @SuppressWarnings({"unused"})
+ protected Object newInstance(
+ UnusedPrivateParameter unused) {
+ return new RegisterRMResponseProto();
+ }
+
+ @Override
+ public final com.google.protobuf.UnknownFieldSet
+ getUnknownFields() {
+ return this.unknownFields;
+ }
+ private RegisterRMResponseProto(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ this();
+ if (extensionRegistry == null) {
+ throw new NullPointerException();
+ }
+ com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+ com.google.protobuf.UnknownFieldSet.newBuilder();
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ case 10: {
+ AbstractIdentifyResponseProto.Builder subBuilder = null;
+ if (abstractIdentifyResponse_ != null) {
+ subBuilder = abstractIdentifyResponse_.toBuilder();
+ }
+ abstractIdentifyResponse_ = input.readMessage(AbstractIdentifyResponseProto.parser(), extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(abstractIdentifyResponse_);
+ abstractIdentifyResponse_ = subBuilder.buildPartial();
+ }
+
+ break;
+ }
+ default: {
+ if (!parseUnknownField(
+ input, unknownFields, extensionRegistry, tag)) {
+ done = true;
+ }
+ break;
+ }
+ }
+ }
+ } 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);
+ } finally {
+ this.unknownFields = unknownFields.build();
+ makeExtensionsImmutable();
+ }
+ }
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return RegisterRMResponse.internal_static_org_apache_seata_protocol_protobuf_RegisterRMResponseProto_descriptor;
+ }
+
+ @Override
+ protected FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return RegisterRMResponse.internal_static_org_apache_seata_protocol_protobuf_RegisterRMResponseProto_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ RegisterRMResponseProto.class, Builder.class);
+ }
+
+ public static final int ABSTRACTIDENTIFYRESPONSE_FIELD_NUMBER = 1;
+ private AbstractIdentifyResponseProto abstractIdentifyResponse_;
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyResponseProto abstractIdentifyResponse = 1;
+ * @return Whether the abstractIdentifyResponse field is set.
+ */
+ @Override
+ public boolean hasAbstractIdentifyResponse() {
+ return abstractIdentifyResponse_ != null;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyResponseProto abstractIdentifyResponse = 1;
+ * @return The abstractIdentifyResponse.
+ */
+ @Override
+ public AbstractIdentifyResponseProto getAbstractIdentifyResponse() {
+ return abstractIdentifyResponse_ == null ? AbstractIdentifyResponseProto.getDefaultInstance() : abstractIdentifyResponse_;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyResponseProto abstractIdentifyResponse = 1;
+ */
+ @Override
+ public AbstractIdentifyResponseProtoOrBuilder getAbstractIdentifyResponseOrBuilder() {
+ return getAbstractIdentifyResponse();
+ }
+
+ private byte memoizedIsInitialized = -1;
+ @Override
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ @Override
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ if (abstractIdentifyResponse_ != null) {
+ output.writeMessage(1, getAbstractIdentifyResponse());
+ }
+ unknownFields.writeTo(output);
+ }
+
+ @Override
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (abstractIdentifyResponse_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(1, getAbstractIdentifyResponse());
+ }
+ size += unknownFields.getSerializedSize();
+ memoizedSize = size;
+ return size;
+ }
+
+ @Override
+ public boolean equals(final Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof RegisterRMResponseProto)) {
+ return super.equals(obj);
+ }
+ RegisterRMResponseProto other = (RegisterRMResponseProto) obj;
+
+ if (hasAbstractIdentifyResponse() != other.hasAbstractIdentifyResponse()) return false;
+ if (hasAbstractIdentifyResponse()) {
+ if (!getAbstractIdentifyResponse()
+ .equals(other.getAbstractIdentifyResponse())) return false;
+ }
+ if (!unknownFields.equals(other.unknownFields)) return false;
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptor().hashCode();
+ if (hasAbstractIdentifyResponse()) {
+ hash = (37 * hash) + ABSTRACTIDENTIFYRESPONSE_FIELD_NUMBER;
+ hash = (53 * hash) + getAbstractIdentifyResponse().hashCode();
+ }
+ hash = (29 * hash) + unknownFields.hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static RegisterRMResponseProto parseFrom(
+ java.nio.ByteBuffer data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static RegisterRMResponseProto parseFrom(
+ java.nio.ByteBuffer data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static RegisterRMResponseProto parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static RegisterRMResponseProto parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static RegisterRMResponseProto parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static RegisterRMResponseProto parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static RegisterRMResponseProto parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static RegisterRMResponseProto parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static RegisterRMResponseProto parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input);
+ }
+ public static RegisterRMResponseProto parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static RegisterRMResponseProto parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static RegisterRMResponseProto parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ @Override
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(RegisterRMResponseProto prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ @Override
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @Override
+ protected Builder newBuilderForType(
+ BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ *
+ * PublishRequest is a publish request.
+ *
+ *
+ * Protobuf type {@code org.apache.seata.protocol.protobuf.RegisterRMResponseProto}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessageV3.Builder implements
+ // @@protoc_insertion_point(builder_implements:org.apache.seata.protocol.protobuf.RegisterRMResponseProto)
+ RegisterRMResponseProtoOrBuilder {
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return RegisterRMResponse.internal_static_org_apache_seata_protocol_protobuf_RegisterRMResponseProto_descriptor;
+ }
+
+ @Override
+ protected FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return RegisterRMResponse.internal_static_org_apache_seata_protocol_protobuf_RegisterRMResponseProto_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ RegisterRMResponseProto.class, Builder.class);
+ }
+
+ // Construct using org.apache.seata.core.serializer.protobuf.generated.RegisterRMResponseProto.newBuilder()
+ private Builder() {
+ maybeForceBuilderInitialization();
+ }
+
+ private Builder(
+ BuilderParent parent) {
+ super(parent);
+ maybeForceBuilderInitialization();
+ }
+ private void maybeForceBuilderInitialization() {
+ if (com.google.protobuf.GeneratedMessageV3
+ .alwaysUseFieldBuilders) {
+ }
+ }
+ @Override
+ public Builder clear() {
+ super.clear();
+ if (abstractIdentifyResponseBuilder_ == null) {
+ abstractIdentifyResponse_ = null;
+ } else {
+ abstractIdentifyResponse_ = null;
+ abstractIdentifyResponseBuilder_ = null;
+ }
+ return this;
+ }
+
+ @Override
+ public com.google.protobuf.Descriptors.Descriptor
+ getDescriptorForType() {
+ return RegisterRMResponse.internal_static_org_apache_seata_protocol_protobuf_RegisterRMResponseProto_descriptor;
+ }
+
+ @Override
+ public RegisterRMResponseProto getDefaultInstanceForType() {
+ return RegisterRMResponseProto.getDefaultInstance();
+ }
+
+ @Override
+ public RegisterRMResponseProto build() {
+ RegisterRMResponseProto result = buildPartial();
+ if (!result.isInitialized()) {
+ throw newUninitializedMessageException(result);
+ }
+ return result;
+ }
+
+ @Override
+ public RegisterRMResponseProto buildPartial() {
+ RegisterRMResponseProto result = new RegisterRMResponseProto(this);
+ if (abstractIdentifyResponseBuilder_ == null) {
+ result.abstractIdentifyResponse_ = abstractIdentifyResponse_;
+ } else {
+ result.abstractIdentifyResponse_ = abstractIdentifyResponseBuilder_.build();
+ }
+ onBuilt();
+ return result;
+ }
+
+ @Override
+ public Builder clone() {
+ return super.clone();
+ }
+ @Override
+ public Builder setField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ Object value) {
+ return super.setField(field, value);
+ }
+ @Override
+ public Builder clearField(
+ com.google.protobuf.Descriptors.FieldDescriptor field) {
+ return super.clearField(field);
+ }
+ @Override
+ public Builder clearOneof(
+ com.google.protobuf.Descriptors.OneofDescriptor oneof) {
+ return super.clearOneof(oneof);
+ }
+ @Override
+ public Builder setRepeatedField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ int index, Object value) {
+ return super.setRepeatedField(field, index, value);
+ }
+ @Override
+ public Builder addRepeatedField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ Object value) {
+ return super.addRepeatedField(field, value);
+ }
+ @Override
+ public Builder mergeFrom(com.google.protobuf.Message other) {
+ if (other instanceof RegisterRMResponseProto) {
+ return mergeFrom((RegisterRMResponseProto)other);
+ } else {
+ super.mergeFrom(other);
+ return this;
+ }
+ }
+
+ public Builder mergeFrom(RegisterRMResponseProto other) {
+ if (other == RegisterRMResponseProto.getDefaultInstance()) return this;
+ if (other.hasAbstractIdentifyResponse()) {
+ mergeAbstractIdentifyResponse(other.getAbstractIdentifyResponse());
+ }
+ this.mergeUnknownFields(other.unknownFields);
+ onChanged();
+ return this;
+ }
+
+ @Override
+ public final boolean isInitialized() {
+ return true;
+ }
+
+ @Override
+ public Builder mergeFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ RegisterRMResponseProto parsedMessage = null;
+ try {
+ parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ parsedMessage = (RegisterRMResponseProto) e.getUnfinishedMessage();
+ throw e.unwrapIOException();
+ } finally {
+ if (parsedMessage != null) {
+ mergeFrom(parsedMessage);
+ }
+ }
+ return this;
+ }
+
+ private AbstractIdentifyResponseProto abstractIdentifyResponse_;
+ private com.google.protobuf.SingleFieldBuilderV3<
+ AbstractIdentifyResponseProto, AbstractIdentifyResponseProto.Builder, AbstractIdentifyResponseProtoOrBuilder> abstractIdentifyResponseBuilder_;
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyResponseProto abstractIdentifyResponse = 1;
+ * @return Whether the abstractIdentifyResponse field is set.
+ */
+ public boolean hasAbstractIdentifyResponse() {
+ return abstractIdentifyResponseBuilder_ != null || abstractIdentifyResponse_ != null;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyResponseProto abstractIdentifyResponse = 1;
+ * @return The abstractIdentifyResponse.
+ */
+ public AbstractIdentifyResponseProto getAbstractIdentifyResponse() {
+ if (abstractIdentifyResponseBuilder_ == null) {
+ return abstractIdentifyResponse_ == null ? AbstractIdentifyResponseProto.getDefaultInstance() : abstractIdentifyResponse_;
+ } else {
+ return abstractIdentifyResponseBuilder_.getMessage();
+ }
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyResponseProto abstractIdentifyResponse = 1;
+ */
+ public Builder setAbstractIdentifyResponse(AbstractIdentifyResponseProto value) {
+ if (abstractIdentifyResponseBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ abstractIdentifyResponse_ = value;
+ onChanged();
+ } else {
+ abstractIdentifyResponseBuilder_.setMessage(value);
+ }
+
+ return this;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyResponseProto abstractIdentifyResponse = 1;
+ */
+ public Builder setAbstractIdentifyResponse(
+ AbstractIdentifyResponseProto.Builder builderForValue) {
+ if (abstractIdentifyResponseBuilder_ == null) {
+ abstractIdentifyResponse_ = builderForValue.build();
+ onChanged();
+ } else {
+ abstractIdentifyResponseBuilder_.setMessage(builderForValue.build());
+ }
+
+ return this;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyResponseProto abstractIdentifyResponse = 1;
+ */
+ public Builder mergeAbstractIdentifyResponse(AbstractIdentifyResponseProto value) {
+ if (abstractIdentifyResponseBuilder_ == null) {
+ if (abstractIdentifyResponse_ != null) {
+ abstractIdentifyResponse_ =
+ AbstractIdentifyResponseProto.newBuilder(abstractIdentifyResponse_).mergeFrom(value).buildPartial();
+ } else {
+ abstractIdentifyResponse_ = value;
+ }
+ onChanged();
+ } else {
+ abstractIdentifyResponseBuilder_.mergeFrom(value);
+ }
+
+ return this;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyResponseProto abstractIdentifyResponse = 1;
+ */
+ public Builder clearAbstractIdentifyResponse() {
+ if (abstractIdentifyResponseBuilder_ == null) {
+ abstractIdentifyResponse_ = null;
+ onChanged();
+ } else {
+ abstractIdentifyResponse_ = null;
+ abstractIdentifyResponseBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyResponseProto abstractIdentifyResponse = 1;
+ */
+ public AbstractIdentifyResponseProto.Builder getAbstractIdentifyResponseBuilder() {
+
+ onChanged();
+ return getAbstractIdentifyResponseFieldBuilder().getBuilder();
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyResponseProto abstractIdentifyResponse = 1;
+ */
+ public AbstractIdentifyResponseProtoOrBuilder getAbstractIdentifyResponseOrBuilder() {
+ if (abstractIdentifyResponseBuilder_ != null) {
+ return abstractIdentifyResponseBuilder_.getMessageOrBuilder();
+ } else {
+ return abstractIdentifyResponse_ == null ?
+ AbstractIdentifyResponseProto.getDefaultInstance() : abstractIdentifyResponse_;
+ }
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyResponseProto abstractIdentifyResponse = 1;
+ */
+ private com.google.protobuf.SingleFieldBuilderV3<
+ AbstractIdentifyResponseProto, AbstractIdentifyResponseProto.Builder, AbstractIdentifyResponseProtoOrBuilder>
+ getAbstractIdentifyResponseFieldBuilder() {
+ if (abstractIdentifyResponseBuilder_ == null) {
+ abstractIdentifyResponseBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
+ AbstractIdentifyResponseProto, AbstractIdentifyResponseProto.Builder, AbstractIdentifyResponseProtoOrBuilder>(
+ getAbstractIdentifyResponse(),
+ getParentForChildren(),
+ isClean());
+ abstractIdentifyResponse_ = null;
+ }
+ return abstractIdentifyResponseBuilder_;
+ }
+ @Override
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.setUnknownFields(unknownFields);
+ }
+
+ @Override
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.mergeUnknownFields(unknownFields);
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:org.apache.seata.protocol.protobuf.RegisterRMResponseProto)
+ }
+
+ // @@protoc_insertion_point(class_scope:org.apache.seata.protocol.protobuf.RegisterRMResponseProto)
+ private static final RegisterRMResponseProto DEFAULT_INSTANCE;
+ static {
+ DEFAULT_INSTANCE = new RegisterRMResponseProto();
+ }
+
+ public static RegisterRMResponseProto getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parser
+ PARSER = new com.google.protobuf.AbstractParser() {
+ @Override
+ public RegisterRMResponseProto parsePartialFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return new RegisterRMResponseProto(input, extensionRegistry);
+ }
+ };
+
+ public static com.google.protobuf.Parser parser() {
+ return PARSER;
+ }
+
+ @Override
+ public com.google.protobuf.Parser getParserForType() {
+ return PARSER;
+ }
+
+ @Override
+ public RegisterRMResponseProto getDefaultInstanceForType() {
+ return DEFAULT_INSTANCE;
+ }
+
+}
+
diff --git a/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMResponseProtoOrBuilder.java b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMResponseProtoOrBuilder.java
new file mode 100644
index 00000000000..a1c45cc5375
--- /dev/null
+++ b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterRMResponseProtoOrBuilder.java
@@ -0,0 +1,24 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: registerRMResponse.proto
+
+package org.apache.seata.core.serializer.protobuf.generated;
+
+public interface RegisterRMResponseProtoOrBuilder extends
+ // @@protoc_insertion_point(interface_extends:org.apache.seata.protocol.protobuf.RegisterRMResponseProto)
+ com.google.protobuf.MessageOrBuilder {
+
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyResponseProto abstractIdentifyResponse = 1;
+ * @return Whether the abstractIdentifyResponse field is set.
+ */
+ boolean hasAbstractIdentifyResponse();
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyResponseProto abstractIdentifyResponse = 1;
+ * @return The abstractIdentifyResponse.
+ */
+ AbstractIdentifyResponseProto getAbstractIdentifyResponse();
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyResponseProto abstractIdentifyResponse = 1;
+ */
+ AbstractIdentifyResponseProtoOrBuilder getAbstractIdentifyResponseOrBuilder();
+}
diff --git a/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterTMRequest.java b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterTMRequest.java
new file mode 100644
index 00000000000..c7eb423de4b
--- /dev/null
+++ b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterTMRequest.java
@@ -0,0 +1,55 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: registerTMRequest.proto
+
+package org.apache.seata.core.serializer.protobuf.generated;
+
+public final class RegisterTMRequest {
+ private RegisterTMRequest() {}
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistryLite registry) {
+ }
+
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistry registry) {
+ registerAllExtensions(
+ (com.google.protobuf.ExtensionRegistryLite) registry);
+ }
+ static final com.google.protobuf.Descriptors.Descriptor
+ internal_static_org_apache_seata_protocol_protobuf_RegisterTMRequestProto_descriptor;
+ static final
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internal_static_org_apache_seata_protocol_protobuf_RegisterTMRequestProto_fieldAccessorTable;
+
+ public static com.google.protobuf.Descriptors.FileDescriptor
+ getDescriptor() {
+ return descriptor;
+ }
+ private static com.google.protobuf.Descriptors.FileDescriptor
+ descriptor;
+ static {
+ String[] descriptorData = {
+ "\n\027registerTMRequest.proto\022\"org.apache.se" +
+ "ata.protocol.protobuf\032\035abstractIdentifyR" +
+ "equest.proto\"{\n\026RegisterTMRequestProto\022a" +
+ "\n\027abstractIdentifyRequest\030\001 \001(\0132@.org.ap" +
+ "ache.seata.protocol.protobuf.AbstractIde" +
+ "ntifyRequestProtoBJ\n3org.apache.seata.co" +
+ "re.serializer.protobuf.generatedB\021Regist" +
+ "erTMRequestP\001b\006proto3"
+ };
+ descriptor = com.google.protobuf.Descriptors.FileDescriptor
+ .internalBuildGeneratedFileFrom(descriptorData,
+ new com.google.protobuf.Descriptors.FileDescriptor[] {
+ AbstractIdentifyRequest.getDescriptor(),
+ });
+ internal_static_org_apache_seata_protocol_protobuf_RegisterTMRequestProto_descriptor =
+ getDescriptor().getMessageTypes().get(0);
+ internal_static_org_apache_seata_protocol_protobuf_RegisterTMRequestProto_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+ internal_static_org_apache_seata_protocol_protobuf_RegisterTMRequestProto_descriptor,
+ new String[] { "AbstractIdentifyRequest", });
+ AbstractIdentifyRequest.getDescriptor();
+ }
+
+ // @@protoc_insertion_point(outer_class_scope)
+}
diff --git a/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterTMRequestProto.java b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterTMRequestProto.java
new file mode 100644
index 00000000000..a70a66f1e54
--- /dev/null
+++ b/core/src/main/java/org/apache/seata/core/serializer/protobuf/generated/RegisterTMRequestProto.java
@@ -0,0 +1,617 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: registerTMRequest.proto
+
+package org.apache.seata.core.serializer.protobuf.generated;
+
+/**
+ *
+ * PublishRequest is a publish request.
+ *
+ *
+ * Protobuf type {@code org.apache.seata.protocol.protobuf.RegisterTMRequestProto}
+ */
+public final class RegisterTMRequestProto extends
+ com.google.protobuf.GeneratedMessageV3 implements
+ // @@protoc_insertion_point(message_implements:org.apache.seata.protocol.protobuf.RegisterTMRequestProto)
+ RegisterTMRequestProtoOrBuilder {
+private static final long serialVersionUID = 0L;
+ // Use RegisterTMRequestProto.newBuilder() to construct.
+ private RegisterTMRequestProto(com.google.protobuf.GeneratedMessageV3.Builder builder) {
+ super(builder);
+ }
+ private RegisterTMRequestProto() {
+ }
+
+ @Override
+ @SuppressWarnings({"unused"})
+ protected Object newInstance(
+ UnusedPrivateParameter unused) {
+ return new RegisterTMRequestProto();
+ }
+
+ @Override
+ public final com.google.protobuf.UnknownFieldSet
+ getUnknownFields() {
+ return this.unknownFields;
+ }
+ private RegisterTMRequestProto(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ this();
+ if (extensionRegistry == null) {
+ throw new NullPointerException();
+ }
+ com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+ com.google.protobuf.UnknownFieldSet.newBuilder();
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ case 10: {
+ AbstractIdentifyRequestProto.Builder subBuilder = null;
+ if (abstractIdentifyRequest_ != null) {
+ subBuilder = abstractIdentifyRequest_.toBuilder();
+ }
+ abstractIdentifyRequest_ = input.readMessage(AbstractIdentifyRequestProto.parser(), extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(abstractIdentifyRequest_);
+ abstractIdentifyRequest_ = subBuilder.buildPartial();
+ }
+
+ break;
+ }
+ default: {
+ if (!parseUnknownField(
+ input, unknownFields, extensionRegistry, tag)) {
+ done = true;
+ }
+ break;
+ }
+ }
+ }
+ } 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);
+ } finally {
+ this.unknownFields = unknownFields.build();
+ makeExtensionsImmutable();
+ }
+ }
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return RegisterTMRequest.internal_static_org_apache_seata_protocol_protobuf_RegisterTMRequestProto_descriptor;
+ }
+
+ @Override
+ protected FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return RegisterTMRequest.internal_static_org_apache_seata_protocol_protobuf_RegisterTMRequestProto_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ RegisterTMRequestProto.class, Builder.class);
+ }
+
+ public static final int ABSTRACTIDENTIFYREQUEST_FIELD_NUMBER = 1;
+ private AbstractIdentifyRequestProto abstractIdentifyRequest_;
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ * @return Whether the abstractIdentifyRequest field is set.
+ */
+ @Override
+ public boolean hasAbstractIdentifyRequest() {
+ return abstractIdentifyRequest_ != null;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ * @return The abstractIdentifyRequest.
+ */
+ @Override
+ public AbstractIdentifyRequestProto getAbstractIdentifyRequest() {
+ return abstractIdentifyRequest_ == null ? AbstractIdentifyRequestProto.getDefaultInstance() : abstractIdentifyRequest_;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ @Override
+ public AbstractIdentifyRequestProtoOrBuilder getAbstractIdentifyRequestOrBuilder() {
+ return getAbstractIdentifyRequest();
+ }
+
+ private byte memoizedIsInitialized = -1;
+ @Override
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ @Override
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ if (abstractIdentifyRequest_ != null) {
+ output.writeMessage(1, getAbstractIdentifyRequest());
+ }
+ unknownFields.writeTo(output);
+ }
+
+ @Override
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (abstractIdentifyRequest_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(1, getAbstractIdentifyRequest());
+ }
+ size += unknownFields.getSerializedSize();
+ memoizedSize = size;
+ return size;
+ }
+
+ @Override
+ public boolean equals(final Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof RegisterTMRequestProto)) {
+ return super.equals(obj);
+ }
+ RegisterTMRequestProto other = (RegisterTMRequestProto) obj;
+
+ if (hasAbstractIdentifyRequest() != other.hasAbstractIdentifyRequest()) return false;
+ if (hasAbstractIdentifyRequest()) {
+ if (!getAbstractIdentifyRequest()
+ .equals(other.getAbstractIdentifyRequest())) return false;
+ }
+ if (!unknownFields.equals(other.unknownFields)) return false;
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptor().hashCode();
+ if (hasAbstractIdentifyRequest()) {
+ hash = (37 * hash) + ABSTRACTIDENTIFYREQUEST_FIELD_NUMBER;
+ hash = (53 * hash) + getAbstractIdentifyRequest().hashCode();
+ }
+ hash = (29 * hash) + unknownFields.hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static RegisterTMRequestProto parseFrom(
+ java.nio.ByteBuffer data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static RegisterTMRequestProto parseFrom(
+ java.nio.ByteBuffer data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static RegisterTMRequestProto parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static RegisterTMRequestProto parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static RegisterTMRequestProto parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static RegisterTMRequestProto parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static RegisterTMRequestProto parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static RegisterTMRequestProto parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static RegisterTMRequestProto parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input);
+ }
+ public static RegisterTMRequestProto parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static RegisterTMRequestProto parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static RegisterTMRequestProto parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ @Override
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(RegisterTMRequestProto prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ @Override
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @Override
+ protected Builder newBuilderForType(
+ BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ *
+ * PublishRequest is a publish request.
+ *
+ *
+ * Protobuf type {@code org.apache.seata.protocol.protobuf.RegisterTMRequestProto}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessageV3.Builder implements
+ // @@protoc_insertion_point(builder_implements:org.apache.seata.protocol.protobuf.RegisterTMRequestProto)
+ RegisterTMRequestProtoOrBuilder {
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return RegisterTMRequest.internal_static_org_apache_seata_protocol_protobuf_RegisterTMRequestProto_descriptor;
+ }
+
+ @Override
+ protected FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return RegisterTMRequest.internal_static_org_apache_seata_protocol_protobuf_RegisterTMRequestProto_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ RegisterTMRequestProto.class, Builder.class);
+ }
+
+ // Construct using org.apache.seata.core.serializer.protobuf.generated.RegisterTMRequestProto.newBuilder()
+ private Builder() {
+ maybeForceBuilderInitialization();
+ }
+
+ private Builder(
+ BuilderParent parent) {
+ super(parent);
+ maybeForceBuilderInitialization();
+ }
+ private void maybeForceBuilderInitialization() {
+ if (com.google.protobuf.GeneratedMessageV3
+ .alwaysUseFieldBuilders) {
+ }
+ }
+ @Override
+ public Builder clear() {
+ super.clear();
+ if (abstractIdentifyRequestBuilder_ == null) {
+ abstractIdentifyRequest_ = null;
+ } else {
+ abstractIdentifyRequest_ = null;
+ abstractIdentifyRequestBuilder_ = null;
+ }
+ return this;
+ }
+
+ @Override
+ public com.google.protobuf.Descriptors.Descriptor
+ getDescriptorForType() {
+ return RegisterTMRequest.internal_static_org_apache_seata_protocol_protobuf_RegisterTMRequestProto_descriptor;
+ }
+
+ @Override
+ public RegisterTMRequestProto getDefaultInstanceForType() {
+ return RegisterTMRequestProto.getDefaultInstance();
+ }
+
+ @Override
+ public RegisterTMRequestProto build() {
+ RegisterTMRequestProto result = buildPartial();
+ if (!result.isInitialized()) {
+ throw newUninitializedMessageException(result);
+ }
+ return result;
+ }
+
+ @Override
+ public RegisterTMRequestProto buildPartial() {
+ RegisterTMRequestProto result = new RegisterTMRequestProto(this);
+ if (abstractIdentifyRequestBuilder_ == null) {
+ result.abstractIdentifyRequest_ = abstractIdentifyRequest_;
+ } else {
+ result.abstractIdentifyRequest_ = abstractIdentifyRequestBuilder_.build();
+ }
+ onBuilt();
+ return result;
+ }
+
+ @Override
+ public Builder clone() {
+ return super.clone();
+ }
+ @Override
+ public Builder setField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ Object value) {
+ return super.setField(field, value);
+ }
+ @Override
+ public Builder clearField(
+ com.google.protobuf.Descriptors.FieldDescriptor field) {
+ return super.clearField(field);
+ }
+ @Override
+ public Builder clearOneof(
+ com.google.protobuf.Descriptors.OneofDescriptor oneof) {
+ return super.clearOneof(oneof);
+ }
+ @Override
+ public Builder setRepeatedField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ int index, Object value) {
+ return super.setRepeatedField(field, index, value);
+ }
+ @Override
+ public Builder addRepeatedField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ Object value) {
+ return super.addRepeatedField(field, value);
+ }
+ @Override
+ public Builder mergeFrom(com.google.protobuf.Message other) {
+ if (other instanceof RegisterTMRequestProto) {
+ return mergeFrom((RegisterTMRequestProto)other);
+ } else {
+ super.mergeFrom(other);
+ return this;
+ }
+ }
+
+ public Builder mergeFrom(RegisterTMRequestProto other) {
+ if (other == RegisterTMRequestProto.getDefaultInstance()) return this;
+ if (other.hasAbstractIdentifyRequest()) {
+ mergeAbstractIdentifyRequest(other.getAbstractIdentifyRequest());
+ }
+ this.mergeUnknownFields(other.unknownFields);
+ onChanged();
+ return this;
+ }
+
+ @Override
+ public final boolean isInitialized() {
+ return true;
+ }
+
+ @Override
+ public Builder mergeFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ RegisterTMRequestProto parsedMessage = null;
+ try {
+ parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ parsedMessage = (RegisterTMRequestProto) e.getUnfinishedMessage();
+ throw e.unwrapIOException();
+ } finally {
+ if (parsedMessage != null) {
+ mergeFrom(parsedMessage);
+ }
+ }
+ return this;
+ }
+
+ private AbstractIdentifyRequestProto abstractIdentifyRequest_;
+ private com.google.protobuf.SingleFieldBuilderV3<
+ AbstractIdentifyRequestProto, AbstractIdentifyRequestProto.Builder, AbstractIdentifyRequestProtoOrBuilder> abstractIdentifyRequestBuilder_;
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ * @return Whether the abstractIdentifyRequest field is set.
+ */
+ public boolean hasAbstractIdentifyRequest() {
+ return abstractIdentifyRequestBuilder_ != null || abstractIdentifyRequest_ != null;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ * @return The abstractIdentifyRequest.
+ */
+ public AbstractIdentifyRequestProto getAbstractIdentifyRequest() {
+ if (abstractIdentifyRequestBuilder_ == null) {
+ return abstractIdentifyRequest_ == null ? AbstractIdentifyRequestProto.getDefaultInstance() : abstractIdentifyRequest_;
+ } else {
+ return abstractIdentifyRequestBuilder_.getMessage();
+ }
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ public Builder setAbstractIdentifyRequest(AbstractIdentifyRequestProto value) {
+ if (abstractIdentifyRequestBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ abstractIdentifyRequest_ = value;
+ onChanged();
+ } else {
+ abstractIdentifyRequestBuilder_.setMessage(value);
+ }
+
+ return this;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ public Builder setAbstractIdentifyRequest(
+ AbstractIdentifyRequestProto.Builder builderForValue) {
+ if (abstractIdentifyRequestBuilder_ == null) {
+ abstractIdentifyRequest_ = builderForValue.build();
+ onChanged();
+ } else {
+ abstractIdentifyRequestBuilder_.setMessage(builderForValue.build());
+ }
+
+ return this;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ public Builder mergeAbstractIdentifyRequest(AbstractIdentifyRequestProto value) {
+ if (abstractIdentifyRequestBuilder_ == null) {
+ if (abstractIdentifyRequest_ != null) {
+ abstractIdentifyRequest_ =
+ AbstractIdentifyRequestProto.newBuilder(abstractIdentifyRequest_).mergeFrom(value).buildPartial();
+ } else {
+ abstractIdentifyRequest_ = value;
+ }
+ onChanged();
+ } else {
+ abstractIdentifyRequestBuilder_.mergeFrom(value);
+ }
+
+ return this;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ public Builder clearAbstractIdentifyRequest() {
+ if (abstractIdentifyRequestBuilder_ == null) {
+ abstractIdentifyRequest_ = null;
+ onChanged();
+ } else {
+ abstractIdentifyRequest_ = null;
+ abstractIdentifyRequestBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ public AbstractIdentifyRequestProto.Builder getAbstractIdentifyRequestBuilder() {
+
+ onChanged();
+ return getAbstractIdentifyRequestFieldBuilder().getBuilder();
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ public AbstractIdentifyRequestProtoOrBuilder getAbstractIdentifyRequestOrBuilder() {
+ if (abstractIdentifyRequestBuilder_ != null) {
+ return abstractIdentifyRequestBuilder_.getMessageOrBuilder();
+ } else {
+ return abstractIdentifyRequest_ == null ?
+ AbstractIdentifyRequestProto.getDefaultInstance() : abstractIdentifyRequest_;
+ }
+ }
+ /**
+ * .org.apache.seata.protocol.protobuf.AbstractIdentifyRequestProto abstractIdentifyRequest = 1;
+ */
+ private com.google.protobuf.SingleFieldBuilderV3<
+ AbstractIdentifyRequestProto, AbstractIdentifyRequestProto.Builder, AbstractIdentifyRequestProtoOrBuilder>
+ getAbstractIdentifyRequestFieldBuilder() {
+ if (abstractIdentifyRequestBuilder_ == null) {
+ abstractIdentifyRequestBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
+ AbstractIdentifyRequestProto, AbstractIdentifyRequestProto.Builder, AbstractIdentifyRequestProtoOrBuilder>(
+ getAbstractIdentifyRequest(),
+ getParentForChildren(),
+ isClean());
+ abstractIdentifyRequest_ = null;
+ }
+ return abstractIdentifyRequestBuilder_;
+ }
+ @Override
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.setUnknownFields(unknownFields);
+ }
+
+ @Override
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.mergeUnknownFields(unknownFields);
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:org.apache.seata.protocol.protobuf.RegisterTMRequestProto)
+ }
+
+ // @@protoc_insertion_point(class_scope:org.apache.seata.protocol.protobuf.RegisterTMRequestProto)
+ private static final RegisterTMRequestProto DEFAULT_INSTANCE;
+ static {
+ DEFAULT_INSTANCE = new RegisterTMRequestProto();
+ }
+
+ public static RegisterTMRequestProto getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parser
+ PARSER = new com.google.protobuf.AbstractParser() {
+ @Override
+ public RegisterTMRequestProto parsePartialFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return new RegisterTMRequestProto(input, extensionRegistry);
+ }
+ };
+
+ public static com.google.protobuf.Parser parser() {
+ return PARSER;
+ }
+
+ @Override
+ public com.google.protobuf.Parser