001    //
002    // Generated by protoc, do not edit by hand.
003    //
004    package org.apache.activemq.console.command.store.proto;
005    
006    
007    public class QueueEntryPB implements org.fusesource.hawtbuf.proto.PBMessageFactory<QueueEntryPB.Bean, QueueEntryPB.Buffer> {
008    
009       public static final QueueEntryPB FACTORY = new QueueEntryPB();
010       public static final org.fusesource.hawtbuf.proto.PBMessageFramedCodec<Buffer> FRAMED_CODEC = new org.fusesource.hawtbuf.proto.PBMessageFramedCodec<Buffer>(FACTORY);
011       public static final org.fusesource.hawtbuf.proto.PBMessageUnframedCodec<Buffer> UNFRAMED_CODEC = new org.fusesource.hawtbuf.proto.PBMessageUnframedCodec<Buffer>(FACTORY);
012    
013       public Bean create()  {
014          return new Bean();
015       }
016    
017       public Bean parseUnframed(org.fusesource.hawtbuf.proto.CodedInputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
018          return new Bean().mergeUnframed(data);
019       }
020    
021       public Bean parseUnframed(java.io.InputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
022          return parseUnframed(new org.fusesource.hawtbuf.proto.CodedInputStream(data));
023       }
024    
025       public Buffer parseUnframed(org.fusesource.hawtbuf.Buffer data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
026          return new Buffer(data);
027       }
028    
029       public Buffer parseUnframed(byte[] data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
030          return parseUnframed(new org.fusesource.hawtbuf.Buffer(data));
031       }
032    
033       public Buffer parseFramed(org.fusesource.hawtbuf.proto.CodedInputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
034          int length = data.readRawVarint32();
035          int oldLimit = data.pushLimit(length);
036          Buffer rc = parseUnframed(data.readRawBytes(length));
037          data.popLimit(oldLimit);
038          return rc;
039       }
040    
041       public Buffer parseFramed(org.fusesource.hawtbuf.Buffer data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
042          try {
043             org.fusesource.hawtbuf.proto.CodedInputStream input = new org.fusesource.hawtbuf.proto.CodedInputStream(data);
044             Buffer rc = parseFramed(input);
045             input.checkLastTagWas(0);
046             return rc;
047          } catch (org.fusesource.hawtbuf.proto.InvalidProtocolBufferException e) {
048             throw e;
049          } catch (java.io.IOException e) {
050             throw new RuntimeException("An IOException was thrown (should never happen in this method).", e);
051          }
052       }
053    
054       public Buffer parseFramed(byte[] data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException {
055          return parseFramed(new org.fusesource.hawtbuf.Buffer(data));
056       }
057    
058       public Buffer parseFramed(java.io.InputStream data) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException {
059          return parseUnframed(org.fusesource.hawtbuf.proto.MessageBufferSupport.readFrame(data));
060       }
061    
062       public interface Getter extends org.fusesource.hawtbuf.proto.PBMessage<QueueEntryPB.Bean, QueueEntryPB.Buffer> {
063    
064          // required int64 queueKey = 1;
065          public boolean hasQueueKey();
066          public long getQueueKey();
067          // required int64 queueSeq = 2;
068          public boolean hasQueueSeq();
069          public long getQueueSeq();
070          // required int64 messageKey = 3;
071          public boolean hasMessageKey();
072          public long getMessageKey();
073          // optional int32 size = 4;
074          public boolean hasSize();
075          public int getSize();
076          // optional bytes attachment = 5;
077          public boolean hasAttachment();
078          public org.fusesource.hawtbuf.Buffer getAttachment();
079          // optional int32 redeliveries = 6;
080          public boolean hasRedeliveries();
081          public int getRedeliveries();
082          // optional sint64 expiration = 7;
083          public boolean hasExpiration();
084          public long getExpiration();
085          // optional bytes messageLocator = 8;
086          public boolean hasMessageLocator();
087          public org.fusesource.hawtbuf.Buffer getMessageLocator();
088          // repeated bytes sender = 9;
089          public boolean hasSender();
090          public java.util.List<org.fusesource.hawtbuf.Buffer> getSenderList();
091          public int getSenderCount();
092          public org.fusesource.hawtbuf.Buffer getSender(int index);
093          public Bean copy();
094          public Buffer freeze();
095          public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix);
096       }
097    
098       static public final class Bean implements Getter {
099    
100          Buffer frozen;
101          Bean bean;
102    
103          public Bean() {
104             this.bean = this;
105          }
106    
107          public Bean(Bean copy) {
108             this.bean = copy;
109          }
110    
111          public Bean copy() {
112             return new Bean(bean);
113          }
114    
115          public boolean frozen() {
116             return frozen!=null;
117          }
118    
119          public Buffer freeze() {
120             if( frozen==null ) {
121                frozen = new Buffer(bean);
122                assert deepFreeze();
123             }
124             return frozen;
125          }
126    
127          private boolean deepFreeze() {
128             frozen.serializedSizeUnframed();
129             return true;
130          }
131    
132          private void copyCheck() {
133             assert frozen==null : org.fusesource.hawtbuf.proto.MessageBufferSupport.FORZEN_ERROR_MESSAGE;
134             if (bean != this) {
135                copy(bean);
136             }
137          }
138    
139          private void copy(Bean other) {
140             this.bean = this;
141             this.f_queueKey = other.f_queueKey;
142             this.b_queueKey = other.b_queueKey;
143             this.f_queueSeq = other.f_queueSeq;
144             this.b_queueSeq = other.b_queueSeq;
145             this.f_messageKey = other.f_messageKey;
146             this.b_messageKey = other.b_messageKey;
147             this.f_size = other.f_size;
148             this.b_size = other.b_size;
149             this.f_attachment = other.f_attachment;
150             this.f_redeliveries = other.f_redeliveries;
151             this.b_redeliveries = other.b_redeliveries;
152             this.f_expiration = other.f_expiration;
153             this.b_expiration = other.b_expiration;
154             this.f_messageLocator = other.f_messageLocator;
155             this.f_sender = other.f_sender;
156             if( this.f_sender !=null && !other.frozen()) {
157                this.f_sender = new java.util.ArrayList<org.fusesource.hawtbuf.Buffer>(this.f_sender);
158             }
159          }
160    
161          // required int64 queueKey = 1;
162          private long f_queueKey = 0;
163          private boolean b_queueKey;
164    
165          public boolean hasQueueKey() {
166             return bean.b_queueKey;
167          }
168    
169          public long getQueueKey() {
170             return bean.f_queueKey;
171          }
172    
173          public Bean setQueueKey(long queueKey) {
174             copyCheck();
175             this.b_queueKey = true;
176             this.f_queueKey = queueKey;
177             return this;
178          }
179    
180          public void clearQueueKey() {
181             copyCheck();
182             this.b_queueKey = false;
183             this.f_queueKey = 0;
184          }
185    
186          // required int64 queueSeq = 2;
187          private long f_queueSeq = 0;
188          private boolean b_queueSeq;
189    
190          public boolean hasQueueSeq() {
191             return bean.b_queueSeq;
192          }
193    
194          public long getQueueSeq() {
195             return bean.f_queueSeq;
196          }
197    
198          public Bean setQueueSeq(long queueSeq) {
199             copyCheck();
200             this.b_queueSeq = true;
201             this.f_queueSeq = queueSeq;
202             return this;
203          }
204    
205          public void clearQueueSeq() {
206             copyCheck();
207             this.b_queueSeq = false;
208             this.f_queueSeq = 0;
209          }
210    
211          // required int64 messageKey = 3;
212          private long f_messageKey = 0;
213          private boolean b_messageKey;
214    
215          public boolean hasMessageKey() {
216             return bean.b_messageKey;
217          }
218    
219          public long getMessageKey() {
220             return bean.f_messageKey;
221          }
222    
223          public Bean setMessageKey(long messageKey) {
224             copyCheck();
225             this.b_messageKey = true;
226             this.f_messageKey = messageKey;
227             return this;
228          }
229    
230          public void clearMessageKey() {
231             copyCheck();
232             this.b_messageKey = false;
233             this.f_messageKey = 0;
234          }
235    
236          // optional int32 size = 4;
237          private int f_size = 0;
238          private boolean b_size;
239    
240          public boolean hasSize() {
241             return bean.b_size;
242          }
243    
244          public int getSize() {
245             return bean.f_size;
246          }
247    
248          public Bean setSize(int size) {
249             copyCheck();
250             this.b_size = true;
251             this.f_size = size;
252             return this;
253          }
254    
255          public void clearSize() {
256             copyCheck();
257             this.b_size = false;
258             this.f_size = 0;
259          }
260    
261          // optional bytes attachment = 5;
262          private org.fusesource.hawtbuf.Buffer f_attachment = null;
263    
264          public boolean hasAttachment() {
265             return bean.f_attachment!=null;
266          }
267    
268          public org.fusesource.hawtbuf.Buffer getAttachment() {
269             return bean.f_attachment;
270          }
271    
272          public Bean setAttachment(org.fusesource.hawtbuf.Buffer attachment) {
273             copyCheck();
274             this.f_attachment = attachment;
275             return this;
276          }
277    
278          public void clearAttachment() {
279             copyCheck();
280             this.f_attachment = null;
281          }
282    
283          // optional int32 redeliveries = 6;
284          private int f_redeliveries = 0;
285          private boolean b_redeliveries;
286    
287          public boolean hasRedeliveries() {
288             return bean.b_redeliveries;
289          }
290    
291          public int getRedeliveries() {
292             return bean.f_redeliveries;
293          }
294    
295          public Bean setRedeliveries(int redeliveries) {
296             copyCheck();
297             this.b_redeliveries = true;
298             this.f_redeliveries = redeliveries;
299             return this;
300          }
301    
302          public void clearRedeliveries() {
303             copyCheck();
304             this.b_redeliveries = false;
305             this.f_redeliveries = 0;
306          }
307    
308          // optional sint64 expiration = 7;
309          private long f_expiration = 0;
310          private boolean b_expiration;
311    
312          public boolean hasExpiration() {
313             return bean.b_expiration;
314          }
315    
316          public long getExpiration() {
317             return bean.f_expiration;
318          }
319    
320          public Bean setExpiration(long expiration) {
321             copyCheck();
322             this.b_expiration = true;
323             this.f_expiration = expiration;
324             return this;
325          }
326    
327          public void clearExpiration() {
328             copyCheck();
329             this.b_expiration = false;
330             this.f_expiration = 0;
331          }
332    
333          // optional bytes messageLocator = 8;
334          private org.fusesource.hawtbuf.Buffer f_messageLocator = null;
335    
336          public boolean hasMessageLocator() {
337             return bean.f_messageLocator!=null;
338          }
339    
340          public org.fusesource.hawtbuf.Buffer getMessageLocator() {
341             return bean.f_messageLocator;
342          }
343    
344          public Bean setMessageLocator(org.fusesource.hawtbuf.Buffer messageLocator) {
345             copyCheck();
346             this.f_messageLocator = messageLocator;
347             return this;
348          }
349    
350          public void clearMessageLocator() {
351             copyCheck();
352             this.f_messageLocator = null;
353          }
354    
355          // repeated bytes sender = 9;
356          private java.util.List<org.fusesource.hawtbuf.Buffer> f_sender;
357    
358          public boolean hasSender() {
359             return bean.f_sender!=null && !bean.f_sender.isEmpty();
360          }
361    
362          public java.util.List<org.fusesource.hawtbuf.Buffer> getSenderList() {
363             return bean.f_sender;
364          }
365    
366          public java.util.List<org.fusesource.hawtbuf.Buffer> createSenderList() {
367             copyCheck();
368             if( this.f_sender == null ) {
369                this.f_sender = new java.util.ArrayList<org.fusesource.hawtbuf.Buffer>();
370             }
371             return bean.f_sender;
372          }
373    
374          public Bean setSenderList(java.util.List<org.fusesource.hawtbuf.Buffer> sender) {
375             copyCheck();
376             this.f_sender = sender;
377             return this;
378          }
379    
380          public int getSenderCount() {
381             if( bean.f_sender == null ) {
382                return 0;
383             }
384             return bean.f_sender.size();
385          }
386    
387          public org.fusesource.hawtbuf.Buffer getSender(int index) {
388             if( bean.f_sender == null ) {
389                return null;
390             }
391             return bean.f_sender.get(index);
392          }
393    
394          public Bean setSender(int index, org.fusesource.hawtbuf.Buffer value) {
395             this.createSenderList().set(index, value);
396             return this;
397          }
398    
399          public Bean addSender(org.fusesource.hawtbuf.Buffer value) {
400             this.createSenderList().add(value);
401             return this;
402          }
403    
404          public Bean addAllSender(java.lang.Iterable<? extends org.fusesource.hawtbuf.Buffer> collection) {
405             org.fusesource.hawtbuf.proto.MessageBufferSupport.addAll(collection, this.createSenderList());
406             return this;
407          }
408    
409          public void clearSender() {
410             copyCheck();
411             this.f_sender = null;
412          }
413    
414          public String toString() {
415             return toString(new java.lang.StringBuilder(), "").toString();
416          }
417    
418          public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix) {
419             if(  hasQueueKey() ) {
420                sb.append(prefix+"queueKey: ");
421                sb.append(getQueueKey());
422                sb.append("\n");
423             }
424             if(  hasQueueSeq() ) {
425                sb.append(prefix+"queueSeq: ");
426                sb.append(getQueueSeq());
427                sb.append("\n");
428             }
429             if(  hasMessageKey() ) {
430                sb.append(prefix+"messageKey: ");
431                sb.append(getMessageKey());
432                sb.append("\n");
433             }
434             if(  hasSize() ) {
435                sb.append(prefix+"size: ");
436                sb.append(getSize());
437                sb.append("\n");
438             }
439             if(  hasAttachment() ) {
440                sb.append(prefix+"attachment: ");
441                sb.append(getAttachment());
442                sb.append("\n");
443             }
444             if(  hasRedeliveries() ) {
445                sb.append(prefix+"redeliveries: ");
446                sb.append(getRedeliveries());
447                sb.append("\n");
448             }
449             if(  hasExpiration() ) {
450                sb.append(prefix+"expiration: ");
451                sb.append(getExpiration());
452                sb.append("\n");
453             }
454             if(  hasMessageLocator() ) {
455                sb.append(prefix+"messageLocator: ");
456                sb.append(getMessageLocator());
457                sb.append("\n");
458             }
459             if(  hasSender() ) {
460                java.util.List<org.fusesource.hawtbuf.Buffer> l = getSenderList();
461                for( int i=0; i < l.size(); i++ ) {
462                   sb.append(prefix+"sender["+i+"]: ");
463                   sb.append(l.get(i));
464                   sb.append("\n");
465                }
466             }
467             return sb;
468          }
469    
470          public Bean mergeUnframed(java.io.InputStream input) throws java.io.IOException {
471             return mergeUnframed(new org.fusesource.hawtbuf.proto.CodedInputStream(input));
472          }
473    
474          public Bean mergeUnframed(org.fusesource.hawtbuf.proto.CodedInputStream input) throws java.io.IOException {
475             copyCheck();
476             while (true) {
477                int tag = input.readTag();
478                if ((tag & 0x07) == 4) {
479                   return this;
480                }
481                switch (tag) {
482                case 0:
483                   return this;
484                default: {
485                   break;
486                }
487                case 8:
488                   setQueueKey(input.readInt64());
489                   break;
490                case 16:
491                   setQueueSeq(input.readInt64());
492                   break;
493                case 24:
494                   setMessageKey(input.readInt64());
495                   break;
496                case 32:
497                   setSize(input.readInt32());
498                   break;
499                case 42:
500                   setAttachment(input.readBytes());
501                   break;
502                case 48:
503                   setRedeliveries(input.readInt32());
504                   break;
505                case 56:
506                   setExpiration(input.readSInt64());
507                   break;
508                case 66:
509                   setMessageLocator(input.readBytes());
510                   break;
511                case 74:
512                   createSenderList().add(input.readBytes());
513                   break;
514                }
515             }
516          }
517          public boolean equals(Object obj) {
518             if( obj==this )
519                return true;
520             
521             if( obj==null || obj.getClass()!=Bean.class )
522                return false;
523             
524             return equals((Bean)obj);
525          }
526          
527          public boolean equals(Bean obj) {
528             if (hasQueueKey() ^ obj.hasQueueKey() ) 
529                return false;
530             if (hasQueueKey() && ( getQueueKey()!=obj.getQueueKey() ))
531                return false;
532             if (hasQueueSeq() ^ obj.hasQueueSeq() ) 
533                return false;
534             if (hasQueueSeq() && ( getQueueSeq()!=obj.getQueueSeq() ))
535                return false;
536             if (hasMessageKey() ^ obj.hasMessageKey() ) 
537                return false;
538             if (hasMessageKey() && ( getMessageKey()!=obj.getMessageKey() ))
539                return false;
540             if (hasSize() ^ obj.hasSize() ) 
541                return false;
542             if (hasSize() && ( getSize()!=obj.getSize() ))
543                return false;
544             if (hasAttachment() ^ obj.hasAttachment() ) 
545                return false;
546             if (hasAttachment() && ( !getAttachment().equals(obj.getAttachment()) ))
547                return false;
548             if (hasRedeliveries() ^ obj.hasRedeliveries() ) 
549                return false;
550             if (hasRedeliveries() && ( getRedeliveries()!=obj.getRedeliveries() ))
551                return false;
552             if (hasExpiration() ^ obj.hasExpiration() ) 
553                return false;
554             if (hasExpiration() && ( getExpiration()!=obj.getExpiration() ))
555                return false;
556             if (hasMessageLocator() ^ obj.hasMessageLocator() ) 
557                return false;
558             if (hasMessageLocator() && ( !getMessageLocator().equals(obj.getMessageLocator()) ))
559                return false;
560             if (hasSender() ^ obj.hasSender() ) 
561                return false;
562             if (hasSender() && ( !getSenderList().equals(obj.getSenderList()) ))
563                return false;
564             return true;
565          }
566          
567          public int hashCode() {
568             int rc=2066384;
569             if (hasQueueKey()) {
570                rc ^= ( -1099854930^(new Long(getQueueKey())).hashCode() );
571             }
572             if (hasQueueSeq()) {
573                rc ^= ( -1099847250^(new Long(getQueueSeq())).hashCode() );
574             }
575             if (hasMessageKey()) {
576                rc ^= ( 302723320^(new Long(getMessageKey())).hashCode() );
577             }
578             if (hasSize()) {
579                rc ^= ( 2577441^getSize() );
580             }
581             if (hasAttachment()) {
582                rc ^= ( 29963587^getAttachment().hashCode() );
583             }
584             if (hasRedeliveries()) {
585                rc ^= ( 1969176101^getRedeliveries() );
586             }
587             if (hasExpiration()) {
588                rc ^= ( 1155999439^(new Long(getExpiration())).hashCode() );
589             }
590             if (hasMessageLocator()) {
591                rc ^= ( 193493679^getMessageLocator().hashCode() );
592             }
593             if (hasSender()) {
594                rc ^= ( -1822095787^getSenderList().hashCode() );
595             }
596             return rc;
597          }
598          
599          public Bean mergeFrom(Getter other) {
600             copyCheck();
601             if (other.hasQueueKey()) {
602                setQueueKey(other.getQueueKey());
603             }
604             if (other.hasQueueSeq()) {
605                setQueueSeq(other.getQueueSeq());
606             }
607             if (other.hasMessageKey()) {
608                setMessageKey(other.getMessageKey());
609             }
610             if (other.hasSize()) {
611                setSize(other.getSize());
612             }
613             if (other.hasAttachment()) {
614                setAttachment(other.getAttachment());
615             }
616             if (other.hasRedeliveries()) {
617                setRedeliveries(other.getRedeliveries());
618             }
619             if (other.hasExpiration()) {
620                setExpiration(other.getExpiration());
621             }
622             if (other.hasMessageLocator()) {
623                setMessageLocator(other.getMessageLocator());
624             }
625             if (other.hasSender()) {
626                getSenderList().addAll(other.getSenderList());
627             }
628             return this;
629          }
630    
631          public void clear() {
632             clearQueueKey();
633             clearQueueSeq();
634             clearMessageKey();
635             clearSize();
636             clearAttachment();
637             clearRedeliveries();
638             clearExpiration();
639             clearMessageLocator();
640             clearSender();
641          }
642    
643          public void readExternal(java.io.DataInput in) throws java.io.IOException {
644             assert frozen==null : org.fusesource.hawtbuf.proto.MessageBufferSupport.FORZEN_ERROR_MESSAGE;
645             bean = this;
646             frozen = null;
647             f_queueKey = in.readLong();
648             b_queueKey = true;
649             f_queueSeq = in.readLong();
650             b_queueSeq = true;
651             f_messageKey = in.readLong();
652             b_messageKey = true;
653             f_size = in.readInt();
654             b_size = true;
655             {
656                int size = in.readInt();
657                if( size>=0 ) {
658                   byte b[] = new byte[size];
659                   in.readFully(b);
660                   f_attachment = new org.fusesource.hawtbuf.Buffer(b);
661                } else {
662                   f_attachment = null;
663                }
664             }
665             f_redeliveries = in.readInt();
666             b_redeliveries = true;
667             f_expiration = in.readLong();
668             b_expiration = true;
669             {
670                int size = in.readInt();
671                if( size>=0 ) {
672                   byte b[] = new byte[size];
673                   in.readFully(b);
674                   f_messageLocator = new org.fusesource.hawtbuf.Buffer(b);
675                } else {
676                   f_messageLocator = null;
677                }
678             }
679             {
680                int size = in.readShort();
681                if( size>=0 ) {
682                   f_sender = new java.util.ArrayList<org.fusesource.hawtbuf.Buffer>(size);
683                   for(int i=0; i<size; i++) {
684                      byte b[] = new byte[in.readInt()];
685                      in.readFully(b);
686                      f_sender.add(new org.fusesource.hawtbuf.Buffer(b));
687                   }
688                } else {
689                   f_sender = null;
690                }
691             }
692          }
693    
694          public void writeExternal(java.io.DataOutput out) throws java.io.IOException {
695             out.writeLong(bean.f_queueKey);
696             out.writeLong(bean.f_queueSeq);
697             out.writeLong(bean.f_messageKey);
698             out.writeInt(bean.f_size);
699             if( bean.f_attachment!=null ) {
700                out.writeInt(bean.f_attachment.getLength());
701                out.write(bean.f_attachment.getData(), bean.f_attachment.getOffset(), bean.f_attachment.getLength());
702             } else {
703                out.writeInt(-1);
704             }
705             out.writeInt(bean.f_redeliveries);
706             out.writeLong(bean.f_expiration);
707             if( bean.f_messageLocator!=null ) {
708                out.writeInt(bean.f_messageLocator.getLength());
709                out.write(bean.f_messageLocator.getData(), bean.f_messageLocator.getOffset(), bean.f_messageLocator.getLength());
710             } else {
711                out.writeInt(-1);
712             }
713             if( bean.f_sender!=null ) {
714                out.writeShort(bean.f_sender.size());
715                for(org.fusesource.hawtbuf.Buffer o : bean.f_sender) {
716                   out.writeInt(o.getLength());
717                   out.write(o.getData(), o.getOffset(), o.getLength());
718                }
719             } else {
720                out.writeShort(-1);
721             }
722          }
723    
724       }
725    
726       static public final class Buffer implements org.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean, QueueEntryPB.Buffer>, Getter {
727    
728          private Bean bean;
729          private org.fusesource.hawtbuf.Buffer buffer;
730          private int size=-1;
731          private int hashCode;
732    
733          private Buffer(org.fusesource.hawtbuf.Buffer buffer) {
734             this.buffer = buffer;
735          }
736    
737          private Buffer(Bean bean) {
738             this.bean = bean;
739          }
740    
741          public Bean copy() {
742             return bean().copy();
743          }
744    
745          public Buffer freeze() {
746             return this;
747          }
748    
749          private Bean bean() {
750             if (bean == null) {
751                try {
752                   bean = new Bean().mergeUnframed(new org.fusesource.hawtbuf.proto.CodedInputStream(buffer));
753                   bean.frozen=this;
754                } catch (org.fusesource.hawtbuf.proto.InvalidProtocolBufferException e) {
755                   throw new RuntimeException(e);
756                } catch (java.io.IOException e) {
757                   throw new RuntimeException("An IOException was thrown (should never happen in this method).", e);
758                }
759             }
760             return bean;
761          }
762    
763          public String toString() {
764             return bean().toString();
765          }
766    
767          public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix) {
768             return bean().toString(sb, prefix);
769          }
770    
771          // required int64 queueKey = 1;
772          public boolean hasQueueKey() {
773             return bean().hasQueueKey();
774          }
775    
776          public long getQueueKey() {
777             return bean().getQueueKey();
778          }
779    
780          // required int64 queueSeq = 2;
781          public boolean hasQueueSeq() {
782             return bean().hasQueueSeq();
783          }
784    
785          public long getQueueSeq() {
786             return bean().getQueueSeq();
787          }
788    
789          // required int64 messageKey = 3;
790          public boolean hasMessageKey() {
791             return bean().hasMessageKey();
792          }
793    
794          public long getMessageKey() {
795             return bean().getMessageKey();
796          }
797    
798          // optional int32 size = 4;
799          public boolean hasSize() {
800             return bean().hasSize();
801          }
802    
803          public int getSize() {
804             return bean().getSize();
805          }
806    
807          // optional bytes attachment = 5;
808          public boolean hasAttachment() {
809             return bean().hasAttachment();
810          }
811    
812          public org.fusesource.hawtbuf.Buffer getAttachment() {
813             return bean().getAttachment();
814          }
815    
816          // optional int32 redeliveries = 6;
817          public boolean hasRedeliveries() {
818             return bean().hasRedeliveries();
819          }
820    
821          public int getRedeliveries() {
822             return bean().getRedeliveries();
823          }
824    
825          // optional sint64 expiration = 7;
826          public boolean hasExpiration() {
827             return bean().hasExpiration();
828          }
829    
830          public long getExpiration() {
831             return bean().getExpiration();
832          }
833    
834          // optional bytes messageLocator = 8;
835          public boolean hasMessageLocator() {
836             return bean().hasMessageLocator();
837          }
838    
839          public org.fusesource.hawtbuf.Buffer getMessageLocator() {
840             return bean().getMessageLocator();
841          }
842    
843          // repeated bytes sender = 9;
844          public boolean hasSender() {
845             return bean().hasSender();
846          }
847    
848          public java.util.List<org.fusesource.hawtbuf.Buffer> getSenderList() {
849             return bean().getSenderList();
850          }
851    
852          public int getSenderCount() {
853             return bean().getSenderCount();
854          }
855    
856          public org.fusesource.hawtbuf.Buffer getSender(int index) {
857             return bean().getSender(index);
858          }
859    
860          public org.fusesource.hawtbuf.Buffer toUnframedBuffer() {
861             if( buffer !=null ) {
862                return buffer;
863             }
864             return org.fusesource.hawtbuf.proto.MessageBufferSupport.toUnframedBuffer(this);
865          }
866    
867          public org.fusesource.hawtbuf.Buffer toFramedBuffer() {
868             return org.fusesource.hawtbuf.proto.MessageBufferSupport.toFramedBuffer(this);
869          }
870    
871          public byte[] toUnframedByteArray() {
872             return toUnframedBuffer().toByteArray();
873          }
874    
875          public byte[] toFramedByteArray() {
876             return toFramedBuffer().toByteArray();
877          }
878    
879          public void writeFramed(org.fusesource.hawtbuf.proto.CodedOutputStream output) throws java.io.IOException {
880             output.writeRawVarint32(serializedSizeUnframed());
881             writeUnframed(output);
882          }
883    
884          public void writeFramed(java.io.OutputStream output) throws java.io.IOException {
885             org.fusesource.hawtbuf.proto.CodedOutputStream codedOutput = new org.fusesource.hawtbuf.proto.CodedOutputStream(output);
886             writeFramed(codedOutput);
887             codedOutput.flush();
888          }
889    
890          public void writeUnframed(java.io.OutputStream output) throws java.io.IOException {
891             org.fusesource.hawtbuf.proto.CodedOutputStream codedOutput = new org.fusesource.hawtbuf.proto.CodedOutputStream(output);
892             writeUnframed(codedOutput);
893             codedOutput.flush();
894          }
895    
896          public void writeUnframed(org.fusesource.hawtbuf.proto.CodedOutputStream output) throws java.io.IOException {
897             if (buffer == null) {
898                int size = serializedSizeUnframed();
899                buffer = output.getNextBuffer(size);
900                org.fusesource.hawtbuf.proto.CodedOutputStream original=null;
901                if( buffer == null ) {
902                   buffer = new org.fusesource.hawtbuf.Buffer(new byte[size]);
903                   original = output;
904                   output = new org.fusesource.hawtbuf.proto.CodedOutputStream(buffer);
905                }
906                output.writeInt64(1, bean.getQueueKey());
907                output.writeInt64(2, bean.getQueueSeq());
908                output.writeInt64(3, bean.getMessageKey());
909                if (bean.hasSize()) {
910                   output.writeInt32(4, bean.getSize());
911                }
912                if (bean.hasAttachment()) {
913                   output.writeBytes(5, bean.getAttachment());
914                }
915                if (bean.hasRedeliveries()) {
916                   output.writeInt32(6, bean.getRedeliveries());
917                }
918                if (bean.hasExpiration()) {
919                   output.writeSInt64(7, bean.getExpiration());
920                }
921                if (bean.hasMessageLocator()) {
922                   output.writeBytes(8, bean.getMessageLocator());
923                }
924                if (bean.hasSender()) {
925                   for (org.fusesource.hawtbuf.Buffer i : bean.getSenderList()) {
926                      output.writeBytes(9, i);
927                   }
928                }
929                if( original !=null ) {
930                   output.checkNoSpaceLeft();
931                   output = original;
932                   output.writeRawBytes(buffer);
933                }
934             } else {
935                output.writeRawBytes(buffer);
936             }
937          }
938    
939          public int serializedSizeFramed() {
940             int t = serializedSizeUnframed();
941             return org.fusesource.hawtbuf.proto.CodedOutputStream.computeRawVarint32Size(t) + t;
942          }
943    
944          public int serializedSizeUnframed() {
945             if (buffer != null) {
946                return buffer.length;
947             }
948             if (size != -1)
949                return size;
950    
951             size = 0;
952             size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeInt64Size(1, getQueueKey());
953             size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeInt64Size(2, getQueueSeq());
954             size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeInt64Size(3, getMessageKey());
955             if (hasSize()) {
956                size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeInt32Size(4, getSize());
957             }
958             if (hasAttachment()) {
959                size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeBytesSize(5, getAttachment());
960             }
961             if (hasRedeliveries()) {
962                size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeInt32Size(6, getRedeliveries());
963             }
964             if (hasExpiration()) {
965                size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeSInt64Size(7, getExpiration());
966             }
967             if (hasMessageLocator()) {
968                size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeBytesSize(8, getMessageLocator());
969             }
970             if (hasSender()) {
971                for (org.fusesource.hawtbuf.Buffer i : getSenderList()) {
972                   size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeBytesSize(9, i);
973                }
974             }
975             return size;
976          }
977    
978          public boolean equals(Object obj) {
979             if( obj==this )
980                return true;
981             
982             if( obj==null || obj.getClass()!=Buffer.class )
983                return false;
984             
985             return equals((Buffer)obj);
986          }
987          
988          public boolean equals(Buffer obj) {
989             return toUnframedBuffer().equals(obj.toUnframedBuffer());
990          }
991          
992          public int hashCode() {
993             if( hashCode==0 ) {
994             hashCode=2000715872 ^ toUnframedBuffer().hashCode();
995             }
996             return hashCode;
997          }
998          
999          public boolean frozen() {
1000             return true;
1001          }
1002       }
1003    
1004    }
1005