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