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