activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r961087 [3/7] - in /activemq/sandbox/activemq-apollo-actor: ./ activemq-broker/ activemq-broker/src/main/scala/org/apache/activemq/apollo/broker/ activemq-broker/src/main/scala/org/apache/activemq/apollo/broker/path/ activemq-broker/src/tes...
Date Wed, 07 Jul 2010 03:50:51 GMT
Added: activemq/sandbox/activemq-apollo-actor/activemq-hawtdb/target/generated-sources/proto/org/apache/activemq/broker/store/hawtdb/Data.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-hawtdb/target/generated-sources/proto/org/apache/activemq/broker/store/hawtdb/Data.java?rev=961087&view=auto
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-hawtdb/target/generated-sources/proto/org/apache/activemq/broker/store/hawtdb/Data.java (added)
+++ activemq/sandbox/activemq-apollo-actor/activemq-hawtdb/target/generated-sources/proto/org/apache/activemq/broker/store/hawtdb/Data.java Wed Jul  7 03:50:42 2010
@@ -0,0 +1,10666 @@
+//
+// Generated by protoc, do not edit by hand.
+//
+package org.apache.activemq.broker.store.hawtdb;
+
+public class Data {
+
+   public static enum Type {
+
+      MESSAGE_ADD("MESSAGE_ADD", 0),
+      QUEUE_ADD("QUEUE_ADD", 10),
+      QUEUE_REMOVE("QUEUE_REMOVE", 11),
+      QUEUE_ADD_MESSAGE("QUEUE_ADD_MESSAGE", 12),
+      QUEUE_REMOVE_MESSAGE("QUEUE_REMOVE_MESSAGE", 13),
+      TRANSACTION_BEGIN("TRANSACTION_BEGIN", 20),
+      TRANSACTION_ADD_MESSAGE("TRANSACTION_ADD_MESSAGE", 21),
+      TRANSACTION_REMOVE_MESSAGE("TRANSACTION_REMOVE_MESSAGE", 22),
+      TRANSACTION_COMMIT("TRANSACTION_COMMIT", 23),
+      TRANSACTION_ROLLBACK("TRANSACTION_ROLLBACK", 24),
+      MAP_ADD("MAP_ADD", 30),
+      MAP_REMOVE("MAP_REMOVE", 31),
+      MAP_ENTRY_PUT("MAP_ENTRY_PUT", 32),
+      MAP_ENTRY_REMOVE("MAP_ENTRY_REMOVE", 33),
+      STREAM_OPEN("STREAM_OPEN", 40),
+      STREAM_WRITE("STREAM_WRITE", 41),
+      STREAM_CLOSE("STREAM_CLOSE", 42),
+      STREAM_REMOVE("STREAM_REMOVE", 43),
+      SUBSCRIPTION_ADD("SUBSCRIPTION_ADD", 50),
+      SUBSCRIPTION_REMOVE("SUBSCRIPTION_REMOVE", 51),
+      TRACE("TRACE", 100);
+
+      private final String name;
+      private final int value;
+
+      private Type(String name, int value) {
+         this.name = name;
+         this.value = value;
+      }
+
+      public final int getNumber() {
+         return value;
+      }
+
+      public final String toString() {
+         return name;
+      }
+
+      public static Type valueOf(int value) {
+         switch (value) {
+         case 0:
+            return MESSAGE_ADD;
+         case 10:
+            return QUEUE_ADD;
+         case 11:
+            return QUEUE_REMOVE;
+         case 12:
+            return QUEUE_ADD_MESSAGE;
+         case 13:
+            return QUEUE_REMOVE_MESSAGE;
+         case 20:
+            return TRANSACTION_BEGIN;
+         case 21:
+            return TRANSACTION_ADD_MESSAGE;
+         case 22:
+            return TRANSACTION_REMOVE_MESSAGE;
+         case 23:
+            return TRANSACTION_COMMIT;
+         case 24:
+            return TRANSACTION_ROLLBACK;
+         case 30:
+            return MAP_ADD;
+         case 31:
+            return MAP_REMOVE;
+         case 32:
+            return MAP_ENTRY_PUT;
+         case 33:
+            return MAP_ENTRY_REMOVE;
+         case 40:
+            return STREAM_OPEN;
+         case 41:
+            return STREAM_WRITE;
+         case 42:
+            return STREAM_CLOSE;
+         case 43:
+            return STREAM_REMOVE;
+         case 50:
+            return SUBSCRIPTION_ADD;
+         case 51:
+            return SUBSCRIPTION_REMOVE;
+         case 100:
+            return TRACE;
+         default:
+            return null;
+         }
+      }
+
+      public interface TypeCreatable {
+         Type toType();
+      }
+
+      public TypeCreatable createBean() {
+         switch (this) {
+            case MESSAGE_ADD:
+               return new MessageAdd.MessageAddBean();
+            case QUEUE_ADD:
+               return new QueueAdd.QueueAddBean();
+            case QUEUE_REMOVE:
+               return new QueueRemove.QueueRemoveBean();
+            case QUEUE_ADD_MESSAGE:
+               return new QueueAddMessage.QueueAddMessageBean();
+            case QUEUE_REMOVE_MESSAGE:
+               return new QueueRemoveMessage.QueueRemoveMessageBean();
+            case TRANSACTION_BEGIN:
+               return new TransactionBegin.TransactionBeginBean();
+            case TRANSACTION_ADD_MESSAGE:
+               return new TransactionAddMessage.TransactionAddMessageBean();
+            case TRANSACTION_REMOVE_MESSAGE:
+               return new TransactionRemoveMessage.TransactionRemoveMessageBean();
+            case TRANSACTION_COMMIT:
+               return new TransactionCommit.TransactionCommitBean();
+            case TRANSACTION_ROLLBACK:
+               return new TransactionRollback.TransactionRollbackBean();
+            case MAP_ADD:
+               return new MapAdd.MapAddBean();
+            case MAP_REMOVE:
+               return new MapRemove.MapRemoveBean();
+            case MAP_ENTRY_PUT:
+               return new MapEntryPut.MapEntryPutBean();
+            case MAP_ENTRY_REMOVE:
+               return new MapEntryRemove.MapEntryRemoveBean();
+            case STREAM_OPEN:
+               return new StreamOpen.StreamOpenBean();
+            case STREAM_WRITE:
+               return new StreamWrite.StreamWriteBean();
+            case STREAM_CLOSE:
+               return new StreamClose.StreamCloseBean();
+            case STREAM_REMOVE:
+               return new StreamRemove.StreamRemoveBean();
+            case SUBSCRIPTION_ADD:
+               return new SubscriptionAdd.SubscriptionAddBean();
+            case SUBSCRIPTION_REMOVE:
+               return new SubscriptionRemove.SubscriptionRemoveBean();
+            case TRACE:
+               return new Trace.TraceBean();
+            default:
+               return null;
+         }
+      }
+
+      public org.fusesource.hawtbuf.proto.MessageBuffer parseUnframed(org.fusesource.hawtbuf.Buffer data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+         switch (this) {
+            case MESSAGE_ADD:
+               return MessageAdd.MessageAddBuffer.parseUnframed(data);
+            case QUEUE_ADD:
+               return QueueAdd.QueueAddBuffer.parseUnframed(data);
+            case QUEUE_REMOVE:
+               return QueueRemove.QueueRemoveBuffer.parseUnframed(data);
+            case QUEUE_ADD_MESSAGE:
+               return QueueAddMessage.QueueAddMessageBuffer.parseUnframed(data);
+            case QUEUE_REMOVE_MESSAGE:
+               return QueueRemoveMessage.QueueRemoveMessageBuffer.parseUnframed(data);
+            case TRANSACTION_BEGIN:
+               return TransactionBegin.TransactionBeginBuffer.parseUnframed(data);
+            case TRANSACTION_ADD_MESSAGE:
+               return TransactionAddMessage.TransactionAddMessageBuffer.parseUnframed(data);
+            case TRANSACTION_REMOVE_MESSAGE:
+               return TransactionRemoveMessage.TransactionRemoveMessageBuffer.parseUnframed(data);
+            case TRANSACTION_COMMIT:
+               return TransactionCommit.TransactionCommitBuffer.parseUnframed(data);
+            case TRANSACTION_ROLLBACK:
+               return TransactionRollback.TransactionRollbackBuffer.parseUnframed(data);
+            case MAP_ADD:
+               return MapAdd.MapAddBuffer.parseUnframed(data);
+            case MAP_REMOVE:
+               return MapRemove.MapRemoveBuffer.parseUnframed(data);
+            case MAP_ENTRY_PUT:
+               return MapEntryPut.MapEntryPutBuffer.parseUnframed(data);
+            case MAP_ENTRY_REMOVE:
+               return MapEntryRemove.MapEntryRemoveBuffer.parseUnframed(data);
+            case STREAM_OPEN:
+               return StreamOpen.StreamOpenBuffer.parseUnframed(data);
+            case STREAM_WRITE:
+               return StreamWrite.StreamWriteBuffer.parseUnframed(data);
+            case STREAM_CLOSE:
+               return StreamClose.StreamCloseBuffer.parseUnframed(data);
+            case STREAM_REMOVE:
+               return StreamRemove.StreamRemoveBuffer.parseUnframed(data);
+            case SUBSCRIPTION_ADD:
+               return SubscriptionAdd.SubscriptionAddBuffer.parseUnframed(data);
+            case SUBSCRIPTION_REMOVE:
+               return SubscriptionRemove.SubscriptionRemoveBuffer.parseUnframed(data);
+            case TRACE:
+               return Trace.TraceBuffer.parseUnframed(data);
+            default:
+               return null;
+         }
+      }
+
+      public org.fusesource.hawtbuf.proto.MessageBuffer parseFramed(org.fusesource.hawtbuf.Buffer data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+         switch (this) {
+            case MESSAGE_ADD:
+               return MessageAdd.MessageAddBuffer.parseFramed(data);
+            case QUEUE_ADD:
+               return QueueAdd.QueueAddBuffer.parseFramed(data);
+            case QUEUE_REMOVE:
+               return QueueRemove.QueueRemoveBuffer.parseFramed(data);
+            case QUEUE_ADD_MESSAGE:
+               return QueueAddMessage.QueueAddMessageBuffer.parseFramed(data);
+            case QUEUE_REMOVE_MESSAGE:
+               return QueueRemoveMessage.QueueRemoveMessageBuffer.parseFramed(data);
+            case TRANSACTION_BEGIN:
+               return TransactionBegin.TransactionBeginBuffer.parseFramed(data);
+            case TRANSACTION_ADD_MESSAGE:
+               return TransactionAddMessage.TransactionAddMessageBuffer.parseFramed(data);
+            case TRANSACTION_REMOVE_MESSAGE:
+               return TransactionRemoveMessage.TransactionRemoveMessageBuffer.parseFramed(data);
+            case TRANSACTION_COMMIT:
+               return TransactionCommit.TransactionCommitBuffer.parseFramed(data);
+            case TRANSACTION_ROLLBACK:
+               return TransactionRollback.TransactionRollbackBuffer.parseFramed(data);
+            case MAP_ADD:
+               return MapAdd.MapAddBuffer.parseFramed(data);
+            case MAP_REMOVE:
+               return MapRemove.MapRemoveBuffer.parseFramed(data);
+            case MAP_ENTRY_PUT:
+               return MapEntryPut.MapEntryPutBuffer.parseFramed(data);
+            case MAP_ENTRY_REMOVE:
+               return MapEntryRemove.MapEntryRemoveBuffer.parseFramed(data);
+            case STREAM_OPEN:
+               return StreamOpen.StreamOpenBuffer.parseFramed(data);
+            case STREAM_WRITE:
+               return StreamWrite.StreamWriteBuffer.parseFramed(data);
+            case STREAM_CLOSE:
+               return StreamClose.StreamCloseBuffer.parseFramed(data);
+            case STREAM_REMOVE:
+               return StreamRemove.StreamRemoveBuffer.parseFramed(data);
+            case SUBSCRIPTION_ADD:
+               return SubscriptionAdd.SubscriptionAddBuffer.parseFramed(data);
+            case SUBSCRIPTION_REMOVE:
+               return SubscriptionRemove.SubscriptionRemoveBuffer.parseFramed(data);
+            case TRACE:
+               return Trace.TraceBuffer.parseFramed(data);
+            default:
+               return null;
+         }
+      }
+
+      public org.fusesource.hawtbuf.proto.MessageBuffer parseUnframed(byte[] data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+         switch (this) {
+            case MESSAGE_ADD:
+               return MessageAdd.MessageAddBuffer.parseUnframed(data);
+            case QUEUE_ADD:
+               return QueueAdd.QueueAddBuffer.parseUnframed(data);
+            case QUEUE_REMOVE:
+               return QueueRemove.QueueRemoveBuffer.parseUnframed(data);
+            case QUEUE_ADD_MESSAGE:
+               return QueueAddMessage.QueueAddMessageBuffer.parseUnframed(data);
+            case QUEUE_REMOVE_MESSAGE:
+               return QueueRemoveMessage.QueueRemoveMessageBuffer.parseUnframed(data);
+            case TRANSACTION_BEGIN:
+               return TransactionBegin.TransactionBeginBuffer.parseUnframed(data);
+            case TRANSACTION_ADD_MESSAGE:
+               return TransactionAddMessage.TransactionAddMessageBuffer.parseUnframed(data);
+            case TRANSACTION_REMOVE_MESSAGE:
+               return TransactionRemoveMessage.TransactionRemoveMessageBuffer.parseUnframed(data);
+            case TRANSACTION_COMMIT:
+               return TransactionCommit.TransactionCommitBuffer.parseUnframed(data);
+            case TRANSACTION_ROLLBACK:
+               return TransactionRollback.TransactionRollbackBuffer.parseUnframed(data);
+            case MAP_ADD:
+               return MapAdd.MapAddBuffer.parseUnframed(data);
+            case MAP_REMOVE:
+               return MapRemove.MapRemoveBuffer.parseUnframed(data);
+            case MAP_ENTRY_PUT:
+               return MapEntryPut.MapEntryPutBuffer.parseUnframed(data);
+            case MAP_ENTRY_REMOVE:
+               return MapEntryRemove.MapEntryRemoveBuffer.parseUnframed(data);
+            case STREAM_OPEN:
+               return StreamOpen.StreamOpenBuffer.parseUnframed(data);
+            case STREAM_WRITE:
+               return StreamWrite.StreamWriteBuffer.parseUnframed(data);
+            case STREAM_CLOSE:
+               return StreamClose.StreamCloseBuffer.parseUnframed(data);
+            case STREAM_REMOVE:
+               return StreamRemove.StreamRemoveBuffer.parseUnframed(data);
+            case SUBSCRIPTION_ADD:
+               return SubscriptionAdd.SubscriptionAddBuffer.parseUnframed(data);
+            case SUBSCRIPTION_REMOVE:
+               return SubscriptionRemove.SubscriptionRemoveBuffer.parseUnframed(data);
+            case TRACE:
+               return Trace.TraceBuffer.parseUnframed(data);
+            default:
+               return null;
+         }
+      }
+
+      public org.fusesource.hawtbuf.proto.MessageBuffer parseFramed(byte[] data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+         switch (this) {
+            case MESSAGE_ADD:
+               return MessageAdd.MessageAddBuffer.parseFramed(data);
+            case QUEUE_ADD:
+               return QueueAdd.QueueAddBuffer.parseFramed(data);
+            case QUEUE_REMOVE:
+               return QueueRemove.QueueRemoveBuffer.parseFramed(data);
+            case QUEUE_ADD_MESSAGE:
+               return QueueAddMessage.QueueAddMessageBuffer.parseFramed(data);
+            case QUEUE_REMOVE_MESSAGE:
+               return QueueRemoveMessage.QueueRemoveMessageBuffer.parseFramed(data);
+            case TRANSACTION_BEGIN:
+               return TransactionBegin.TransactionBeginBuffer.parseFramed(data);
+            case TRANSACTION_ADD_MESSAGE:
+               return TransactionAddMessage.TransactionAddMessageBuffer.parseFramed(data);
+            case TRANSACTION_REMOVE_MESSAGE:
+               return TransactionRemoveMessage.TransactionRemoveMessageBuffer.parseFramed(data);
+            case TRANSACTION_COMMIT:
+               return TransactionCommit.TransactionCommitBuffer.parseFramed(data);
+            case TRANSACTION_ROLLBACK:
+               return TransactionRollback.TransactionRollbackBuffer.parseFramed(data);
+            case MAP_ADD:
+               return MapAdd.MapAddBuffer.parseFramed(data);
+            case MAP_REMOVE:
+               return MapRemove.MapRemoveBuffer.parseFramed(data);
+            case MAP_ENTRY_PUT:
+               return MapEntryPut.MapEntryPutBuffer.parseFramed(data);
+            case MAP_ENTRY_REMOVE:
+               return MapEntryRemove.MapEntryRemoveBuffer.parseFramed(data);
+            case STREAM_OPEN:
+               return StreamOpen.StreamOpenBuffer.parseFramed(data);
+            case STREAM_WRITE:
+               return StreamWrite.StreamWriteBuffer.parseFramed(data);
+            case STREAM_CLOSE:
+               return StreamClose.StreamCloseBuffer.parseFramed(data);
+            case STREAM_REMOVE:
+               return StreamRemove.StreamRemoveBuffer.parseFramed(data);
+            case SUBSCRIPTION_ADD:
+               return SubscriptionAdd.SubscriptionAddBuffer.parseFramed(data);
+            case SUBSCRIPTION_REMOVE:
+               return SubscriptionRemove.SubscriptionRemoveBuffer.parseFramed(data);
+            case TRACE:
+               return Trace.TraceBuffer.parseFramed(data);
+            default:
+               return null;
+         }
+      }
+
+      public org.fusesource.hawtbuf.proto.MessageBuffer parseFramed(org.fusesource.hawtbuf.proto.CodedInputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
+         switch (this) {
+            case MESSAGE_ADD:
+               return MessageAdd.MessageAddBuffer.parseFramed(data);
+            case QUEUE_ADD:
+               return QueueAdd.QueueAddBuffer.parseFramed(data);
+            case QUEUE_REMOVE:
+               return QueueRemove.QueueRemoveBuffer.parseFramed(data);
+            case QUEUE_ADD_MESSAGE:
+               return QueueAddMessage.QueueAddMessageBuffer.parseFramed(data);
+            case QUEUE_REMOVE_MESSAGE:
+               return QueueRemoveMessage.QueueRemoveMessageBuffer.parseFramed(data);
+            case TRANSACTION_BEGIN:
+               return TransactionBegin.TransactionBeginBuffer.parseFramed(data);
+            case TRANSACTION_ADD_MESSAGE:
+               return TransactionAddMessage.TransactionAddMessageBuffer.parseFramed(data);
+            case TRANSACTION_REMOVE_MESSAGE:
+               return TransactionRemoveMessage.TransactionRemoveMessageBuffer.parseFramed(data);
+            case TRANSACTION_COMMIT:
+               return TransactionCommit.TransactionCommitBuffer.parseFramed(data);
+            case TRANSACTION_ROLLBACK:
+               return TransactionRollback.TransactionRollbackBuffer.parseFramed(data);
+            case MAP_ADD:
+               return MapAdd.MapAddBuffer.parseFramed(data);
+            case MAP_REMOVE:
+               return MapRemove.MapRemoveBuffer.parseFramed(data);
+            case MAP_ENTRY_PUT:
+               return MapEntryPut.MapEntryPutBuffer.parseFramed(data);
+            case MAP_ENTRY_REMOVE:
+               return MapEntryRemove.MapEntryRemoveBuffer.parseFramed(data);
+            case STREAM_OPEN:
+               return StreamOpen.StreamOpenBuffer.parseFramed(data);
+            case STREAM_WRITE:
+               return StreamWrite.StreamWriteBuffer.parseFramed(data);
+            case STREAM_CLOSE:
+               return StreamClose.StreamCloseBuffer.parseFramed(data);
+            case STREAM_REMOVE:
+               return StreamRemove.StreamRemoveBuffer.parseFramed(data);
+            case SUBSCRIPTION_ADD:
+               return SubscriptionAdd.SubscriptionAddBuffer.parseFramed(data);
+            case SUBSCRIPTION_REMOVE:
+               return SubscriptionRemove.SubscriptionRemoveBuffer.parseFramed(data);
+            case TRACE:
+               return Trace.TraceBuffer.parseFramed(data);
+            default:
+               return null;
+         }
+      }
+
+      public org.fusesource.hawtbuf.proto.MessageBuffer parseFramed(java.io.InputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
+         switch (this) {
+            case MESSAGE_ADD:
+               return MessageAdd.MessageAddBuffer.parseFramed(data);
+            case QUEUE_ADD:
+               return QueueAdd.QueueAddBuffer.parseFramed(data);
+            case QUEUE_REMOVE:
+               return QueueRemove.QueueRemoveBuffer.parseFramed(data);
+            case QUEUE_ADD_MESSAGE:
+               return QueueAddMessage.QueueAddMessageBuffer.parseFramed(data);
+            case QUEUE_REMOVE_MESSAGE:
+               return QueueRemoveMessage.QueueRemoveMessageBuffer.parseFramed(data);
+            case TRANSACTION_BEGIN:
+               return TransactionBegin.TransactionBeginBuffer.parseFramed(data);
+            case TRANSACTION_ADD_MESSAGE:
+               return TransactionAddMessage.TransactionAddMessageBuffer.parseFramed(data);
+            case TRANSACTION_REMOVE_MESSAGE:
+               return TransactionRemoveMessage.TransactionRemoveMessageBuffer.parseFramed(data);
+            case TRANSACTION_COMMIT:
+               return TransactionCommit.TransactionCommitBuffer.parseFramed(data);
+            case TRANSACTION_ROLLBACK:
+               return TransactionRollback.TransactionRollbackBuffer.parseFramed(data);
+            case MAP_ADD:
+               return MapAdd.MapAddBuffer.parseFramed(data);
+            case MAP_REMOVE:
+               return MapRemove.MapRemoveBuffer.parseFramed(data);
+            case MAP_ENTRY_PUT:
+               return MapEntryPut.MapEntryPutBuffer.parseFramed(data);
+            case MAP_ENTRY_REMOVE:
+               return MapEntryRemove.MapEntryRemoveBuffer.parseFramed(data);
+            case STREAM_OPEN:
+               return StreamOpen.StreamOpenBuffer.parseFramed(data);
+            case STREAM_WRITE:
+               return StreamWrite.StreamWriteBuffer.parseFramed(data);
+            case STREAM_CLOSE:
+               return StreamClose.StreamCloseBuffer.parseFramed(data);
+            case STREAM_REMOVE:
+               return StreamRemove.StreamRemoveBuffer.parseFramed(data);
+            case SUBSCRIPTION_ADD:
+               return SubscriptionAdd.SubscriptionAddBuffer.parseFramed(data);
+            case SUBSCRIPTION_REMOVE:
+               return SubscriptionRemove.SubscriptionRemoveBuffer.parseFramed(data);
+            case TRACE:
+               return Trace.TraceBuffer.parseFramed(data);
+            default:
+               return null;
+         }
+      }
+
+   }
+
+
+   static public interface Trace extends org.fusesource.hawtbuf.proto.PBMessage<Trace.TraceBean, Trace.TraceBuffer>, Type.TypeCreatable {
+
+      // optional bytes message = 2;
+      public boolean hasMessage();
+      public org.fusesource.hawtbuf.AsciiBuffer getMessage();
+      public TraceBean copy();
+      public TraceBuffer freeze();
+      public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix);
+
+      static public final class TraceBean implements Trace {
+
+         TraceBuffer frozen;
+         TraceBean bean;
+
+         public TraceBean() {
+            this.bean = this;
+         }
+
+         public TraceBean(TraceBean copy) {
+            this.bean = copy;
+         }
+
+         public TraceBean copy() {
+            return new TraceBean(bean);
+         }
+
+         public boolean frozen() {
+            return frozen!=null;
+         }
+
+         public TraceBuffer freeze() {
+            if( frozen==null ) {
+               frozen = new TraceBuffer(bean);
+               assert deepFreeze();
+            }
+            return frozen;
+         }
+
+         private boolean deepFreeze() {
+            frozen.serializedSizeUnframed();
+            return true;
+         }
+
+         private void copyCheck() {
+            assert frozen==null : org.fusesource.hawtbuf.proto.MessageBufferSupport.FORZEN_ERROR_MESSAGE;
+            if (bean != this) {
+               copy(bean);
+            }
+         }
+
+         private void copy(TraceBean other) {
+            this.bean = this;
+            this.f_message = other.f_message;
+            this.b_message = other.b_message;
+         }
+
+         // optional bytes message = 2;
+         private org.fusesource.hawtbuf.AsciiBuffer f_message = null;
+         private boolean b_message;
+
+         public boolean hasMessage() {
+            return bean.b_message;
+         }
+
+         public org.fusesource.hawtbuf.AsciiBuffer getMessage() {
+            return bean.f_message;
+         }
+
+         public TraceBean setMessage(org.fusesource.hawtbuf.AsciiBuffer message) {
+            copyCheck();
+            this.b_message = true;
+            this.f_message = message;
+            return this;
+         }
+
+         public void clearMessage() {
+            copyCheck();
+            this.b_message = false;
+            this.f_message = null;
+         }
+
+         public String toString() {
+            return toString(new java.lang.StringBuilder(), "").toString();
+         }
+
+         public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix) {
+            if(  hasMessage() ) {
+               sb.append(prefix+"message: ");
+               sb.append(getMessage());
+               sb.append("\n");
+            }
+            return sb;
+         }
+
+         public TraceBean mergeUnframed(java.io.InputStream input) throws java.io.IOException {
+            return mergeUnframed(new org.fusesource.hawtbuf.proto.CodedInputStream(input));
+         }
+
+         public TraceBean mergeUnframed(org.fusesource.hawtbuf.proto.CodedInputStream input) throws java.io.IOException {
+            copyCheck();
+            while (true) {
+               int tag = input.readTag();
+               if ((tag & 0x07) == 4) {
+                  return this;
+               }
+               switch (tag) {
+               case 0:
+                  return this;
+               default: {
+                  break;
+               }
+               case 18:
+                  setMessage(new org.fusesource.hawtbuf.AsciiBuffer(input.readBytes()));
+                  break;
+               }
+            }
+         }
+         public boolean equals(Object obj) {
+            if( obj==this )
+               return true;
+            
+            if( obj==null || obj.getClass()!=TraceBean.class )
+               return false;
+            
+            return equals((TraceBean)obj);
+         }
+         
+         public boolean equals(TraceBean obj) {
+            if (hasMessage() ^ obj.hasMessage() ) 
+               return false;
+            if (hasMessage() && ( !getMessage().equals(obj.getMessage()) ))
+               return false;
+            return true;
+         }
+         
+         public int hashCode() {
+            int rc=-1567265163;
+            if (hasMessage()) {
+               rc ^= ( -1675388953^getMessage().hashCode() );
+            }
+            return rc;
+         }
+         
+         public TraceBean mergeFrom(Trace other) {
+            copyCheck();
+            if (other.hasMessage()) {
+               setMessage(other.getMessage());
+            }
+            return this;
+         }
+
+         public void clear() {
+            clearMessage();
+         }
+
+         public void readExternal(java.io.DataInput in) throws java.io.IOException {
+            assert frozen==null : org.fusesource.hawtbuf.proto.MessageBufferSupport.FORZEN_ERROR_MESSAGE;
+            bean = this;
+            frozen = null;
+            {
+               int size = in.readInt();
+               if( size>=0 ) {
+                  byte b[] = new byte[size];
+                  in.readFully(b);
+                  f_message = new org.fusesource.hawtbuf.AsciiBuffer(b);
+                  b_message = true;
+               } else {
+                  f_message = null;
+                  b_message = false;
+               }
+            }
+         }
+
+         public void writeExternal(java.io.DataOutput out) throws java.io.IOException {
+            if( bean.f_message!=null ) {
+               out.writeInt(bean.f_message.getLength());
+               out.write(bean.f_message.getData(), bean.f_message.getOffset(), bean.f_message.getLength());
+            } else {
+               out.writeInt(-1);
+            }
+         }
+
+         public Type toType() {
+            return Type.TRACE;
+         }
+
+      }
+
+      static public final class TraceBuffer implements org.fusesource.hawtbuf.proto.MessageBuffer<Trace.TraceBean, Trace.TraceBuffer>, Trace {
+
+         private TraceBean bean;
+         private org.fusesource.hawtbuf.Buffer buffer;
+         private int size=-1;
+         private int hashCode;
+
+         private TraceBuffer(org.fusesource.hawtbuf.Buffer buffer) {
+            this.buffer = buffer;
+         }
+
+         private TraceBuffer(TraceBean bean) {
+            this.bean = bean;
+         }
+
+         public TraceBean copy() {
+            return bean().copy();
+         }
+
+         public TraceBuffer freeze() {
+            return this;
+         }
+
+         private TraceBean bean() {
+            if (bean == null) {
+               try {
+                  bean = new TraceBean().mergeUnframed(new org.fusesource.hawtbuf.proto.CodedInputStream(buffer));
+                  bean.frozen=this;
+               } catch (org.fusesource.hawtbuf.proto.InvalidProtocolBufferException e) {
+                  throw new RuntimeException(e);
+               } catch (java.io.IOException e) {
+                  throw new RuntimeException("An IOException was thrown (should never happen in this method).", e);
+               }
+            }
+            return bean;
+         }
+
+         public String toString() {
+            return bean().toString();
+         }
+
+         public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix) {
+            return bean().toString(sb, prefix);
+         }
+
+         // optional bytes message = 2;
+         public boolean hasMessage() {
+            return bean().hasMessage();
+         }
+
+         public org.fusesource.hawtbuf.AsciiBuffer getMessage() {
+            return bean().getMessage();
+         }
+
+         public org.fusesource.hawtbuf.Buffer toUnframedBuffer() {
+            if( buffer !=null ) {
+               return buffer;
+            }
+            return org.fusesource.hawtbuf.proto.MessageBufferSupport.toUnframedBuffer(this);
+         }
+
+         public org.fusesource.hawtbuf.Buffer toFramedBuffer() {
+            return org.fusesource.hawtbuf.proto.MessageBufferSupport.toFramedBuffer(this);
+         }
+
+         public byte[] toUnframedByteArray() {
+            return toUnframedBuffer().toByteArray();
+         }
+
+         public byte[] toFramedByteArray() {
+            return toFramedBuffer().toByteArray();
+         }
+
+         public void writeFramed(org.fusesource.hawtbuf.proto.CodedOutputStream output) throws java.io.IOException {
+            output.writeRawVarint32(serializedSizeUnframed());
+            writeUnframed(output);
+         }
+
+         public void writeFramed(java.io.OutputStream output) throws java.io.IOException {
+            org.fusesource.hawtbuf.proto.CodedOutputStream codedOutput = new org.fusesource.hawtbuf.proto.CodedOutputStream(output);
+            writeFramed(codedOutput);
+            codedOutput.flush();
+         }
+
+         public void writeUnframed(java.io.OutputStream output) throws java.io.IOException {
+            org.fusesource.hawtbuf.proto.CodedOutputStream codedOutput = new org.fusesource.hawtbuf.proto.CodedOutputStream(output);
+            writeUnframed(codedOutput);
+            codedOutput.flush();
+         }
+
+         public void writeUnframed(org.fusesource.hawtbuf.proto.CodedOutputStream output) throws java.io.IOException {
+            if (buffer == null) {
+               int size = serializedSizeUnframed();
+               buffer = output.getNextBuffer(size);
+               org.fusesource.hawtbuf.proto.CodedOutputStream original=null;
+               if( buffer == null ) {
+                  buffer = new org.fusesource.hawtbuf.Buffer(new byte[size]);
+                  original = output;
+                  output = new org.fusesource.hawtbuf.proto.CodedOutputStream(buffer);
+               }
+               if (bean.hasMessage()) {
+                  output.writeBytes(2, bean.getMessage());
+               }
+               if( original !=null ) {
+                  output.checkNoSpaceLeft();
+                  output = original;
+                  output.writeRawBytes(buffer);
+               }
+            } else {
+               output.writeRawBytes(buffer);
+            }
+         }
+
+         public int serializedSizeFramed() {
+            int t = serializedSizeUnframed();
+            return org.fusesource.hawtbuf.proto.CodedOutputStream.computeRawVarint32Size(t) + t;
+         }
+
+         public int serializedSizeUnframed() {
+            if (buffer != null) {
+               return buffer.length;
+            }
+            if (size != -1)
+               return size;
+
+            size = 0;
+            if (hasMessage()) {
+               size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeBytesSize(2, getMessage());
+            }
+            return size;
+         }
+
+         public static TraceBean parseUnframed(org.fusesource.hawtbuf.proto.CodedInputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
+            return new TraceBean().mergeUnframed(data);
+         }
+
+         public static TraceBean parseUnframed(java.io.InputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
+            return parseUnframed(new org.fusesource.hawtbuf.proto.CodedInputStream(data));
+         }
+
+         public static TraceBuffer parseUnframed(org.fusesource.hawtbuf.Buffer data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+            return new TraceBuffer(data);
+         }
+
+         public static TraceBuffer parseUnframed(byte[] data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+            return parseUnframed(new org.fusesource.hawtbuf.Buffer(data));
+         }
+
+         public static TraceBuffer parseFramed(org.fusesource.hawtbuf.proto.CodedInputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
+            int length = data.readRawVarint32();
+            int oldLimit = data.pushLimit(length);
+            TraceBuffer rc = parseUnframed(data.readRawBytes(length));
+            data.popLimit(oldLimit);
+            return rc;
+         }
+
+         public static TraceBuffer parseFramed(org.fusesource.hawtbuf.Buffer data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+            try {
+               org.fusesource.hawtbuf.proto.CodedInputStream input = new org.fusesource.hawtbuf.proto.CodedInputStream(data);
+               TraceBuffer rc = parseFramed(input);
+               input.checkLastTagWas(0);
+               return rc;
+            } catch (org.fusesource.hawtbuf.proto.InvalidProtocolBufferException e) {
+               throw e;
+            } catch (java.io.IOException e) {
+               throw new RuntimeException("An IOException was thrown (should never happen in this method).", e);
+            }
+         }
+
+         public static TraceBuffer parseFramed(byte[] data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+            return parseFramed(new org.fusesource.hawtbuf.Buffer(data));
+         }
+
+         public static TraceBuffer parseFramed(java.io.InputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
+            return parseUnframed(org.fusesource.hawtbuf.proto.MessageBufferSupport.readFrame(data));
+         }
+
+         public boolean equals(Object obj) {
+            if( obj==this )
+               return true;
+            
+            if( obj==null || obj.getClass()!=TraceBuffer.class )
+               return false;
+            
+            return equals((TraceBuffer)obj);
+         }
+         
+         public boolean equals(TraceBuffer obj) {
+            return toUnframedBuffer().equals(obj.toUnframedBuffer());
+         }
+         
+         public int hashCode() {
+            if( hashCode==0 ) {
+            hashCode=1406620101 ^ toUnframedBuffer().hashCode();
+            }
+            return hashCode;
+         }
+         
+         public boolean frozen() {
+            return true;
+         }
+         public Type toType() {
+            return Type.TRACE;
+         }
+
+      }
+
+   }
+
+
+   static public interface MessageAdd extends org.fusesource.hawtbuf.proto.PBMessage<MessageAdd.MessageAddBean, MessageAdd.MessageAddBuffer>, Type.TypeCreatable {
+
+      // optional int64 messageKey = 1;
+      public boolean hasMessageKey();
+      public long getMessageKey();
+      // optional bytes messageId = 2;
+      public boolean hasMessageId();
+      public org.fusesource.hawtbuf.AsciiBuffer getMessageId();
+      // optional bytes encoding = 3;
+      public boolean hasEncoding();
+      public org.fusesource.hawtbuf.AsciiBuffer getEncoding();
+      // optional bytes buffer = 4;
+      public boolean hasBuffer();
+      public org.fusesource.hawtbuf.Buffer getBuffer();
+      // optional int64 streamKey = 5;
+      public boolean hasStreamKey();
+      public long getStreamKey();
+      // optional int32 messageSize = 6;
+      public boolean hasMessageSize();
+      public int getMessageSize();
+      public MessageAddBean copy();
+      public MessageAddBuffer freeze();
+      public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix);
+
+      static public final class MessageAddBean implements MessageAdd {
+
+         MessageAddBuffer frozen;
+         MessageAddBean bean;
+
+         public MessageAddBean() {
+            this.bean = this;
+         }
+
+         public MessageAddBean(MessageAddBean copy) {
+            this.bean = copy;
+         }
+
+         public MessageAddBean copy() {
+            return new MessageAddBean(bean);
+         }
+
+         public boolean frozen() {
+            return frozen!=null;
+         }
+
+         public MessageAddBuffer freeze() {
+            if( frozen==null ) {
+               frozen = new MessageAddBuffer(bean);
+               assert deepFreeze();
+            }
+            return frozen;
+         }
+
+         private boolean deepFreeze() {
+            frozen.serializedSizeUnframed();
+            return true;
+         }
+
+         private void copyCheck() {
+            assert frozen==null : org.fusesource.hawtbuf.proto.MessageBufferSupport.FORZEN_ERROR_MESSAGE;
+            if (bean != this) {
+               copy(bean);
+            }
+         }
+
+         private void copy(MessageAddBean other) {
+            this.bean = this;
+            this.f_messageKey = other.f_messageKey;
+            this.b_messageKey = other.b_messageKey;
+            this.f_messageId = other.f_messageId;
+            this.b_messageId = other.b_messageId;
+            this.f_encoding = other.f_encoding;
+            this.b_encoding = other.b_encoding;
+            this.f_buffer = other.f_buffer;
+            this.b_buffer = other.b_buffer;
+            this.f_streamKey = other.f_streamKey;
+            this.b_streamKey = other.b_streamKey;
+            this.f_messageSize = other.f_messageSize;
+            this.b_messageSize = other.b_messageSize;
+         }
+
+         // optional int64 messageKey = 1;
+         private long f_messageKey = 0;
+         private boolean b_messageKey;
+
+         public boolean hasMessageKey() {
+            return bean.b_messageKey;
+         }
+
+         public long getMessageKey() {
+            return bean.f_messageKey;
+         }
+
+         public MessageAddBean setMessageKey(long messageKey) {
+            copyCheck();
+            this.b_messageKey = true;
+            this.f_messageKey = messageKey;
+            return this;
+         }
+
+         public void clearMessageKey() {
+            copyCheck();
+            this.b_messageKey = false;
+            this.f_messageKey = 0;
+         }
+
+         // optional bytes messageId = 2;
+         private org.fusesource.hawtbuf.AsciiBuffer f_messageId = null;
+         private boolean b_messageId;
+
+         public boolean hasMessageId() {
+            return bean.b_messageId;
+         }
+
+         public org.fusesource.hawtbuf.AsciiBuffer getMessageId() {
+            return bean.f_messageId;
+         }
+
+         public MessageAddBean setMessageId(org.fusesource.hawtbuf.AsciiBuffer messageId) {
+            copyCheck();
+            this.b_messageId = true;
+            this.f_messageId = messageId;
+            return this;
+         }
+
+         public void clearMessageId() {
+            copyCheck();
+            this.b_messageId = false;
+            this.f_messageId = null;
+         }
+
+         // optional bytes encoding = 3;
+         private org.fusesource.hawtbuf.AsciiBuffer f_encoding = null;
+         private boolean b_encoding;
+
+         public boolean hasEncoding() {
+            return bean.b_encoding;
+         }
+
+         public org.fusesource.hawtbuf.AsciiBuffer getEncoding() {
+            return bean.f_encoding;
+         }
+
+         public MessageAddBean setEncoding(org.fusesource.hawtbuf.AsciiBuffer encoding) {
+            copyCheck();
+            this.b_encoding = true;
+            this.f_encoding = encoding;
+            return this;
+         }
+
+         public void clearEncoding() {
+            copyCheck();
+            this.b_encoding = false;
+            this.f_encoding = null;
+         }
+
+         // optional bytes buffer = 4;
+         private org.fusesource.hawtbuf.Buffer f_buffer = null;
+         private boolean b_buffer;
+
+         public boolean hasBuffer() {
+            return bean.b_buffer;
+         }
+
+         public org.fusesource.hawtbuf.Buffer getBuffer() {
+            return bean.f_buffer;
+         }
+
+         public MessageAddBean setBuffer(org.fusesource.hawtbuf.Buffer buffer) {
+            copyCheck();
+            this.b_buffer = true;
+            this.f_buffer = buffer;
+            return this;
+         }
+
+         public void clearBuffer() {
+            copyCheck();
+            this.b_buffer = false;
+            this.f_buffer = null;
+         }
+
+         // optional int64 streamKey = 5;
+         private long f_streamKey = 0;
+         private boolean b_streamKey;
+
+         public boolean hasStreamKey() {
+            return bean.b_streamKey;
+         }
+
+         public long getStreamKey() {
+            return bean.f_streamKey;
+         }
+
+         public MessageAddBean setStreamKey(long streamKey) {
+            copyCheck();
+            this.b_streamKey = true;
+            this.f_streamKey = streamKey;
+            return this;
+         }
+
+         public void clearStreamKey() {
+            copyCheck();
+            this.b_streamKey = false;
+            this.f_streamKey = 0;
+         }
+
+         // optional int32 messageSize = 6;
+         private int f_messageSize = 0;
+         private boolean b_messageSize;
+
+         public boolean hasMessageSize() {
+            return bean.b_messageSize;
+         }
+
+         public int getMessageSize() {
+            return bean.f_messageSize;
+         }
+
+         public MessageAddBean setMessageSize(int messageSize) {
+            copyCheck();
+            this.b_messageSize = true;
+            this.f_messageSize = messageSize;
+            return this;
+         }
+
+         public void clearMessageSize() {
+            copyCheck();
+            this.b_messageSize = false;
+            this.f_messageSize = 0;
+         }
+
+         public String toString() {
+            return toString(new java.lang.StringBuilder(), "").toString();
+         }
+
+         public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix) {
+            if(  hasMessageKey() ) {
+               sb.append(prefix+"messageKey: ");
+               sb.append(getMessageKey());
+               sb.append("\n");
+            }
+            if(  hasMessageId() ) {
+               sb.append(prefix+"messageId: ");
+               sb.append(getMessageId());
+               sb.append("\n");
+            }
+            if(  hasEncoding() ) {
+               sb.append(prefix+"encoding: ");
+               sb.append(getEncoding());
+               sb.append("\n");
+            }
+            if(  hasBuffer() ) {
+               sb.append(prefix+"buffer: ");
+               sb.append(getBuffer());
+               sb.append("\n");
+            }
+            if(  hasStreamKey() ) {
+               sb.append(prefix+"streamKey: ");
+               sb.append(getStreamKey());
+               sb.append("\n");
+            }
+            if(  hasMessageSize() ) {
+               sb.append(prefix+"messageSize: ");
+               sb.append(getMessageSize());
+               sb.append("\n");
+            }
+            return sb;
+         }
+
+         public MessageAddBean mergeUnframed(java.io.InputStream input) throws java.io.IOException {
+            return mergeUnframed(new org.fusesource.hawtbuf.proto.CodedInputStream(input));
+         }
+
+         public MessageAddBean mergeUnframed(org.fusesource.hawtbuf.proto.CodedInputStream input) throws java.io.IOException {
+            copyCheck();
+            while (true) {
+               int tag = input.readTag();
+               if ((tag & 0x07) == 4) {
+                  return this;
+               }
+               switch (tag) {
+               case 0:
+                  return this;
+               default: {
+                  break;
+               }
+               case 8:
+                  setMessageKey(input.readInt64());
+                  break;
+               case 18:
+                  setMessageId(new org.fusesource.hawtbuf.AsciiBuffer(input.readBytes()));
+                  break;
+               case 26:
+                  setEncoding(new org.fusesource.hawtbuf.AsciiBuffer(input.readBytes()));
+                  break;
+               case 34:
+                  setBuffer(input.readBytes());
+                  break;
+               case 40:
+                  setStreamKey(input.readInt64());
+                  break;
+               case 48:
+                  setMessageSize(input.readInt32());
+                  break;
+               }
+            }
+         }
+         public boolean equals(Object obj) {
+            if( obj==this )
+               return true;
+            
+            if( obj==null || obj.getClass()!=MessageAddBean.class )
+               return false;
+            
+            return equals((MessageAddBean)obj);
+         }
+         
+         public boolean equals(MessageAddBean obj) {
+            if (hasMessageKey() ^ obj.hasMessageKey() ) 
+               return false;
+            if (hasMessageKey() && ( getMessageKey()!=obj.getMessageKey() ))
+               return false;
+            if (hasMessageId() ^ obj.hasMessageId() ) 
+               return false;
+            if (hasMessageId() && ( !getMessageId().equals(obj.getMessageId()) ))
+               return false;
+            if (hasEncoding() ^ obj.hasEncoding() ) 
+               return false;
+            if (hasEncoding() && ( !getEncoding().equals(obj.getEncoding()) ))
+               return false;
+            if (hasBuffer() ^ obj.hasBuffer() ) 
+               return false;
+            if (hasBuffer() && ( !getBuffer().equals(obj.getBuffer()) ))
+               return false;
+            if (hasStreamKey() ^ obj.hasStreamKey() ) 
+               return false;
+            if (hasStreamKey() && ( getStreamKey()!=obj.getStreamKey() ))
+               return false;
+            if (hasMessageSize() ^ obj.hasMessageSize() ) 
+               return false;
+            if (hasMessageSize() && ( getMessageSize()!=obj.getMessageSize() ))
+               return false;
+            return true;
+         }
+         
+         public int hashCode() {
+            int rc=-1294047734;
+            if (hasMessageKey()) {
+               rc ^= ( 302723320^(new Long(getMessageKey())).hashCode() );
+            }
+            if (hasMessageId()) {
+               rc ^= ( 563954530^getMessageId().hashCode() );
+            }
+            if (hasEncoding()) {
+               rc ^= ( 1775866227^getEncoding().hashCode() );
+            }
+            if (hasBuffer()) {
+               rc ^= ( 2000715872^getBuffer().hashCode() );
+            }
+            if (hasStreamKey()) {
+               rc ^= ( 1688323743^(new Long(getStreamKey())).hashCode() );
+            }
+            if (hasMessageSize()) {
+               rc ^= ( 794730632^getMessageSize() );
+            }
+            return rc;
+         }
+         
+         public MessageAddBean mergeFrom(MessageAdd other) {
+            copyCheck();
+            if (other.hasMessageKey()) {
+               setMessageKey(other.getMessageKey());
+            }
+            if (other.hasMessageId()) {
+               setMessageId(other.getMessageId());
+            }
+            if (other.hasEncoding()) {
+               setEncoding(other.getEncoding());
+            }
+            if (other.hasBuffer()) {
+               setBuffer(other.getBuffer());
+            }
+            if (other.hasStreamKey()) {
+               setStreamKey(other.getStreamKey());
+            }
+            if (other.hasMessageSize()) {
+               setMessageSize(other.getMessageSize());
+            }
+            return this;
+         }
+
+         public void clear() {
+            clearMessageKey();
+            clearMessageId();
+            clearEncoding();
+            clearBuffer();
+            clearStreamKey();
+            clearMessageSize();
+         }
+
+         public void readExternal(java.io.DataInput in) throws java.io.IOException {
+            assert frozen==null : org.fusesource.hawtbuf.proto.MessageBufferSupport.FORZEN_ERROR_MESSAGE;
+            bean = this;
+            frozen = null;
+            f_messageKey = in.readLong();
+            b_messageKey = true;
+            {
+               int size = in.readInt();
+               if( size>=0 ) {
+                  byte b[] = new byte[size];
+                  in.readFully(b);
+                  f_messageId = new org.fusesource.hawtbuf.AsciiBuffer(b);
+                  b_messageId = true;
+               } else {
+                  f_messageId = null;
+                  b_messageId = false;
+               }
+            }
+            {
+               int size = in.readInt();
+               if( size>=0 ) {
+                  byte b[] = new byte[size];
+                  in.readFully(b);
+                  f_encoding = new org.fusesource.hawtbuf.AsciiBuffer(b);
+                  b_encoding = true;
+               } else {
+                  f_encoding = null;
+                  b_encoding = false;
+               }
+            }
+            {
+               int size = in.readInt();
+               if( size>=0 ) {
+                  byte b[] = new byte[size];
+                  in.readFully(b);
+                  f_buffer = new org.fusesource.hawtbuf.Buffer(b);
+                  b_buffer = true;
+               } else {
+                  f_buffer = null;
+                  b_buffer = false;
+               }
+            }
+            f_streamKey = in.readLong();
+            b_streamKey = true;
+            f_messageSize = in.readInt();
+            b_messageSize = true;
+         }
+
+         public void writeExternal(java.io.DataOutput out) throws java.io.IOException {
+            out.writeLong(bean.f_messageKey);
+            if( bean.f_messageId!=null ) {
+               out.writeInt(bean.f_messageId.getLength());
+               out.write(bean.f_messageId.getData(), bean.f_messageId.getOffset(), bean.f_messageId.getLength());
+            } else {
+               out.writeInt(-1);
+            }
+            if( bean.f_encoding!=null ) {
+               out.writeInt(bean.f_encoding.getLength());
+               out.write(bean.f_encoding.getData(), bean.f_encoding.getOffset(), bean.f_encoding.getLength());
+            } else {
+               out.writeInt(-1);
+            }
+            if( bean.f_buffer!=null ) {
+               out.writeInt(bean.f_buffer.getLength());
+               out.write(bean.f_buffer.getData(), bean.f_buffer.getOffset(), bean.f_buffer.getLength());
+            } else {
+               out.writeInt(-1);
+            }
+            out.writeLong(bean.f_streamKey);
+            out.writeInt(bean.f_messageSize);
+         }
+
+         public Type toType() {
+            return Type.MESSAGE_ADD;
+         }
+
+      }
+
+      static public final class MessageAddBuffer implements org.fusesource.hawtbuf.proto.MessageBuffer<MessageAdd.MessageAddBean, MessageAdd.MessageAddBuffer>, MessageAdd {
+
+         private MessageAddBean bean;
+         private org.fusesource.hawtbuf.Buffer buffer;
+         private int size=-1;
+         private int hashCode;
+
+         private MessageAddBuffer(org.fusesource.hawtbuf.Buffer buffer) {
+            this.buffer = buffer;
+         }
+
+         private MessageAddBuffer(MessageAddBean bean) {
+            this.bean = bean;
+         }
+
+         public MessageAddBean copy() {
+            return bean().copy();
+         }
+
+         public MessageAddBuffer freeze() {
+            return this;
+         }
+
+         private MessageAddBean bean() {
+            if (bean == null) {
+               try {
+                  bean = new MessageAddBean().mergeUnframed(new org.fusesource.hawtbuf.proto.CodedInputStream(buffer));
+                  bean.frozen=this;
+               } catch (org.fusesource.hawtbuf.proto.InvalidProtocolBufferException e) {
+                  throw new RuntimeException(e);
+               } catch (java.io.IOException e) {
+                  throw new RuntimeException("An IOException was thrown (should never happen in this method).", e);
+               }
+            }
+            return bean;
+         }
+
+         public String toString() {
+            return bean().toString();
+         }
+
+         public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix) {
+            return bean().toString(sb, prefix);
+         }
+
+         // optional int64 messageKey = 1;
+         public boolean hasMessageKey() {
+            return bean().hasMessageKey();
+         }
+
+         public long getMessageKey() {
+            return bean().getMessageKey();
+         }
+
+         // optional bytes messageId = 2;
+         public boolean hasMessageId() {
+            return bean().hasMessageId();
+         }
+
+         public org.fusesource.hawtbuf.AsciiBuffer getMessageId() {
+            return bean().getMessageId();
+         }
+
+         // optional bytes encoding = 3;
+         public boolean hasEncoding() {
+            return bean().hasEncoding();
+         }
+
+         public org.fusesource.hawtbuf.AsciiBuffer getEncoding() {
+            return bean().getEncoding();
+         }
+
+         // optional bytes buffer = 4;
+         public boolean hasBuffer() {
+            return bean().hasBuffer();
+         }
+
+         public org.fusesource.hawtbuf.Buffer getBuffer() {
+            return bean().getBuffer();
+         }
+
+         // optional int64 streamKey = 5;
+         public boolean hasStreamKey() {
+            return bean().hasStreamKey();
+         }
+
+         public long getStreamKey() {
+            return bean().getStreamKey();
+         }
+
+         // optional int32 messageSize = 6;
+         public boolean hasMessageSize() {
+            return bean().hasMessageSize();
+         }
+
+         public int getMessageSize() {
+            return bean().getMessageSize();
+         }
+
+         public org.fusesource.hawtbuf.Buffer toUnframedBuffer() {
+            if( buffer !=null ) {
+               return buffer;
+            }
+            return org.fusesource.hawtbuf.proto.MessageBufferSupport.toUnframedBuffer(this);
+         }
+
+         public org.fusesource.hawtbuf.Buffer toFramedBuffer() {
+            return org.fusesource.hawtbuf.proto.MessageBufferSupport.toFramedBuffer(this);
+         }
+
+         public byte[] toUnframedByteArray() {
+            return toUnframedBuffer().toByteArray();
+         }
+
+         public byte[] toFramedByteArray() {
+            return toFramedBuffer().toByteArray();
+         }
+
+         public void writeFramed(org.fusesource.hawtbuf.proto.CodedOutputStream output) throws java.io.IOException {
+            output.writeRawVarint32(serializedSizeUnframed());
+            writeUnframed(output);
+         }
+
+         public void writeFramed(java.io.OutputStream output) throws java.io.IOException {
+            org.fusesource.hawtbuf.proto.CodedOutputStream codedOutput = new org.fusesource.hawtbuf.proto.CodedOutputStream(output);
+            writeFramed(codedOutput);
+            codedOutput.flush();
+         }
+
+         public void writeUnframed(java.io.OutputStream output) throws java.io.IOException {
+            org.fusesource.hawtbuf.proto.CodedOutputStream codedOutput = new org.fusesource.hawtbuf.proto.CodedOutputStream(output);
+            writeUnframed(codedOutput);
+            codedOutput.flush();
+         }
+
+         public void writeUnframed(org.fusesource.hawtbuf.proto.CodedOutputStream output) throws java.io.IOException {
+            if (buffer == null) {
+               int size = serializedSizeUnframed();
+               buffer = output.getNextBuffer(size);
+               org.fusesource.hawtbuf.proto.CodedOutputStream original=null;
+               if( buffer == null ) {
+                  buffer = new org.fusesource.hawtbuf.Buffer(new byte[size]);
+                  original = output;
+                  output = new org.fusesource.hawtbuf.proto.CodedOutputStream(buffer);
+               }
+               if (bean.hasMessageKey()) {
+                  output.writeInt64(1, bean.getMessageKey());
+               }
+               if (bean.hasMessageId()) {
+                  output.writeBytes(2, bean.getMessageId());
+               }
+               if (bean.hasEncoding()) {
+                  output.writeBytes(3, bean.getEncoding());
+               }
+               if (bean.hasBuffer()) {
+                  output.writeBytes(4, bean.getBuffer());
+               }
+               if (bean.hasStreamKey()) {
+                  output.writeInt64(5, bean.getStreamKey());
+               }
+               if (bean.hasMessageSize()) {
+                  output.writeInt32(6, bean.getMessageSize());
+               }
+               if( original !=null ) {
+                  output.checkNoSpaceLeft();
+                  output = original;
+                  output.writeRawBytes(buffer);
+               }
+            } else {
+               output.writeRawBytes(buffer);
+            }
+         }
+
+         public int serializedSizeFramed() {
+            int t = serializedSizeUnframed();
+            return org.fusesource.hawtbuf.proto.CodedOutputStream.computeRawVarint32Size(t) + t;
+         }
+
+         public int serializedSizeUnframed() {
+            if (buffer != null) {
+               return buffer.length;
+            }
+            if (size != -1)
+               return size;
+
+            size = 0;
+            if (hasMessageKey()) {
+               size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeInt64Size(1, getMessageKey());
+            }
+            if (hasMessageId()) {
+               size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeBytesSize(2, getMessageId());
+            }
+            if (hasEncoding()) {
+               size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeBytesSize(3, getEncoding());
+            }
+            if (hasBuffer()) {
+               size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeBytesSize(4, getBuffer());
+            }
+            if (hasStreamKey()) {
+               size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeInt64Size(5, getStreamKey());
+            }
+            if (hasMessageSize()) {
+               size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeInt32Size(6, getMessageSize());
+            }
+            return size;
+         }
+
+         public static MessageAddBean parseUnframed(org.fusesource.hawtbuf.proto.CodedInputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
+            return new MessageAddBean().mergeUnframed(data);
+         }
+
+         public static MessageAddBean parseUnframed(java.io.InputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
+            return parseUnframed(new org.fusesource.hawtbuf.proto.CodedInputStream(data));
+         }
+
+         public static MessageAddBuffer parseUnframed(org.fusesource.hawtbuf.Buffer data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+            return new MessageAddBuffer(data);
+         }
+
+         public static MessageAddBuffer parseUnframed(byte[] data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+            return parseUnframed(new org.fusesource.hawtbuf.Buffer(data));
+         }
+
+         public static MessageAddBuffer parseFramed(org.fusesource.hawtbuf.proto.CodedInputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
+            int length = data.readRawVarint32();
+            int oldLimit = data.pushLimit(length);
+            MessageAddBuffer rc = parseUnframed(data.readRawBytes(length));
+            data.popLimit(oldLimit);
+            return rc;
+         }
+
+         public static MessageAddBuffer parseFramed(org.fusesource.hawtbuf.Buffer data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+            try {
+               org.fusesource.hawtbuf.proto.CodedInputStream input = new org.fusesource.hawtbuf.proto.CodedInputStream(data);
+               MessageAddBuffer rc = parseFramed(input);
+               input.checkLastTagWas(0);
+               return rc;
+            } catch (org.fusesource.hawtbuf.proto.InvalidProtocolBufferException e) {
+               throw e;
+            } catch (java.io.IOException e) {
+               throw new RuntimeException("An IOException was thrown (should never happen in this method).", e);
+            }
+         }
+
+         public static MessageAddBuffer parseFramed(byte[] data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+            return parseFramed(new org.fusesource.hawtbuf.Buffer(data));
+         }
+
+         public static MessageAddBuffer parseFramed(java.io.InputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
+            return parseUnframed(org.fusesource.hawtbuf.proto.MessageBufferSupport.readFrame(data));
+         }
+
+         public boolean equals(Object obj) {
+            if( obj==this )
+               return true;
+            
+            if( obj==null || obj.getClass()!=MessageAddBuffer.class )
+               return false;
+            
+            return equals((MessageAddBuffer)obj);
+         }
+         
+         public boolean equals(MessageAddBuffer obj) {
+            return toUnframedBuffer().equals(obj.toUnframedBuffer());
+         }
+         
+         public int hashCode() {
+            if( hashCode==0 ) {
+            hashCode=1975564314 ^ toUnframedBuffer().hashCode();
+            }
+            return hashCode;
+         }
+         
+         public boolean frozen() {
+            return true;
+         }
+         public Type toType() {
+            return Type.MESSAGE_ADD;
+         }
+
+      }
+
+   }
+
+
+   static public interface QueueAdd extends org.fusesource.hawtbuf.proto.PBMessage<QueueAdd.QueueAddBean, QueueAdd.QueueAddBuffer>, Type.TypeCreatable {
+
+      // optional bytes queueName = 1;
+      public boolean hasQueueName();
+      public org.fusesource.hawtbuf.AsciiBuffer getQueueName();
+      // optional int32 applicationType = 2;
+      public boolean hasApplicationType();
+      public int getApplicationType();
+      // optional bytes parentName = 3;
+      public boolean hasParentName();
+      public org.fusesource.hawtbuf.AsciiBuffer getParentName();
+      // optional int32 queueType = 4;
+      public boolean hasQueueType();
+      public int getQueueType();
+      // optional int32 partitionId = 5;
+      public boolean hasPartitionId();
+      public int getPartitionId();
+      public QueueAddBean copy();
+      public QueueAddBuffer freeze();
+      public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix);
+
+      static public final class QueueAddBean implements QueueAdd {
+
+         QueueAddBuffer frozen;
+         QueueAddBean bean;
+
+         public QueueAddBean() {
+            this.bean = this;
+         }
+
+         public QueueAddBean(QueueAddBean copy) {
+            this.bean = copy;
+         }
+
+         public QueueAddBean copy() {
+            return new QueueAddBean(bean);
+         }
+
+         public boolean frozen() {
+            return frozen!=null;
+         }
+
+         public QueueAddBuffer freeze() {
+            if( frozen==null ) {
+               frozen = new QueueAddBuffer(bean);
+               assert deepFreeze();
+            }
+            return frozen;
+         }
+
+         private boolean deepFreeze() {
+            frozen.serializedSizeUnframed();
+            return true;
+         }
+
+         private void copyCheck() {
+            assert frozen==null : org.fusesource.hawtbuf.proto.MessageBufferSupport.FORZEN_ERROR_MESSAGE;
+            if (bean != this) {
+               copy(bean);
+            }
+         }
+
+         private void copy(QueueAddBean other) {
+            this.bean = this;
+            this.f_queueName = other.f_queueName;
+            this.b_queueName = other.b_queueName;
+            this.f_applicationType = other.f_applicationType;
+            this.b_applicationType = other.b_applicationType;
+            this.f_parentName = other.f_parentName;
+            this.b_parentName = other.b_parentName;
+            this.f_queueType = other.f_queueType;
+            this.b_queueType = other.b_queueType;
+            this.f_partitionId = other.f_partitionId;
+            this.b_partitionId = other.b_partitionId;
+         }
+
+         // optional bytes queueName = 1;
+         private org.fusesource.hawtbuf.AsciiBuffer f_queueName = null;
+         private boolean b_queueName;
+
+         public boolean hasQueueName() {
+            return bean.b_queueName;
+         }
+
+         public org.fusesource.hawtbuf.AsciiBuffer getQueueName() {
+            return bean.f_queueName;
+         }
+
+         public QueueAddBean setQueueName(org.fusesource.hawtbuf.AsciiBuffer queueName) {
+            copyCheck();
+            this.b_queueName = true;
+            this.f_queueName = queueName;
+            return this;
+         }
+
+         public void clearQueueName() {
+            copyCheck();
+            this.b_queueName = false;
+            this.f_queueName = null;
+         }
+
+         // optional int32 applicationType = 2;
+         private int f_applicationType = 0;
+         private boolean b_applicationType;
+
+         public boolean hasApplicationType() {
+            return bean.b_applicationType;
+         }
+
+         public int getApplicationType() {
+            return bean.f_applicationType;
+         }
+
+         public QueueAddBean setApplicationType(int applicationType) {
+            copyCheck();
+            this.b_applicationType = true;
+            this.f_applicationType = applicationType;
+            return this;
+         }
+
+         public void clearApplicationType() {
+            copyCheck();
+            this.b_applicationType = false;
+            this.f_applicationType = 0;
+         }
+
+         // optional bytes parentName = 3;
+         private org.fusesource.hawtbuf.AsciiBuffer f_parentName = null;
+         private boolean b_parentName;
+
+         public boolean hasParentName() {
+            return bean.b_parentName;
+         }
+
+         public org.fusesource.hawtbuf.AsciiBuffer getParentName() {
+            return bean.f_parentName;
+         }
+
+         public QueueAddBean setParentName(org.fusesource.hawtbuf.AsciiBuffer parentName) {
+            copyCheck();
+            this.b_parentName = true;
+            this.f_parentName = parentName;
+            return this;
+         }
+
+         public void clearParentName() {
+            copyCheck();
+            this.b_parentName = false;
+            this.f_parentName = null;
+         }
+
+         // optional int32 queueType = 4;
+         private int f_queueType = 0;
+         private boolean b_queueType;
+
+         public boolean hasQueueType() {
+            return bean.b_queueType;
+         }
+
+         public int getQueueType() {
+            return bean.f_queueType;
+         }
+
+         public QueueAddBean setQueueType(int queueType) {
+            copyCheck();
+            this.b_queueType = true;
+            this.f_queueType = queueType;
+            return this;
+         }
+
+         public void clearQueueType() {
+            copyCheck();
+            this.b_queueType = false;
+            this.f_queueType = 0;
+         }
+
+         // optional int32 partitionId = 5;
+         private int f_partitionId = 0;
+         private boolean b_partitionId;
+
+         public boolean hasPartitionId() {
+            return bean.b_partitionId;
+         }
+
+         public int getPartitionId() {
+            return bean.f_partitionId;
+         }
+
+         public QueueAddBean setPartitionId(int partitionId) {
+            copyCheck();
+            this.b_partitionId = true;
+            this.f_partitionId = partitionId;
+            return this;
+         }
+
+         public void clearPartitionId() {
+            copyCheck();
+            this.b_partitionId = false;
+            this.f_partitionId = 0;
+         }
+
+         public String toString() {
+            return toString(new java.lang.StringBuilder(), "").toString();
+         }
+
+         public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix) {
+            if(  hasQueueName() ) {
+               sb.append(prefix+"queueName: ");
+               sb.append(getQueueName());
+               sb.append("\n");
+            }
+            if(  hasApplicationType() ) {
+               sb.append(prefix+"applicationType: ");
+               sb.append(getApplicationType());
+               sb.append("\n");
+            }
+            if(  hasParentName() ) {
+               sb.append(prefix+"parentName: ");
+               sb.append(getParentName());
+               sb.append("\n");
+            }
+            if(  hasQueueType() ) {
+               sb.append(prefix+"queueType: ");
+               sb.append(getQueueType());
+               sb.append("\n");
+            }
+            if(  hasPartitionId() ) {
+               sb.append(prefix+"partitionId: ");
+               sb.append(getPartitionId());
+               sb.append("\n");
+            }
+            return sb;
+         }
+
+         public QueueAddBean mergeUnframed(java.io.InputStream input) throws java.io.IOException {
+            return mergeUnframed(new org.fusesource.hawtbuf.proto.CodedInputStream(input));
+         }
+
+         public QueueAddBean mergeUnframed(org.fusesource.hawtbuf.proto.CodedInputStream input) throws java.io.IOException {
+            copyCheck();
+            while (true) {
+               int tag = input.readTag();
+               if ((tag & 0x07) == 4) {
+                  return this;
+               }
+               switch (tag) {
+               case 0:
+                  return this;
+               default: {
+                  break;
+               }
+               case 10:
+                  setQueueName(new org.fusesource.hawtbuf.AsciiBuffer(input.readBytes()));
+                  break;
+               case 16:
+                  setApplicationType(input.readInt32());
+                  break;
+               case 26:
+                  setParentName(new org.fusesource.hawtbuf.AsciiBuffer(input.readBytes()));
+                  break;
+               case 32:
+                  setQueueType(input.readInt32());
+                  break;
+               case 40:
+                  setPartitionId(input.readInt32());
+                  break;
+               }
+            }
+         }
+         public boolean equals(Object obj) {
+            if( obj==this )
+               return true;
+            
+            if( obj==null || obj.getClass()!=QueueAddBean.class )
+               return false;
+            
+            return equals((QueueAddBean)obj);
+         }
+         
+         public boolean equals(QueueAddBean obj) {
+            if (hasQueueName() ^ obj.hasQueueName() ) 
+               return false;
+            if (hasQueueName() && ( !getQueueName().equals(obj.getQueueName()) ))
+               return false;
+            if (hasApplicationType() ^ obj.hasApplicationType() ) 
+               return false;
+            if (hasApplicationType() && ( getApplicationType()!=obj.getApplicationType() ))
+               return false;
+            if (hasParentName() ^ obj.hasParentName() ) 
+               return false;
+            if (hasParentName() && ( !getParentName().equals(obj.getParentName()) ))
+               return false;
+            if (hasQueueType() ^ obj.hasQueueType() ) 
+               return false;
+            if (hasQueueType() && ( getQueueType()!=obj.getQueueType() ))
+               return false;
+            if (hasPartitionId() ^ obj.hasPartitionId() ) 
+               return false;
+            if (hasPartitionId() && ( getPartitionId()!=obj.getPartitionId() ))
+               return false;
+            return true;
+         }
+         
+         public int hashCode() {
+            int rc=-1165199936;
+            if (hasQueueName()) {
+               rc ^= ( 264320796^getQueueName().hashCode() );
+            }
+            if (hasApplicationType()) {
+               rc ^= ( 2050726026^getApplicationType() );
+            }
+            if (hasParentName()) {
+               rc ^= ( 1748594293^getParentName().hashCode() );
+            }
+            if (hasQueueType()) {
+               rc ^= ( 264522699^getQueueType() );
+            }
+            if (hasPartitionId()) {
+               rc ^= ( -1372999291^getPartitionId() );
+            }
+            return rc;
+         }
+         
+         public QueueAddBean mergeFrom(QueueAdd other) {
+            copyCheck();
+            if (other.hasQueueName()) {
+               setQueueName(other.getQueueName());
+            }
+            if (other.hasApplicationType()) {
+               setApplicationType(other.getApplicationType());
+            }
+            if (other.hasParentName()) {
+               setParentName(other.getParentName());
+            }
+            if (other.hasQueueType()) {
+               setQueueType(other.getQueueType());
+            }
+            if (other.hasPartitionId()) {
+               setPartitionId(other.getPartitionId());
+            }
+            return this;
+         }
+
+         public void clear() {
+            clearQueueName();
+            clearApplicationType();
+            clearParentName();
+            clearQueueType();
+            clearPartitionId();
+         }
+
+         public void readExternal(java.io.DataInput in) throws java.io.IOException {
+            assert frozen==null : org.fusesource.hawtbuf.proto.MessageBufferSupport.FORZEN_ERROR_MESSAGE;
+            bean = this;
+            frozen = null;
+            {
+               int size = in.readInt();
+               if( size>=0 ) {
+                  byte b[] = new byte[size];
+                  in.readFully(b);
+                  f_queueName = new org.fusesource.hawtbuf.AsciiBuffer(b);
+                  b_queueName = true;
+               } else {
+                  f_queueName = null;
+                  b_queueName = false;
+               }
+            }
+            f_applicationType = in.readInt();
+            b_applicationType = true;
+            {
+               int size = in.readInt();
+               if( size>=0 ) {
+                  byte b[] = new byte[size];
+                  in.readFully(b);
+                  f_parentName = new org.fusesource.hawtbuf.AsciiBuffer(b);
+                  b_parentName = true;
+               } else {
+                  f_parentName = null;
+                  b_parentName = false;
+               }
+            }
+            f_queueType = in.readInt();
+            b_queueType = true;
+            f_partitionId = in.readInt();
+            b_partitionId = true;
+         }
+
+         public void writeExternal(java.io.DataOutput out) throws java.io.IOException {
+            if( bean.f_queueName!=null ) {
+               out.writeInt(bean.f_queueName.getLength());
+               out.write(bean.f_queueName.getData(), bean.f_queueName.getOffset(), bean.f_queueName.getLength());
+            } else {
+               out.writeInt(-1);
+            }
+            out.writeInt(bean.f_applicationType);
+            if( bean.f_parentName!=null ) {
+               out.writeInt(bean.f_parentName.getLength());
+               out.write(bean.f_parentName.getData(), bean.f_parentName.getOffset(), bean.f_parentName.getLength());
+            } else {
+               out.writeInt(-1);
+            }
+            out.writeInt(bean.f_queueType);
+            out.writeInt(bean.f_partitionId);
+         }
+
+         public Type toType() {
+            return Type.QUEUE_ADD;
+         }
+
+      }
+
+      static public final class QueueAddBuffer implements org.fusesource.hawtbuf.proto.MessageBuffer<QueueAdd.QueueAddBean, QueueAdd.QueueAddBuffer>, QueueAdd {
+
+         private QueueAddBean bean;
+         private org.fusesource.hawtbuf.Buffer buffer;
+         private int size=-1;
+         private int hashCode;
+
+         private QueueAddBuffer(org.fusesource.hawtbuf.Buffer buffer) {
+            this.buffer = buffer;
+         }
+
+         private QueueAddBuffer(QueueAddBean bean) {
+            this.bean = bean;
+         }
+
+         public QueueAddBean copy() {
+            return bean().copy();
+         }
+
+         public QueueAddBuffer freeze() {
+            return this;
+         }
+
+         private QueueAddBean bean() {
+            if (bean == null) {
+               try {
+                  bean = new QueueAddBean().mergeUnframed(new org.fusesource.hawtbuf.proto.CodedInputStream(buffer));
+                  bean.frozen=this;
+               } catch (org.fusesource.hawtbuf.proto.InvalidProtocolBufferException e) {
+                  throw new RuntimeException(e);
+               } catch (java.io.IOException e) {
+                  throw new RuntimeException("An IOException was thrown (should never happen in this method).", e);
+               }
+            }
+            return bean;
+         }
+
+         public String toString() {
+            return bean().toString();
+         }
+
+         public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix) {
+            return bean().toString(sb, prefix);
+         }
+
+         // optional bytes queueName = 1;
+         public boolean hasQueueName() {
+            return bean().hasQueueName();
+         }
+
+         public org.fusesource.hawtbuf.AsciiBuffer getQueueName() {
+            return bean().getQueueName();
+         }
+
+         // optional int32 applicationType = 2;
+         public boolean hasApplicationType() {
+            return bean().hasApplicationType();
+         }
+
+         public int getApplicationType() {
+            return bean().getApplicationType();
+         }
+
+         // optional bytes parentName = 3;
+         public boolean hasParentName() {
+            return bean().hasParentName();
+         }
+
+         public org.fusesource.hawtbuf.AsciiBuffer getParentName() {
+            return bean().getParentName();
+         }
+
+         // optional int32 queueType = 4;
+         public boolean hasQueueType() {
+            return bean().hasQueueType();
+         }
+
+         public int getQueueType() {
+            return bean().getQueueType();
+         }
+
+         // optional int32 partitionId = 5;
+         public boolean hasPartitionId() {
+            return bean().hasPartitionId();
+         }
+
+         public int getPartitionId() {
+            return bean().getPartitionId();
+         }
+
+         public org.fusesource.hawtbuf.Buffer toUnframedBuffer() {
+            if( buffer !=null ) {
+               return buffer;
+            }
+            return org.fusesource.hawtbuf.proto.MessageBufferSupport.toUnframedBuffer(this);
+         }
+
+         public org.fusesource.hawtbuf.Buffer toFramedBuffer() {
+            return org.fusesource.hawtbuf.proto.MessageBufferSupport.toFramedBuffer(this);
+         }
+
+         public byte[] toUnframedByteArray() {
+            return toUnframedBuffer().toByteArray();
+         }
+
+         public byte[] toFramedByteArray() {
+            return toFramedBuffer().toByteArray();
+         }
+
+         public void writeFramed(org.fusesource.hawtbuf.proto.CodedOutputStream output) throws java.io.IOException {
+            output.writeRawVarint32(serializedSizeUnframed());
+            writeUnframed(output);
+         }
+
+         public void writeFramed(java.io.OutputStream output) throws java.io.IOException {
+            org.fusesource.hawtbuf.proto.CodedOutputStream codedOutput = new org.fusesource.hawtbuf.proto.CodedOutputStream(output);
+            writeFramed(codedOutput);
+            codedOutput.flush();
+         }
+
+         public void writeUnframed(java.io.OutputStream output) throws java.io.IOException {
+            org.fusesource.hawtbuf.proto.CodedOutputStream codedOutput = new org.fusesource.hawtbuf.proto.CodedOutputStream(output);
+            writeUnframed(codedOutput);
+            codedOutput.flush();
+         }
+
+         public void writeUnframed(org.fusesource.hawtbuf.proto.CodedOutputStream output) throws java.io.IOException {
+            if (buffer == null) {
+               int size = serializedSizeUnframed();
+               buffer = output.getNextBuffer(size);
+               org.fusesource.hawtbuf.proto.CodedOutputStream original=null;
+               if( buffer == null ) {
+                  buffer = new org.fusesource.hawtbuf.Buffer(new byte[size]);
+                  original = output;
+                  output = new org.fusesource.hawtbuf.proto.CodedOutputStream(buffer);
+               }
+               if (bean.hasQueueName()) {
+                  output.writeBytes(1, bean.getQueueName());
+               }
+               if (bean.hasApplicationType()) {
+                  output.writeInt32(2, bean.getApplicationType());
+               }
+               if (bean.hasParentName()) {
+                  output.writeBytes(3, bean.getParentName());
+               }
+               if (bean.hasQueueType()) {
+                  output.writeInt32(4, bean.getQueueType());
+               }
+               if (bean.hasPartitionId()) {
+                  output.writeInt32(5, bean.getPartitionId());
+               }
+               if( original !=null ) {
+                  output.checkNoSpaceLeft();
+                  output = original;
+                  output.writeRawBytes(buffer);
+               }
+            } else {
+               output.writeRawBytes(buffer);
+            }
+         }
+
+         public int serializedSizeFramed() {
+            int t = serializedSizeUnframed();
+            return org.fusesource.hawtbuf.proto.CodedOutputStream.computeRawVarint32Size(t) + t;
+         }
+
+         public int serializedSizeUnframed() {
+            if (buffer != null) {
+               return buffer.length;
+            }
+            if (size != -1)
+               return size;
+
+            size = 0;
+            if (hasQueueName()) {
+               size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeBytesSize(1, getQueueName());
+            }
+            if (hasApplicationType()) {
+               size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeInt32Size(2, getApplicationType());
+            }
+            if (hasParentName()) {
+               size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeBytesSize(3, getParentName());
+            }
+            if (hasQueueType()) {
+               size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeInt32Size(4, getQueueType());
+            }
+            if (hasPartitionId()) {
+               size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeInt32Size(5, getPartitionId());
+            }
+            return size;
+         }
+
+         public static QueueAddBean parseUnframed(org.fusesource.hawtbuf.proto.CodedInputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
+            return new QueueAddBean().mergeUnframed(data);
+         }
+
+         public static QueueAddBean parseUnframed(java.io.InputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
+            return parseUnframed(new org.fusesource.hawtbuf.proto.CodedInputStream(data));
+         }
+
+         public static QueueAddBuffer parseUnframed(org.fusesource.hawtbuf.Buffer data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+            return new QueueAddBuffer(data);
+         }
+
+         public static QueueAddBuffer parseUnframed(byte[] data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+            return parseUnframed(new org.fusesource.hawtbuf.Buffer(data));
+         }
+
+         public static QueueAddBuffer parseFramed(org.fusesource.hawtbuf.proto.CodedInputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
+            int length = data.readRawVarint32();
+            int oldLimit = data.pushLimit(length);
+            QueueAddBuffer rc = parseUnframed(data.readRawBytes(length));
+            data.popLimit(oldLimit);
+            return rc;
+         }
+
+         public static QueueAddBuffer parseFramed(org.fusesource.hawtbuf.Buffer data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+            try {
+               org.fusesource.hawtbuf.proto.CodedInputStream input = new org.fusesource.hawtbuf.proto.CodedInputStream(data);
+               QueueAddBuffer rc = parseFramed(input);
+               input.checkLastTagWas(0);
+               return rc;
+            } catch (org.fusesource.hawtbuf.proto.InvalidProtocolBufferException e) {
+               throw e;
+            } catch (java.io.IOException e) {
+               throw new RuntimeException("An IOException was thrown (should never happen in this method).", e);
+            }
+         }
+
+         public static QueueAddBuffer parseFramed(byte[] data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
+            return parseFramed(new org.fusesource.hawtbuf.Buffer(data));
+         }
+
+         public static QueueAddBuffer parseFramed(java.io.InputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
+            return parseUnframed(org.fusesource.hawtbuf.proto.MessageBufferSupport.readFrame(data));
+         }
+
+         public boolean equals(Object obj) {
+            if( obj==this )
+               return true;
+            
+            if( obj==null || obj.getClass()!=QueueAddBuffer.class )
+               return false;
+            
+            return equals((QueueAddBuffer)obj);
+         }
+         
+         public boolean equals(QueueAddBuffer obj) {
+            return toUnframedBuffer().equals(obj.toUnframedBuffer());
+         }
+         
+         public int hashCode() {
+            if( hashCode==0 ) {
+            hashCode=1244246608 ^ toUnframedBuffer().hashCode();
+            }
+            return hashCode;
+         }
+         
+         public boolean frozen() {
+            return true;
+         }
+         public Type toType() {
+            return Type.QUEUE_ADD;
+         }
+
+      }
+
+   }
+
+
+   static public interface QueueRemove extends org.fusesource.hawtbuf.proto.PBMessage<QueueRemove.QueueRemoveBean, QueueRemove.QueueRemoveBuffer>, Type.TypeCreatable {
+
+      // optional bytes queueName = 1;
+      public boolean hasQueueName();
+      public org.fusesource.hawtbuf.AsciiBuffer getQueueName();
+      public QueueRemoveBean copy();
+      public QueueRemoveBuffer freeze();
+      public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix);
+
+      static public final class QueueRemoveBean implements QueueRemove {
+
+         QueueRemoveBuffer frozen;
+         QueueRemoveBean bean;
+
+         public QueueRemoveBean() {
+            this.bean = this;
+         }
+
+         public QueueRemoveBean(QueueRemoveBean copy) {
+            this.bean = copy;
+         }
+
+         public QueueRemoveBean copy() {
+            return new QueueRemoveBean(bean);
+         }
+
+         public boolean frozen() {
+            return frozen!=null;
+         }
+
+         public QueueRemoveBuffer freeze() {
+            if( frozen==null ) {
+               frozen = new QueueRemoveBuffer(bean);
+               assert deepFreeze();
+            }
+            return frozen;
+         }
+
+         private boolean deepFreeze() {
+            frozen.serializedSizeUnframed();
+            return true;
+         }
+
+         private void copyCheck() {
+            assert frozen==null : org.fusesource.hawtbuf.proto.MessageBufferSupport.FORZEN_ERROR_MESSAGE;
+            if (bean != this) {
+               copy(bean);
+            }
+         }
+
+         private void copy(QueueRemoveBean other) {
+            this.bean = this;
+            this.f_queueName = other.f_queueName;
+            this.b_queueName = other.b_queueName;
+         }
+
+         // optional bytes queueName = 1;

[... 8322 lines stripped ...]


Mime
View raw message