You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2010/07/07 05:50:51 UTC
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...
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 ...]