activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r674837 [2/3] - in /activemq/trunk/activemq-protocol-buffer: ./ src/ src/main/ src/main/java/ src/main/java/org/ src/main/java/org/apache/ src/main/java/org/apache/activemq/ src/main/java/org/apache/activemq/protocolbuffer/ src/main/proto/ ...
Date Tue, 08 Jul 2008 14:15:36 GMT
Added: activemq/trunk/activemq-protocol-buffer/src/main/java/org/apache/activemq/protocolbuffer/OpenWire.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-protocol-buffer/src/main/java/org/apache/activemq/protocolbuffer/OpenWire.java?rev=674837&view=auto
==============================================================================
--- activemq/trunk/activemq-protocol-buffer/src/main/java/org/apache/activemq/protocolbuffer/OpenWire.java (added)
+++ activemq/trunk/activemq-protocol-buffer/src/main/java/org/apache/activemq/protocolbuffer/OpenWire.java Tue Jul  8 07:15:35 2008
@@ -0,0 +1,5961 @@
+// Generated by the protocol buffer compiler.  DO NOT EDIT!
+
+package org.apache.activemq.protocolbuffer;
+
+public final class OpenWire {
+  private OpenWire() {}
+  public static com.google.protobuf.Descriptors.FileDescriptor
+      getDescriptor() {
+    return descriptor;
+  }
+  private static final com.google.protobuf.Descriptors.FileDescriptor
+      descriptor = buildDescriptor();
+  private static
+      com.google.protobuf.Descriptors.FileDescriptor
+      buildDescriptor() {
+    java.lang.String descriptorData =
+      "\n\016openwire.proto\022\"org.apache.activemq.pr" +
+      "otocolbuffer\"e\n\007Command\022\022\n\ncommand_id\030\001 " +
+      "\002(\005\022\031\n\021response_required\030\002 \002(\010\022\024\n\014comman" +
+      "d_type\030\003 \002(\005\022\025\n\rcommand_bytes\030\004 \002(\014\"\272\001\n\013" +
+      "Destination\022T\n\004type\030\001 \002(\0162?.org.apache.a" +
+      "ctivemq.protocolbuffer.Destination.Desti" +
+      "nationType:\005QUEUE\022\014\n\004name\030\002 \002(\t\"G\n\017Desti" +
+      "nationType\022\t\n\005QUEUE\020\000\022\t\n\005TOPIC\020\001\022\016\n\nTEMP" +
+      "_QUEUE\020\002\022\016\n\nTEMP_TOPIC\020\003\":\n\022LocalTransac" +
+      "tionId\022\025\n\rconnection_id\030\001 \002(\005\022\r\n\005value\030\002" +
+      " \002(\003\"]\n\017XATransactionId\022\021\n\tformat_id\030\001 \002" +
+      "(\005\022\030\n\020branch_qualifier\030\002 \002(\014\022\035\n\025global_t" +
+      "ransaction_id\030\003 \002(\014\"-\n\016StringProperty\022\014\n" +
+      "\004name\030\001 \002(\t\022\r\n\005value\030\002 \002(\t\"+\n\014BoolProper" +
+      "ty\022\014\n\004name\030\001 \002(\t\022\r\n\005value\030\002 \002(\010\"+\n\014ByteP" +
+      "roperty\022\014\n\004name\030\001 \002(\t\022\r\n\005value\030\002 \002(\005\",\n\r" +
+      "ShortProperty\022\014\n\004name\030\001 \002(\t\022\r\n\005value\030\002 \002" +
+      "(\005\"*\n\013IntProperty\022\014\n\004name\030\001 \002(\t\022\r\n\005value" +
+      "\030\002 \002(\005\"+\n\014LongProperty\022\014\n\004name\030\001 \002(\t\022\r\n\005" +
+      "value\030\002 \002(\005\",\n\rFloatProperty\022\014\n\004name\030\001 \002" +
+      "(\t\022\r\n\005value\030\002 \002(\002\"-\n\016DoubleProperty\022\014\n\004n" +
+      "ame\030\001 \002(\t\022\r\n\005value\030\002 \002(\001\"\336\004\n\nProperties\022" +
+      "K\n\017string_property\030\001 \003(\01322.org.apache.ac" +
+      "tivemq.protocolbuffer.StringProperty\022E\n\014" +
+      "int_property\030\002 \003(\0132/.org.apache.activemq" +
+      ".protocolbuffer.IntProperty\022G\n\rbool_prop" +
+      "erty\030\003 \003(\01320.org.apache.activemq.protoco" +
+      "lbuffer.BoolProperty\022G\n\rlong_property\030\004 " +
+      "\003(\01320.org.apache.activemq.protocolbuffer" +
+      ".LongProperty\022K\n\017double_property\030\005 \003(\01322" +
+      ".org.apache.activemq.protocolbuffer.Doub" +
+      "leProperty\022I\n\016float_property\030\006 \003(\01321.org" +
+      ".apache.activemq.protocolbuffer.FloatPro" +
+      "perty\022I\n\016short_property\030\007 \003(\01321.org.apac" +
+      "he.activemq.protocolbuffer.ShortProperty" +
+      "\022G\n\rbyte_property\030\010 \003(\01320.org.apache.act" +
+      "ivemq.protocolbuffer.ByteProperty\"\306\006\n\007Me" +
+      "ssage\022\023\n\013producer_id\030\001 \002(\005\022\030\n\020producer_c" +
+      "ounter\030\002 \002(\005\022D\n\013destination\030\003 \002(\0132/.org." +
+      "apache.activemq.protocolbuffer.Destinati" +
+      "on\022M\n\024original_destination\030\004 \001(\0132/.org.a" +
+      "pache.activemq.protocolbuffer.Destinatio" +
+      "n\022\020\n\010group_id\030\005 \001(\t\022\026\n\016property_bytes\030\006 " +
+      "\001(\014\022\026\n\016correlation_id\030\007 \001(\t\022\022\n\npersisten" +
+      "t\030\010 \001(\010\022\022\n\nexpiration\030\t \001(\003\022\020\n\010priority\030" +
+      "\n \001(\005\022A\n\010reply_to\030\013 \001(\0132/.org.apache.act" +
+      "ivemq.protocolbuffer.Destination\022\021\n\ttime" +
+      "stamp\030\014 \001(\003\022\014\n\004type\030\r \001(\t\022T\n\024local_trans" +
+      "action_id\030\016 \001(\01326.org.apache.activemq.pr" +
+      "otocolbuffer.LocalTransactionId\022N\n\021xa_tr" +
+      "ansaction_id\030\017 \001(\01323.org.apache.activemq" +
+      ".protocolbuffer.XATransactionId\022\022\n\ncompr" +
+      "essed\030\020 \001(\010\022\032\n\022redelivery_counter\030\021 \001(\005\022" +
+      "\023\n\013broker_path\030\022 \003(\t\022\022\n\ncluster_id\030\023 \003(\t" +
+      "\022\017\n\007user_id\030\024 \001(\t\022\017\n\007arrival\030\026 \001(\003\022\026\n\016br" +
+      "oker_in_time\030\027 \001(\003\022\027\n\017broker_out_time\030\030 " +
+      "\001(\003\022\021\n\tdroppable\030\034 \001(\010\022\032\n\022receivedByDFBr" +
+      "idge\030\035 \001(\010\022\026\n\016group_sequence\030( \001(\005B0\n\"or" +
+      "g.apache.activemq.protocolbufferB\010OpenWi" +
+      "reH\001";
+    try {
+      return com.google.protobuf.Descriptors.FileDescriptor
+        .internalBuildGeneratedFileFrom(descriptorData,
+          new com.google.protobuf.Descriptors.FileDescriptor[] {
+          });
+    } catch (Exception e) {
+      throw new RuntimeException(
+        "Failed to parse protocol buffer descriptor for " +
+        "\"openwire.proto\".", e);
+    }
+  }
+  
+  public static final class Command extends
+      com.google.protobuf.GeneratedMessage {
+    // Use Command.newBuilder() to construct.
+    private Command() {}
+    
+    private static final Command defaultInstance = new Command();
+    public static Command getDefaultInstance() {
+      return defaultInstance;
+    }
+    
+    public Command getDefaultInstanceForType() {
+      return defaultInstance;
+    }
+    
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_Command_descriptor;
+    }
+    
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_Command_fieldAccessorTable;
+    }
+    
+    // required int32 command_id = 1;
+    private boolean hasCommandId;
+    private int commandId_ = 0;
+    public boolean hasCommandId() { return hasCommandId; }
+    public int getCommandId() { return commandId_; }
+    
+    // required bool response_required = 2;
+    private boolean hasResponseRequired;
+    private boolean responseRequired_ = false;
+    public boolean hasResponseRequired() { return hasResponseRequired; }
+    public boolean getResponseRequired() { return responseRequired_; }
+    
+    // required int32 command_type = 3;
+    private boolean hasCommandType;
+    private int commandType_ = 0;
+    public boolean hasCommandType() { return hasCommandType; }
+    public int getCommandType() { return commandType_; }
+    
+    // required bytes command_bytes = 4;
+    private boolean hasCommandBytes;
+    private com.google.protobuf.ByteString commandBytes_ = com.google.protobuf.ByteString.EMPTY;
+    public boolean hasCommandBytes() { return hasCommandBytes; }
+    public com.google.protobuf.ByteString getCommandBytes() { return commandBytes_; }
+    
+    public final boolean isInitialized() {
+      if (!hasCommandId) return false;
+      if (!hasResponseRequired) return false;
+      if (!hasCommandType) return false;
+      if (!hasCommandBytes) return false;
+      return true;
+    }
+    
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      if (hasCommandId()) {
+        output.writeInt32(1, getCommandId());
+      }
+      if (hasResponseRequired()) {
+        output.writeBool(2, getResponseRequired());
+      }
+      if (hasCommandType()) {
+        output.writeInt32(3, getCommandType());
+      }
+      if (hasCommandBytes()) {
+        output.writeBytes(4, getCommandBytes());
+      }
+      getUnknownFields().writeTo(output);
+    }
+    
+    private int memoizedSerializedSize = -1;
+    public int getSerializedSize() {
+      int size = memoizedSerializedSize;
+      if (size != -1) return size;
+    
+      size = 0;
+      if (hasCommandId()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeInt32Size(1, getCommandId());
+      }
+      if (hasResponseRequired()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBoolSize(2, getResponseRequired());
+      }
+      if (hasCommandType()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeInt32Size(3, getCommandType());
+      }
+      if (hasCommandBytes()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBytesSize(4, getCommandBytes());
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSerializedSize = size;
+      return size;
+    }
+    
+    public static org.apache.activemq.protocolbuffer.OpenWire.Command parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.Command parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.Command parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.Command parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.Command parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.Command parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.Command parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.Command parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    
+    public static Builder newBuilder() { return new Builder(); }
+    public Builder newBuilderForType() { return new Builder(); }
+    public static Builder newBuilder(org.apache.activemq.protocolbuffer.OpenWire.Command prototype) {
+      return new Builder().mergeFrom(prototype);
+    }
+    
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessage.Builder<Builder> {
+      // Construct using org.apache.activemq.protocolbuffer.OpenWire.Command.newBuilder()
+      private Builder() {}
+      
+      org.apache.activemq.protocolbuffer.OpenWire.Command result = new org.apache.activemq.protocolbuffer.OpenWire.Command();
+      
+      protected org.apache.activemq.protocolbuffer.OpenWire.Command internalGetResult() {
+        return result;
+      }
+      
+      public Builder clear() {
+        result = new org.apache.activemq.protocolbuffer.OpenWire.Command();
+        return this;
+      }
+      
+      public Builder clone() {
+        return new Builder().mergeFrom(result);
+      }
+      
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return org.apache.activemq.protocolbuffer.OpenWire.Command.getDescriptor();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.Command getDefaultInstanceForType() {
+        return org.apache.activemq.protocolbuffer.OpenWire.Command.getDefaultInstance();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.Command build() {
+        if (!isInitialized()) {
+          throw new com.google.protobuf.UninitializedMessageException(
+            result);
+        }
+        return buildPartial();
+      }
+      
+      private org.apache.activemq.protocolbuffer.OpenWire.Command buildParsed()
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        if (!isInitialized()) {
+          throw new com.google.protobuf.UninitializedMessageException(
+            result).asInvalidProtocolBufferException();
+        }
+        return buildPartial();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.Command buildPartial() {
+        org.apache.activemq.protocolbuffer.OpenWire.Command returnMe = result;
+        result = null;
+        return returnMe;
+      }
+      
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof org.apache.activemq.protocolbuffer.OpenWire.Command) {
+          return mergeFrom((org.apache.activemq.protocolbuffer.OpenWire.Command)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+      
+      public Builder mergeFrom(org.apache.activemq.protocolbuffer.OpenWire.Command other) {
+        if (other == org.apache.activemq.protocolbuffer.OpenWire.Command.getDefaultInstance()) return this;
+        if (other.hasCommandId()) {
+          setCommandId(other.getCommandId());
+        }
+        if (other.hasResponseRequired()) {
+          setResponseRequired(other.getResponseRequired());
+        }
+        if (other.hasCommandType()) {
+          setCommandType(other.getCommandType());
+        }
+        if (other.hasCommandBytes()) {
+          setCommandBytes(other.getCommandBytes());
+        }
+        this.mergeUnknownFields(other.getUnknownFields());
+        return this;
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input)
+          throws java.io.IOException {
+        return mergeFrom(input,
+          com.google.protobuf.ExtensionRegistry.getEmptyRegistry());
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistry extensionRegistry)
+          throws java.io.IOException {
+        com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder(
+            this.getUnknownFields());
+        while (true) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              this.setUnknownFields(unknownFields.build());
+              return this;
+            default: {
+              if (!parseUnknownField(input, unknownFields,
+                                     extensionRegistry, tag)) {
+                this.setUnknownFields(unknownFields.build());
+                return this;
+              }
+              break;
+            }
+            case 8: {
+              setCommandId(input.readInt32());
+              break;
+            }
+            case 16: {
+              setResponseRequired(input.readBool());
+              break;
+            }
+            case 24: {
+              setCommandType(input.readInt32());
+              break;
+            }
+            case 34: {
+              setCommandBytes(input.readBytes());
+              break;
+            }
+          }
+        }
+      }
+      
+      
+      // required int32 command_id = 1;
+      public boolean hasCommandId() {
+        return result.hasCommandId();
+      }
+      public int getCommandId() {
+        return result.getCommandId();
+      }
+      public Builder setCommandId(int value) {
+        result.hasCommandId = true;
+        result.commandId_ = value;
+        return this;
+      }
+      public Builder clearCommandId() {
+        result.hasCommandId = false;
+        result.commandId_ = 0;
+        return this;
+      }
+      
+      // required bool response_required = 2;
+      public boolean hasResponseRequired() {
+        return result.hasResponseRequired();
+      }
+      public boolean getResponseRequired() {
+        return result.getResponseRequired();
+      }
+      public Builder setResponseRequired(boolean value) {
+        result.hasResponseRequired = true;
+        result.responseRequired_ = value;
+        return this;
+      }
+      public Builder clearResponseRequired() {
+        result.hasResponseRequired = false;
+        result.responseRequired_ = false;
+        return this;
+      }
+      
+      // required int32 command_type = 3;
+      public boolean hasCommandType() {
+        return result.hasCommandType();
+      }
+      public int getCommandType() {
+        return result.getCommandType();
+      }
+      public Builder setCommandType(int value) {
+        result.hasCommandType = true;
+        result.commandType_ = value;
+        return this;
+      }
+      public Builder clearCommandType() {
+        result.hasCommandType = false;
+        result.commandType_ = 0;
+        return this;
+      }
+      
+      // required bytes command_bytes = 4;
+      public boolean hasCommandBytes() {
+        return result.hasCommandBytes();
+      }
+      public com.google.protobuf.ByteString getCommandBytes() {
+        return result.getCommandBytes();
+      }
+      public Builder setCommandBytes(com.google.protobuf.ByteString value) {
+        result.hasCommandBytes = true;
+        result.commandBytes_ = value;
+        return this;
+      }
+      public Builder clearCommandBytes() {
+        result.hasCommandBytes = false;
+        result.commandBytes_ = com.google.protobuf.ByteString.EMPTY;
+        return this;
+      }
+    }
+  }
+  
+  public static final class Destination extends
+      com.google.protobuf.GeneratedMessage {
+    // Use Destination.newBuilder() to construct.
+    private Destination() {}
+    
+    private static final Destination defaultInstance = new Destination();
+    public static Destination getDefaultInstance() {
+      return defaultInstance;
+    }
+    
+    public Destination getDefaultInstanceForType() {
+      return defaultInstance;
+    }
+    
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_Destination_descriptor;
+    }
+    
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_Destination_fieldAccessorTable;
+    }
+    
+    public static enum DestinationType {
+      QUEUE(0, 0),
+      TOPIC(1, 1),
+      TEMP_QUEUE(2, 2),
+      TEMP_TOPIC(3, 3),
+      ;
+      
+      
+      public final int getNumber() { return value; }
+      
+      public static DestinationType valueOf(int value) {
+        switch (value) {
+          case 0: return QUEUE;
+          case 1: return TOPIC;
+          case 2: return TEMP_QUEUE;
+          case 3: return TEMP_TOPIC;
+          default: return null;
+        }
+      }
+      
+      public final com.google.protobuf.Descriptors.EnumValueDescriptor
+          getValueDescriptor() {
+        return getDescriptor().getValues().get(index);
+      }
+      public final com.google.protobuf.Descriptors.EnumDescriptor
+          getDescriptorForType() {
+        return getDescriptor();
+      }
+      public static final com.google.protobuf.Descriptors.EnumDescriptor
+          getDescriptor() {
+        return org.apache.activemq.protocolbuffer.OpenWire.Destination.getDescriptor().getEnumTypes().get(0);
+      }
+      
+      private static final DestinationType[] VALUES = {
+        QUEUE, TOPIC, TEMP_QUEUE, TEMP_TOPIC, 
+      };
+      public static DestinationType valueOf(
+          com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
+        if (desc.getType() != getDescriptor()) {
+          throw new java.lang.IllegalArgumentException(
+            "EnumValueDescriptor is not for this type.");
+        }
+        return VALUES[desc.getIndex()];
+      }
+      private final int index;
+      private final int value;
+      private DestinationType(int index, int value) {
+        this.index = index;
+        this.value = value;
+      }
+    }
+    
+    // required .org.apache.activemq.protocolbuffer.Destination.DestinationType type = 1 [default = QUEUE];
+    private boolean hasType;
+    private org.apache.activemq.protocolbuffer.OpenWire.Destination.DestinationType type_ = org.apache.activemq.protocolbuffer.OpenWire.Destination.DestinationType.QUEUE;
+    public boolean hasType() { return hasType; }
+    public org.apache.activemq.protocolbuffer.OpenWire.Destination.DestinationType getType() { return type_; }
+    
+    // required string name = 2;
+    private boolean hasName;
+    private java.lang.String name_ = "";
+    public boolean hasName() { return hasName; }
+    public java.lang.String getName() { return name_; }
+    
+    public final boolean isInitialized() {
+      if (!hasType) return false;
+      if (!hasName) return false;
+      return true;
+    }
+    
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      if (hasType()) {
+        output.writeEnum(1, getType().getNumber());
+      }
+      if (hasName()) {
+        output.writeString(2, getName());
+      }
+      getUnknownFields().writeTo(output);
+    }
+    
+    private int memoizedSerializedSize = -1;
+    public int getSerializedSize() {
+      int size = memoizedSerializedSize;
+      if (size != -1) return size;
+    
+      size = 0;
+      if (hasType()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeEnumSize(1, getType().getNumber());
+      }
+      if (hasName()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeStringSize(2, getName());
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSerializedSize = size;
+      return size;
+    }
+    
+    public static org.apache.activemq.protocolbuffer.OpenWire.Destination parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.Destination parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.Destination parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.Destination parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.Destination parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.Destination parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.Destination parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.Destination parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    
+    public static Builder newBuilder() { return new Builder(); }
+    public Builder newBuilderForType() { return new Builder(); }
+    public static Builder newBuilder(org.apache.activemq.protocolbuffer.OpenWire.Destination prototype) {
+      return new Builder().mergeFrom(prototype);
+    }
+    
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessage.Builder<Builder> {
+      // Construct using org.apache.activemq.protocolbuffer.OpenWire.Destination.newBuilder()
+      private Builder() {}
+      
+      org.apache.activemq.protocolbuffer.OpenWire.Destination result = new org.apache.activemq.protocolbuffer.OpenWire.Destination();
+      
+      protected org.apache.activemq.protocolbuffer.OpenWire.Destination internalGetResult() {
+        return result;
+      }
+      
+      public Builder clear() {
+        result = new org.apache.activemq.protocolbuffer.OpenWire.Destination();
+        return this;
+      }
+      
+      public Builder clone() {
+        return new Builder().mergeFrom(result);
+      }
+      
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return org.apache.activemq.protocolbuffer.OpenWire.Destination.getDescriptor();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.Destination getDefaultInstanceForType() {
+        return org.apache.activemq.protocolbuffer.OpenWire.Destination.getDefaultInstance();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.Destination build() {
+        if (!isInitialized()) {
+          throw new com.google.protobuf.UninitializedMessageException(
+            result);
+        }
+        return buildPartial();
+      }
+      
+      private org.apache.activemq.protocolbuffer.OpenWire.Destination buildParsed()
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        if (!isInitialized()) {
+          throw new com.google.protobuf.UninitializedMessageException(
+            result).asInvalidProtocolBufferException();
+        }
+        return buildPartial();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.Destination buildPartial() {
+        org.apache.activemq.protocolbuffer.OpenWire.Destination returnMe = result;
+        result = null;
+        return returnMe;
+      }
+      
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof org.apache.activemq.protocolbuffer.OpenWire.Destination) {
+          return mergeFrom((org.apache.activemq.protocolbuffer.OpenWire.Destination)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+      
+      public Builder mergeFrom(org.apache.activemq.protocolbuffer.OpenWire.Destination other) {
+        if (other == org.apache.activemq.protocolbuffer.OpenWire.Destination.getDefaultInstance()) return this;
+        if (other.hasType()) {
+          setType(other.getType());
+        }
+        if (other.hasName()) {
+          setName(other.getName());
+        }
+        this.mergeUnknownFields(other.getUnknownFields());
+        return this;
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input)
+          throws java.io.IOException {
+        return mergeFrom(input,
+          com.google.protobuf.ExtensionRegistry.getEmptyRegistry());
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistry extensionRegistry)
+          throws java.io.IOException {
+        com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder(
+            this.getUnknownFields());
+        while (true) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              this.setUnknownFields(unknownFields.build());
+              return this;
+            default: {
+              if (!parseUnknownField(input, unknownFields,
+                                     extensionRegistry, tag)) {
+                this.setUnknownFields(unknownFields.build());
+                return this;
+              }
+              break;
+            }
+            case 8: {
+              int rawValue = input.readEnum();
+              org.apache.activemq.protocolbuffer.OpenWire.Destination.DestinationType value = org.apache.activemq.protocolbuffer.OpenWire.Destination.DestinationType.valueOf(rawValue);
+              if (value == null) {
+                unknownFields.mergeVarintField(1, rawValue);
+              } else {
+                setType(value);
+              }
+              break;
+            }
+            case 18: {
+              setName(input.readString());
+              break;
+            }
+          }
+        }
+      }
+      
+      
+      // required .org.apache.activemq.protocolbuffer.Destination.DestinationType type = 1 [default = QUEUE];
+      public boolean hasType() {
+        return result.hasType();
+      }
+      public org.apache.activemq.protocolbuffer.OpenWire.Destination.DestinationType getType() {
+        return result.getType();
+      }
+      public Builder setType(org.apache.activemq.protocolbuffer.OpenWire.Destination.DestinationType value) {
+        result.hasType = true;
+        result.type_ = value;
+        return this;
+      }
+      public Builder clearType() {
+        result.hasType = false;
+        result.type_ = org.apache.activemq.protocolbuffer.OpenWire.Destination.DestinationType.QUEUE;
+        return this;
+      }
+      
+      // required string name = 2;
+      public boolean hasName() {
+        return result.hasName();
+      }
+      public java.lang.String getName() {
+        return result.getName();
+      }
+      public Builder setName(java.lang.String value) {
+        result.hasName = true;
+        result.name_ = value;
+        return this;
+      }
+      public Builder clearName() {
+        result.hasName = false;
+        result.name_ = "";
+        return this;
+      }
+    }
+  }
+  
+  public static final class LocalTransactionId extends
+      com.google.protobuf.GeneratedMessage {
+    // Use LocalTransactionId.newBuilder() to construct.
+    private LocalTransactionId() {}
+    
+    private static final LocalTransactionId defaultInstance = new LocalTransactionId();
+    public static LocalTransactionId getDefaultInstance() {
+      return defaultInstance;
+    }
+    
+    public LocalTransactionId getDefaultInstanceForType() {
+      return defaultInstance;
+    }
+    
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_LocalTransactionId_descriptor;
+    }
+    
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_LocalTransactionId_fieldAccessorTable;
+    }
+    
+    // required int32 connection_id = 1;
+    private boolean hasConnectionId;
+    private int connectionId_ = 0;
+    public boolean hasConnectionId() { return hasConnectionId; }
+    public int getConnectionId() { return connectionId_; }
+    
+    // required int64 value = 2;
+    private boolean hasValue;
+    private long value_ = 0L;
+    public boolean hasValue() { return hasValue; }
+    public long getValue() { return value_; }
+    
+    public final boolean isInitialized() {
+      if (!hasConnectionId) return false;
+      if (!hasValue) return false;
+      return true;
+    }
+    
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      if (hasConnectionId()) {
+        output.writeInt32(1, getConnectionId());
+      }
+      if (hasValue()) {
+        output.writeInt64(2, getValue());
+      }
+      getUnknownFields().writeTo(output);
+    }
+    
+    private int memoizedSerializedSize = -1;
+    public int getSerializedSize() {
+      int size = memoizedSerializedSize;
+      if (size != -1) return size;
+    
+      size = 0;
+      if (hasConnectionId()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeInt32Size(1, getConnectionId());
+      }
+      if (hasValue()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeInt64Size(2, getValue());
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSerializedSize = size;
+      return size;
+    }
+    
+    public static org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    
+    public static Builder newBuilder() { return new Builder(); }
+    public Builder newBuilderForType() { return new Builder(); }
+    public static Builder newBuilder(org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId prototype) {
+      return new Builder().mergeFrom(prototype);
+    }
+    
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessage.Builder<Builder> {
+      // Construct using org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId.newBuilder()
+      private Builder() {}
+      
+      org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId result = new org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId();
+      
+      protected org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId internalGetResult() {
+        return result;
+      }
+      
+      public Builder clear() {
+        result = new org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId();
+        return this;
+      }
+      
+      public Builder clone() {
+        return new Builder().mergeFrom(result);
+      }
+      
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId.getDescriptor();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId getDefaultInstanceForType() {
+        return org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId.getDefaultInstance();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId build() {
+        if (!isInitialized()) {
+          throw new com.google.protobuf.UninitializedMessageException(
+            result);
+        }
+        return buildPartial();
+      }
+      
+      private org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId buildParsed()
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        if (!isInitialized()) {
+          throw new com.google.protobuf.UninitializedMessageException(
+            result).asInvalidProtocolBufferException();
+        }
+        return buildPartial();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId buildPartial() {
+        org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId returnMe = result;
+        result = null;
+        return returnMe;
+      }
+      
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId) {
+          return mergeFrom((org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+      
+      public Builder mergeFrom(org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId other) {
+        if (other == org.apache.activemq.protocolbuffer.OpenWire.LocalTransactionId.getDefaultInstance()) return this;
+        if (other.hasConnectionId()) {
+          setConnectionId(other.getConnectionId());
+        }
+        if (other.hasValue()) {
+          setValue(other.getValue());
+        }
+        this.mergeUnknownFields(other.getUnknownFields());
+        return this;
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input)
+          throws java.io.IOException {
+        return mergeFrom(input,
+          com.google.protobuf.ExtensionRegistry.getEmptyRegistry());
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistry extensionRegistry)
+          throws java.io.IOException {
+        com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder(
+            this.getUnknownFields());
+        while (true) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              this.setUnknownFields(unknownFields.build());
+              return this;
+            default: {
+              if (!parseUnknownField(input, unknownFields,
+                                     extensionRegistry, tag)) {
+                this.setUnknownFields(unknownFields.build());
+                return this;
+              }
+              break;
+            }
+            case 8: {
+              setConnectionId(input.readInt32());
+              break;
+            }
+            case 16: {
+              setValue(input.readInt64());
+              break;
+            }
+          }
+        }
+      }
+      
+      
+      // required int32 connection_id = 1;
+      public boolean hasConnectionId() {
+        return result.hasConnectionId();
+      }
+      public int getConnectionId() {
+        return result.getConnectionId();
+      }
+      public Builder setConnectionId(int value) {
+        result.hasConnectionId = true;
+        result.connectionId_ = value;
+        return this;
+      }
+      public Builder clearConnectionId() {
+        result.hasConnectionId = false;
+        result.connectionId_ = 0;
+        return this;
+      }
+      
+      // required int64 value = 2;
+      public boolean hasValue() {
+        return result.hasValue();
+      }
+      public long getValue() {
+        return result.getValue();
+      }
+      public Builder setValue(long value) {
+        result.hasValue = true;
+        result.value_ = value;
+        return this;
+      }
+      public Builder clearValue() {
+        result.hasValue = false;
+        result.value_ = 0L;
+        return this;
+      }
+    }
+  }
+  
+  public static final class XATransactionId extends
+      com.google.protobuf.GeneratedMessage {
+    // Use XATransactionId.newBuilder() to construct.
+    private XATransactionId() {}
+    
+    private static final XATransactionId defaultInstance = new XATransactionId();
+    public static XATransactionId getDefaultInstance() {
+      return defaultInstance;
+    }
+    
+    public XATransactionId getDefaultInstanceForType() {
+      return defaultInstance;
+    }
+    
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_XATransactionId_descriptor;
+    }
+    
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_XATransactionId_fieldAccessorTable;
+    }
+    
+    // required int32 format_id = 1;
+    private boolean hasFormatId;
+    private int formatId_ = 0;
+    public boolean hasFormatId() { return hasFormatId; }
+    public int getFormatId() { return formatId_; }
+    
+    // required bytes branch_qualifier = 2;
+    private boolean hasBranchQualifier;
+    private com.google.protobuf.ByteString branchQualifier_ = com.google.protobuf.ByteString.EMPTY;
+    public boolean hasBranchQualifier() { return hasBranchQualifier; }
+    public com.google.protobuf.ByteString getBranchQualifier() { return branchQualifier_; }
+    
+    // required bytes global_transaction_id = 3;
+    private boolean hasGlobalTransactionId;
+    private com.google.protobuf.ByteString globalTransactionId_ = com.google.protobuf.ByteString.EMPTY;
+    public boolean hasGlobalTransactionId() { return hasGlobalTransactionId; }
+    public com.google.protobuf.ByteString getGlobalTransactionId() { return globalTransactionId_; }
+    
+    public final boolean isInitialized() {
+      if (!hasFormatId) return false;
+      if (!hasBranchQualifier) return false;
+      if (!hasGlobalTransactionId) return false;
+      return true;
+    }
+    
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      if (hasFormatId()) {
+        output.writeInt32(1, getFormatId());
+      }
+      if (hasBranchQualifier()) {
+        output.writeBytes(2, getBranchQualifier());
+      }
+      if (hasGlobalTransactionId()) {
+        output.writeBytes(3, getGlobalTransactionId());
+      }
+      getUnknownFields().writeTo(output);
+    }
+    
+    private int memoizedSerializedSize = -1;
+    public int getSerializedSize() {
+      int size = memoizedSerializedSize;
+      if (size != -1) return size;
+    
+      size = 0;
+      if (hasFormatId()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeInt32Size(1, getFormatId());
+      }
+      if (hasBranchQualifier()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBytesSize(2, getBranchQualifier());
+      }
+      if (hasGlobalTransactionId()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBytesSize(3, getGlobalTransactionId());
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSerializedSize = size;
+      return size;
+    }
+    
+    public static org.apache.activemq.protocolbuffer.OpenWire.XATransactionId parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.XATransactionId parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.XATransactionId parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.XATransactionId parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.XATransactionId parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.XATransactionId parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.XATransactionId parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.XATransactionId parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    
+    public static Builder newBuilder() { return new Builder(); }
+    public Builder newBuilderForType() { return new Builder(); }
+    public static Builder newBuilder(org.apache.activemq.protocolbuffer.OpenWire.XATransactionId prototype) {
+      return new Builder().mergeFrom(prototype);
+    }
+    
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessage.Builder<Builder> {
+      // Construct using org.apache.activemq.protocolbuffer.OpenWire.XATransactionId.newBuilder()
+      private Builder() {}
+      
+      org.apache.activemq.protocolbuffer.OpenWire.XATransactionId result = new org.apache.activemq.protocolbuffer.OpenWire.XATransactionId();
+      
+      protected org.apache.activemq.protocolbuffer.OpenWire.XATransactionId internalGetResult() {
+        return result;
+      }
+      
+      public Builder clear() {
+        result = new org.apache.activemq.protocolbuffer.OpenWire.XATransactionId();
+        return this;
+      }
+      
+      public Builder clone() {
+        return new Builder().mergeFrom(result);
+      }
+      
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return org.apache.activemq.protocolbuffer.OpenWire.XATransactionId.getDescriptor();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.XATransactionId getDefaultInstanceForType() {
+        return org.apache.activemq.protocolbuffer.OpenWire.XATransactionId.getDefaultInstance();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.XATransactionId build() {
+        if (!isInitialized()) {
+          throw new com.google.protobuf.UninitializedMessageException(
+            result);
+        }
+        return buildPartial();
+      }
+      
+      private org.apache.activemq.protocolbuffer.OpenWire.XATransactionId buildParsed()
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        if (!isInitialized()) {
+          throw new com.google.protobuf.UninitializedMessageException(
+            result).asInvalidProtocolBufferException();
+        }
+        return buildPartial();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.XATransactionId buildPartial() {
+        org.apache.activemq.protocolbuffer.OpenWire.XATransactionId returnMe = result;
+        result = null;
+        return returnMe;
+      }
+      
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof org.apache.activemq.protocolbuffer.OpenWire.XATransactionId) {
+          return mergeFrom((org.apache.activemq.protocolbuffer.OpenWire.XATransactionId)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+      
+      public Builder mergeFrom(org.apache.activemq.protocolbuffer.OpenWire.XATransactionId other) {
+        if (other == org.apache.activemq.protocolbuffer.OpenWire.XATransactionId.getDefaultInstance()) return this;
+        if (other.hasFormatId()) {
+          setFormatId(other.getFormatId());
+        }
+        if (other.hasBranchQualifier()) {
+          setBranchQualifier(other.getBranchQualifier());
+        }
+        if (other.hasGlobalTransactionId()) {
+          setGlobalTransactionId(other.getGlobalTransactionId());
+        }
+        this.mergeUnknownFields(other.getUnknownFields());
+        return this;
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input)
+          throws java.io.IOException {
+        return mergeFrom(input,
+          com.google.protobuf.ExtensionRegistry.getEmptyRegistry());
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistry extensionRegistry)
+          throws java.io.IOException {
+        com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder(
+            this.getUnknownFields());
+        while (true) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              this.setUnknownFields(unknownFields.build());
+              return this;
+            default: {
+              if (!parseUnknownField(input, unknownFields,
+                                     extensionRegistry, tag)) {
+                this.setUnknownFields(unknownFields.build());
+                return this;
+              }
+              break;
+            }
+            case 8: {
+              setFormatId(input.readInt32());
+              break;
+            }
+            case 18: {
+              setBranchQualifier(input.readBytes());
+              break;
+            }
+            case 26: {
+              setGlobalTransactionId(input.readBytes());
+              break;
+            }
+          }
+        }
+      }
+      
+      
+      // required int32 format_id = 1;
+      public boolean hasFormatId() {
+        return result.hasFormatId();
+      }
+      public int getFormatId() {
+        return result.getFormatId();
+      }
+      public Builder setFormatId(int value) {
+        result.hasFormatId = true;
+        result.formatId_ = value;
+        return this;
+      }
+      public Builder clearFormatId() {
+        result.hasFormatId = false;
+        result.formatId_ = 0;
+        return this;
+      }
+      
+      // required bytes branch_qualifier = 2;
+      public boolean hasBranchQualifier() {
+        return result.hasBranchQualifier();
+      }
+      public com.google.protobuf.ByteString getBranchQualifier() {
+        return result.getBranchQualifier();
+      }
+      public Builder setBranchQualifier(com.google.protobuf.ByteString value) {
+        result.hasBranchQualifier = true;
+        result.branchQualifier_ = value;
+        return this;
+      }
+      public Builder clearBranchQualifier() {
+        result.hasBranchQualifier = false;
+        result.branchQualifier_ = com.google.protobuf.ByteString.EMPTY;
+        return this;
+      }
+      
+      // required bytes global_transaction_id = 3;
+      public boolean hasGlobalTransactionId() {
+        return result.hasGlobalTransactionId();
+      }
+      public com.google.protobuf.ByteString getGlobalTransactionId() {
+        return result.getGlobalTransactionId();
+      }
+      public Builder setGlobalTransactionId(com.google.protobuf.ByteString value) {
+        result.hasGlobalTransactionId = true;
+        result.globalTransactionId_ = value;
+        return this;
+      }
+      public Builder clearGlobalTransactionId() {
+        result.hasGlobalTransactionId = false;
+        result.globalTransactionId_ = com.google.protobuf.ByteString.EMPTY;
+        return this;
+      }
+    }
+  }
+  
+  public static final class StringProperty extends
+      com.google.protobuf.GeneratedMessage {
+    // Use StringProperty.newBuilder() to construct.
+    private StringProperty() {}
+    
+    private static final StringProperty defaultInstance = new StringProperty();
+    public static StringProperty getDefaultInstance() {
+      return defaultInstance;
+    }
+    
+    public StringProperty getDefaultInstanceForType() {
+      return defaultInstance;
+    }
+    
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_StringProperty_descriptor;
+    }
+    
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_StringProperty_fieldAccessorTable;
+    }
+    
+    // required string name = 1;
+    private boolean hasName;
+    private java.lang.String name_ = "";
+    public boolean hasName() { return hasName; }
+    public java.lang.String getName() { return name_; }
+    
+    // required string value = 2;
+    private boolean hasValue;
+    private java.lang.String value_ = "";
+    public boolean hasValue() { return hasValue; }
+    public java.lang.String getValue() { return value_; }
+    
+    public final boolean isInitialized() {
+      if (!hasName) return false;
+      if (!hasValue) return false;
+      return true;
+    }
+    
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      if (hasName()) {
+        output.writeString(1, getName());
+      }
+      if (hasValue()) {
+        output.writeString(2, getValue());
+      }
+      getUnknownFields().writeTo(output);
+    }
+    
+    private int memoizedSerializedSize = -1;
+    public int getSerializedSize() {
+      int size = memoizedSerializedSize;
+      if (size != -1) return size;
+    
+      size = 0;
+      if (hasName()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeStringSize(1, getName());
+      }
+      if (hasValue()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeStringSize(2, getValue());
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSerializedSize = size;
+      return size;
+    }
+    
+    public static org.apache.activemq.protocolbuffer.OpenWire.StringProperty parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.StringProperty parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.StringProperty parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.StringProperty parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.StringProperty parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.StringProperty parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.StringProperty parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.StringProperty parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    
+    public static Builder newBuilder() { return new Builder(); }
+    public Builder newBuilderForType() { return new Builder(); }
+    public static Builder newBuilder(org.apache.activemq.protocolbuffer.OpenWire.StringProperty prototype) {
+      return new Builder().mergeFrom(prototype);
+    }
+    
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessage.Builder<Builder> {
+      // Construct using org.apache.activemq.protocolbuffer.OpenWire.StringProperty.newBuilder()
+      private Builder() {}
+      
+      org.apache.activemq.protocolbuffer.OpenWire.StringProperty result = new org.apache.activemq.protocolbuffer.OpenWire.StringProperty();
+      
+      protected org.apache.activemq.protocolbuffer.OpenWire.StringProperty internalGetResult() {
+        return result;
+      }
+      
+      public Builder clear() {
+        result = new org.apache.activemq.protocolbuffer.OpenWire.StringProperty();
+        return this;
+      }
+      
+      public Builder clone() {
+        return new Builder().mergeFrom(result);
+      }
+      
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return org.apache.activemq.protocolbuffer.OpenWire.StringProperty.getDescriptor();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.StringProperty getDefaultInstanceForType() {
+        return org.apache.activemq.protocolbuffer.OpenWire.StringProperty.getDefaultInstance();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.StringProperty build() {
+        if (!isInitialized()) {
+          throw new com.google.protobuf.UninitializedMessageException(
+            result);
+        }
+        return buildPartial();
+      }
+      
+      private org.apache.activemq.protocolbuffer.OpenWire.StringProperty buildParsed()
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        if (!isInitialized()) {
+          throw new com.google.protobuf.UninitializedMessageException(
+            result).asInvalidProtocolBufferException();
+        }
+        return buildPartial();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.StringProperty buildPartial() {
+        org.apache.activemq.protocolbuffer.OpenWire.StringProperty returnMe = result;
+        result = null;
+        return returnMe;
+      }
+      
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof org.apache.activemq.protocolbuffer.OpenWire.StringProperty) {
+          return mergeFrom((org.apache.activemq.protocolbuffer.OpenWire.StringProperty)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+      
+      public Builder mergeFrom(org.apache.activemq.protocolbuffer.OpenWire.StringProperty other) {
+        if (other == org.apache.activemq.protocolbuffer.OpenWire.StringProperty.getDefaultInstance()) return this;
+        if (other.hasName()) {
+          setName(other.getName());
+        }
+        if (other.hasValue()) {
+          setValue(other.getValue());
+        }
+        this.mergeUnknownFields(other.getUnknownFields());
+        return this;
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input)
+          throws java.io.IOException {
+        return mergeFrom(input,
+          com.google.protobuf.ExtensionRegistry.getEmptyRegistry());
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistry extensionRegistry)
+          throws java.io.IOException {
+        com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder(
+            this.getUnknownFields());
+        while (true) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              this.setUnknownFields(unknownFields.build());
+              return this;
+            default: {
+              if (!parseUnknownField(input, unknownFields,
+                                     extensionRegistry, tag)) {
+                this.setUnknownFields(unknownFields.build());
+                return this;
+              }
+              break;
+            }
+            case 10: {
+              setName(input.readString());
+              break;
+            }
+            case 18: {
+              setValue(input.readString());
+              break;
+            }
+          }
+        }
+      }
+      
+      
+      // required string name = 1;
+      public boolean hasName() {
+        return result.hasName();
+      }
+      public java.lang.String getName() {
+        return result.getName();
+      }
+      public Builder setName(java.lang.String value) {
+        result.hasName = true;
+        result.name_ = value;
+        return this;
+      }
+      public Builder clearName() {
+        result.hasName = false;
+        result.name_ = "";
+        return this;
+      }
+      
+      // required string value = 2;
+      public boolean hasValue() {
+        return result.hasValue();
+      }
+      public java.lang.String getValue() {
+        return result.getValue();
+      }
+      public Builder setValue(java.lang.String value) {
+        result.hasValue = true;
+        result.value_ = value;
+        return this;
+      }
+      public Builder clearValue() {
+        result.hasValue = false;
+        result.value_ = "";
+        return this;
+      }
+    }
+  }
+  
+  public static final class BoolProperty extends
+      com.google.protobuf.GeneratedMessage {
+    // Use BoolProperty.newBuilder() to construct.
+    private BoolProperty() {}
+    
+    private static final BoolProperty defaultInstance = new BoolProperty();
+    public static BoolProperty getDefaultInstance() {
+      return defaultInstance;
+    }
+    
+    public BoolProperty getDefaultInstanceForType() {
+      return defaultInstance;
+    }
+    
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_BoolProperty_descriptor;
+    }
+    
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_BoolProperty_fieldAccessorTable;
+    }
+    
+    // required string name = 1;
+    private boolean hasName;
+    private java.lang.String name_ = "";
+    public boolean hasName() { return hasName; }
+    public java.lang.String getName() { return name_; }
+    
+    // required bool value = 2;
+    private boolean hasValue;
+    private boolean value_ = false;
+    public boolean hasValue() { return hasValue; }
+    public boolean getValue() { return value_; }
+    
+    public final boolean isInitialized() {
+      if (!hasName) return false;
+      if (!hasValue) return false;
+      return true;
+    }
+    
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      if (hasName()) {
+        output.writeString(1, getName());
+      }
+      if (hasValue()) {
+        output.writeBool(2, getValue());
+      }
+      getUnknownFields().writeTo(output);
+    }
+    
+    private int memoizedSerializedSize = -1;
+    public int getSerializedSize() {
+      int size = memoizedSerializedSize;
+      if (size != -1) return size;
+    
+      size = 0;
+      if (hasName()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeStringSize(1, getName());
+      }
+      if (hasValue()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBoolSize(2, getValue());
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSerializedSize = size;
+      return size;
+    }
+    
+    public static org.apache.activemq.protocolbuffer.OpenWire.BoolProperty parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.BoolProperty parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.BoolProperty parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.BoolProperty parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.BoolProperty parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.BoolProperty parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.BoolProperty parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.BoolProperty parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    
+    public static Builder newBuilder() { return new Builder(); }
+    public Builder newBuilderForType() { return new Builder(); }
+    public static Builder newBuilder(org.apache.activemq.protocolbuffer.OpenWire.BoolProperty prototype) {
+      return new Builder().mergeFrom(prototype);
+    }
+    
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessage.Builder<Builder> {
+      // Construct using org.apache.activemq.protocolbuffer.OpenWire.BoolProperty.newBuilder()
+      private Builder() {}
+      
+      org.apache.activemq.protocolbuffer.OpenWire.BoolProperty result = new org.apache.activemq.protocolbuffer.OpenWire.BoolProperty();
+      
+      protected org.apache.activemq.protocolbuffer.OpenWire.BoolProperty internalGetResult() {
+        return result;
+      }
+      
+      public Builder clear() {
+        result = new org.apache.activemq.protocolbuffer.OpenWire.BoolProperty();
+        return this;
+      }
+      
+      public Builder clone() {
+        return new Builder().mergeFrom(result);
+      }
+      
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return org.apache.activemq.protocolbuffer.OpenWire.BoolProperty.getDescriptor();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.BoolProperty getDefaultInstanceForType() {
+        return org.apache.activemq.protocolbuffer.OpenWire.BoolProperty.getDefaultInstance();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.BoolProperty build() {
+        if (!isInitialized()) {
+          throw new com.google.protobuf.UninitializedMessageException(
+            result);
+        }
+        return buildPartial();
+      }
+      
+      private org.apache.activemq.protocolbuffer.OpenWire.BoolProperty buildParsed()
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        if (!isInitialized()) {
+          throw new com.google.protobuf.UninitializedMessageException(
+            result).asInvalidProtocolBufferException();
+        }
+        return buildPartial();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.BoolProperty buildPartial() {
+        org.apache.activemq.protocolbuffer.OpenWire.BoolProperty returnMe = result;
+        result = null;
+        return returnMe;
+      }
+      
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof org.apache.activemq.protocolbuffer.OpenWire.BoolProperty) {
+          return mergeFrom((org.apache.activemq.protocolbuffer.OpenWire.BoolProperty)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+      
+      public Builder mergeFrom(org.apache.activemq.protocolbuffer.OpenWire.BoolProperty other) {
+        if (other == org.apache.activemq.protocolbuffer.OpenWire.BoolProperty.getDefaultInstance()) return this;
+        if (other.hasName()) {
+          setName(other.getName());
+        }
+        if (other.hasValue()) {
+          setValue(other.getValue());
+        }
+        this.mergeUnknownFields(other.getUnknownFields());
+        return this;
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input)
+          throws java.io.IOException {
+        return mergeFrom(input,
+          com.google.protobuf.ExtensionRegistry.getEmptyRegistry());
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistry extensionRegistry)
+          throws java.io.IOException {
+        com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder(
+            this.getUnknownFields());
+        while (true) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              this.setUnknownFields(unknownFields.build());
+              return this;
+            default: {
+              if (!parseUnknownField(input, unknownFields,
+                                     extensionRegistry, tag)) {
+                this.setUnknownFields(unknownFields.build());
+                return this;
+              }
+              break;
+            }
+            case 10: {
+              setName(input.readString());
+              break;
+            }
+            case 16: {
+              setValue(input.readBool());
+              break;
+            }
+          }
+        }
+      }
+      
+      
+      // required string name = 1;
+      public boolean hasName() {
+        return result.hasName();
+      }
+      public java.lang.String getName() {
+        return result.getName();
+      }
+      public Builder setName(java.lang.String value) {
+        result.hasName = true;
+        result.name_ = value;
+        return this;
+      }
+      public Builder clearName() {
+        result.hasName = false;
+        result.name_ = "";
+        return this;
+      }
+      
+      // required bool value = 2;
+      public boolean hasValue() {
+        return result.hasValue();
+      }
+      public boolean getValue() {
+        return result.getValue();
+      }
+      public Builder setValue(boolean value) {
+        result.hasValue = true;
+        result.value_ = value;
+        return this;
+      }
+      public Builder clearValue() {
+        result.hasValue = false;
+        result.value_ = false;
+        return this;
+      }
+    }
+  }
+  
+  public static final class ByteProperty extends
+      com.google.protobuf.GeneratedMessage {
+    // Use ByteProperty.newBuilder() to construct.
+    private ByteProperty() {}
+    
+    private static final ByteProperty defaultInstance = new ByteProperty();
+    public static ByteProperty getDefaultInstance() {
+      return defaultInstance;
+    }
+    
+    public ByteProperty getDefaultInstanceForType() {
+      return defaultInstance;
+    }
+    
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_ByteProperty_descriptor;
+    }
+    
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_ByteProperty_fieldAccessorTable;
+    }
+    
+    // required string name = 1;
+    private boolean hasName;
+    private java.lang.String name_ = "";
+    public boolean hasName() { return hasName; }
+    public java.lang.String getName() { return name_; }
+    
+    // required int32 value = 2;
+    private boolean hasValue;
+    private int value_ = 0;
+    public boolean hasValue() { return hasValue; }
+    public int getValue() { return value_; }
+    
+    public final boolean isInitialized() {
+      if (!hasName) return false;
+      if (!hasValue) return false;
+      return true;
+    }
+    
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      if (hasName()) {
+        output.writeString(1, getName());
+      }
+      if (hasValue()) {
+        output.writeInt32(2, getValue());
+      }
+      getUnknownFields().writeTo(output);
+    }
+    
+    private int memoizedSerializedSize = -1;
+    public int getSerializedSize() {
+      int size = memoizedSerializedSize;
+      if (size != -1) return size;
+    
+      size = 0;
+      if (hasName()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeStringSize(1, getName());
+      }
+      if (hasValue()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeInt32Size(2, getValue());
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSerializedSize = size;
+      return size;
+    }
+    
+    public static org.apache.activemq.protocolbuffer.OpenWire.ByteProperty parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.ByteProperty parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.ByteProperty parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.ByteProperty parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.ByteProperty parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.ByteProperty parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.ByteProperty parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.ByteProperty parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    
+    public static Builder newBuilder() { return new Builder(); }
+    public Builder newBuilderForType() { return new Builder(); }
+    public static Builder newBuilder(org.apache.activemq.protocolbuffer.OpenWire.ByteProperty prototype) {
+      return new Builder().mergeFrom(prototype);
+    }
+    
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessage.Builder<Builder> {
+      // Construct using org.apache.activemq.protocolbuffer.OpenWire.ByteProperty.newBuilder()
+      private Builder() {}
+      
+      org.apache.activemq.protocolbuffer.OpenWire.ByteProperty result = new org.apache.activemq.protocolbuffer.OpenWire.ByteProperty();
+      
+      protected org.apache.activemq.protocolbuffer.OpenWire.ByteProperty internalGetResult() {
+        return result;
+      }
+      
+      public Builder clear() {
+        result = new org.apache.activemq.protocolbuffer.OpenWire.ByteProperty();
+        return this;
+      }
+      
+      public Builder clone() {
+        return new Builder().mergeFrom(result);
+      }
+      
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return org.apache.activemq.protocolbuffer.OpenWire.ByteProperty.getDescriptor();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.ByteProperty getDefaultInstanceForType() {
+        return org.apache.activemq.protocolbuffer.OpenWire.ByteProperty.getDefaultInstance();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.ByteProperty build() {
+        if (!isInitialized()) {
+          throw new com.google.protobuf.UninitializedMessageException(
+            result);
+        }
+        return buildPartial();
+      }
+      
+      private org.apache.activemq.protocolbuffer.OpenWire.ByteProperty buildParsed()
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        if (!isInitialized()) {
+          throw new com.google.protobuf.UninitializedMessageException(
+            result).asInvalidProtocolBufferException();
+        }
+        return buildPartial();
+      }
+      
+      public org.apache.activemq.protocolbuffer.OpenWire.ByteProperty buildPartial() {
+        org.apache.activemq.protocolbuffer.OpenWire.ByteProperty returnMe = result;
+        result = null;
+        return returnMe;
+      }
+      
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof org.apache.activemq.protocolbuffer.OpenWire.ByteProperty) {
+          return mergeFrom((org.apache.activemq.protocolbuffer.OpenWire.ByteProperty)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+      
+      public Builder mergeFrom(org.apache.activemq.protocolbuffer.OpenWire.ByteProperty other) {
+        if (other == org.apache.activemq.protocolbuffer.OpenWire.ByteProperty.getDefaultInstance()) return this;
+        if (other.hasName()) {
+          setName(other.getName());
+        }
+        if (other.hasValue()) {
+          setValue(other.getValue());
+        }
+        this.mergeUnknownFields(other.getUnknownFields());
+        return this;
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input)
+          throws java.io.IOException {
+        return mergeFrom(input,
+          com.google.protobuf.ExtensionRegistry.getEmptyRegistry());
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistry extensionRegistry)
+          throws java.io.IOException {
+        com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder(
+            this.getUnknownFields());
+        while (true) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              this.setUnknownFields(unknownFields.build());
+              return this;
+            default: {
+              if (!parseUnknownField(input, unknownFields,
+                                     extensionRegistry, tag)) {
+                this.setUnknownFields(unknownFields.build());
+                return this;
+              }
+              break;
+            }
+            case 10: {
+              setName(input.readString());
+              break;
+            }
+            case 16: {
+              setValue(input.readInt32());
+              break;
+            }
+          }
+        }
+      }
+      
+      
+      // required string name = 1;
+      public boolean hasName() {
+        return result.hasName();
+      }
+      public java.lang.String getName() {
+        return result.getName();
+      }
+      public Builder setName(java.lang.String value) {
+        result.hasName = true;
+        result.name_ = value;
+        return this;
+      }
+      public Builder clearName() {
+        result.hasName = false;
+        result.name_ = "";
+        return this;
+      }
+      
+      // required int32 value = 2;
+      public boolean hasValue() {
+        return result.hasValue();
+      }
+      public int getValue() {
+        return result.getValue();
+      }
+      public Builder setValue(int value) {
+        result.hasValue = true;
+        result.value_ = value;
+        return this;
+      }
+      public Builder clearValue() {
+        result.hasValue = false;
+        result.value_ = 0;
+        return this;
+      }
+    }
+  }
+  
+  public static final class ShortProperty extends
+      com.google.protobuf.GeneratedMessage {
+    // Use ShortProperty.newBuilder() to construct.
+    private ShortProperty() {}
+    
+    private static final ShortProperty defaultInstance = new ShortProperty();
+    public static ShortProperty getDefaultInstance() {
+      return defaultInstance;
+    }
+    
+    public ShortProperty getDefaultInstanceForType() {
+      return defaultInstance;
+    }
+    
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_ShortProperty_descriptor;
+    }
+    
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return org.apache.activemq.protocolbuffer.OpenWire.internal_static_org_apache_activemq_protocolbuffer_ShortProperty_fieldAccessorTable;
+    }
+    
+    // required string name = 1;
+    private boolean hasName;
+    private java.lang.String name_ = "";
+    public boolean hasName() { return hasName; }
+    public java.lang.String getName() { return name_; }
+    
+    // required int32 value = 2;
+    private boolean hasValue;
+    private int value_ = 0;
+    public boolean hasValue() { return hasValue; }
+    public int getValue() { return value_; }
+    
+    public final boolean isInitialized() {
+      if (!hasName) return false;
+      if (!hasValue) return false;
+      return true;
+    }
+    
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      if (hasName()) {
+        output.writeString(1, getName());
+      }
+      if (hasValue()) {
+        output.writeInt32(2, getValue());
+      }
+      getUnknownFields().writeTo(output);
+    }
+    
+    private int memoizedSerializedSize = -1;
+    public int getSerializedSize() {
+      int size = memoizedSerializedSize;
+      if (size != -1) return size;
+    
+      size = 0;
+      if (hasName()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeStringSize(1, getName());
+      }
+      if (hasValue()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeInt32Size(2, getValue());
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSerializedSize = size;
+      return size;
+    }
+    
+    public static org.apache.activemq.protocolbuffer.OpenWire.ShortProperty parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.ShortProperty parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistry extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static org.apache.activemq.protocolbuffer.OpenWire.ShortProperty parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {

[... 3674 lines stripped ...]


Mime
View raw message