001// 002// Generated by protoc, do not edit by hand. 003// 004package org.apache.activemq.console.command.store.proto; 005 006 007public class MapEntryPB implements org.fusesource.hawtbuf.proto.PBMessageFactory<MapEntryPB.Bean, MapEntryPB.Buffer> { 008 009 public static final MapEntryPB FACTORY = new MapEntryPB(); 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<MapEntryPB.Bean, MapEntryPB.Buffer> { 063 064 // required bytes key = 1; 065 public boolean hasKey(); 066 public org.fusesource.hawtbuf.Buffer getKey(); 067 // optional bytes value = 2; 068 public boolean hasValue(); 069 public org.fusesource.hawtbuf.Buffer getValue(); 070 public Bean copy(); 071 public Buffer freeze(); 072 public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix); 073 } 074 075 static public final class Bean implements Getter { 076 077 Buffer frozen; 078 Bean bean; 079 080 public Bean() { 081 this.bean = this; 082 } 083 084 public Bean(Bean copy) { 085 this.bean = copy; 086 } 087 088 public Bean copy() { 089 return new Bean(bean); 090 } 091 092 public boolean frozen() { 093 return frozen!=null; 094 } 095 096 public Buffer freeze() { 097 if( frozen==null ) { 098 frozen = new Buffer(bean); 099 assert deepFreeze(); 100 } 101 return frozen; 102 } 103 104 private boolean deepFreeze() { 105 frozen.serializedSizeUnframed(); 106 return true; 107 } 108 109 private void copyCheck() { 110 assert frozen==null : org.fusesource.hawtbuf.proto.MessageBufferSupport.FORZEN_ERROR_MESSAGE; 111 if (bean != this) { 112 copy(bean); 113 } 114 } 115 116 private void copy(Bean other) { 117 this.bean = this; 118 this.f_key = other.f_key; 119 this.f_value = other.f_value; 120 } 121 122 // required bytes key = 1; 123 private org.fusesource.hawtbuf.Buffer f_key = null; 124 125 public boolean hasKey() { 126 return bean.f_key!=null; 127 } 128 129 public org.fusesource.hawtbuf.Buffer getKey() { 130 return bean.f_key; 131 } 132 133 public Bean setKey(org.fusesource.hawtbuf.Buffer key) { 134 copyCheck(); 135 this.f_key = key; 136 return this; 137 } 138 139 public void clearKey() { 140 copyCheck(); 141 this.f_key = null; 142 } 143 144 // optional bytes value = 2; 145 private org.fusesource.hawtbuf.Buffer f_value = null; 146 147 public boolean hasValue() { 148 return bean.f_value!=null; 149 } 150 151 public org.fusesource.hawtbuf.Buffer getValue() { 152 return bean.f_value; 153 } 154 155 public Bean setValue(org.fusesource.hawtbuf.Buffer value) { 156 copyCheck(); 157 this.f_value = value; 158 return this; 159 } 160 161 public void clearValue() { 162 copyCheck(); 163 this.f_value = null; 164 } 165 166 public String toString() { 167 return toString(new java.lang.StringBuilder(), "").toString(); 168 } 169 170 public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix) { 171 if( hasKey() ) { 172 sb.append(prefix+"key: "); 173 sb.append(getKey()); 174 sb.append("\n"); 175 } 176 if( hasValue() ) { 177 sb.append(prefix+"value: "); 178 sb.append(getValue()); 179 sb.append("\n"); 180 } 181 return sb; 182 } 183 184 public Bean mergeUnframed(java.io.InputStream input) throws java.io.IOException { 185 return mergeUnframed(new org.fusesource.hawtbuf.proto.CodedInputStream(input)); 186 } 187 188 public Bean mergeUnframed(org.fusesource.hawtbuf.proto.CodedInputStream input) throws java.io.IOException { 189 copyCheck(); 190 while (true) { 191 int tag = input.readTag(); 192 if ((tag & 0x07) == 4) { 193 return this; 194 } 195 switch (tag) { 196 case 0: 197 return this; 198 default: { 199 break; 200 } 201 case 10: 202 setKey(input.readBytes()); 203 break; 204 case 18: 205 setValue(input.readBytes()); 206 break; 207 } 208 } 209 } 210 public boolean equals(Object obj) { 211 if( obj==this ) 212 return true; 213 214 if( obj==null || obj.getClass()!=Bean.class ) 215 return false; 216 217 return equals((Bean)obj); 218 } 219 220 public boolean equals(Bean obj) { 221 if (hasKey() ^ obj.hasKey() ) 222 return false; 223 if (hasKey() && ( !getKey().equals(obj.getKey()) )) 224 return false; 225 if (hasValue() ^ obj.hasValue() ) 226 return false; 227 if (hasValue() && ( !getValue().equals(obj.getValue()) )) 228 return false; 229 return true; 230 } 231 232 public int hashCode() { 233 int rc=2066384; 234 if (hasKey()) { 235 rc ^= ( 75327^getKey().hashCode() ); 236 } 237 if (hasValue()) { 238 rc ^= ( 82420049^getValue().hashCode() ); 239 } 240 return rc; 241 } 242 243 public Bean mergeFrom(Getter other) { 244 copyCheck(); 245 if (other.hasKey()) { 246 setKey(other.getKey()); 247 } 248 if (other.hasValue()) { 249 setValue(other.getValue()); 250 } 251 return this; 252 } 253 254 public void clear() { 255 clearKey(); 256 clearValue(); 257 } 258 259 public void readExternal(java.io.DataInput in) throws java.io.IOException { 260 assert frozen==null : org.fusesource.hawtbuf.proto.MessageBufferSupport.FORZEN_ERROR_MESSAGE; 261 bean = this; 262 frozen = null; 263 { 264 int size = in.readInt(); 265 if( size>=0 ) { 266 byte b[] = new byte[size]; 267 in.readFully(b); 268 f_key = new org.fusesource.hawtbuf.Buffer(b); 269 } else { 270 f_key = null; 271 } 272 } 273 { 274 int size = in.readInt(); 275 if( size>=0 ) { 276 byte b[] = new byte[size]; 277 in.readFully(b); 278 f_value = new org.fusesource.hawtbuf.Buffer(b); 279 } else { 280 f_value = null; 281 } 282 } 283 } 284 285 public void writeExternal(java.io.DataOutput out) throws java.io.IOException { 286 if( bean.f_key!=null ) { 287 out.writeInt(bean.f_key.getLength()); 288 out.write(bean.f_key.getData(), bean.f_key.getOffset(), bean.f_key.getLength()); 289 } else { 290 out.writeInt(-1); 291 } 292 if( bean.f_value!=null ) { 293 out.writeInt(bean.f_value.getLength()); 294 out.write(bean.f_value.getData(), bean.f_value.getOffset(), bean.f_value.getLength()); 295 } else { 296 out.writeInt(-1); 297 } 298 } 299 300 } 301 302 static public final class Buffer implements org.fusesource.hawtbuf.proto.MessageBuffer<MapEntryPB.Bean, MapEntryPB.Buffer>, Getter { 303 304 private Bean bean; 305 private org.fusesource.hawtbuf.Buffer buffer; 306 private int size=-1; 307 private int hashCode; 308 309 private Buffer(org.fusesource.hawtbuf.Buffer buffer) { 310 this.buffer = buffer; 311 } 312 313 private Buffer(Bean bean) { 314 this.bean = bean; 315 } 316 317 public Bean copy() { 318 return bean().copy(); 319 } 320 321 public Buffer freeze() { 322 return this; 323 } 324 325 private Bean bean() { 326 if (bean == null) { 327 try { 328 bean = new Bean().mergeUnframed(new org.fusesource.hawtbuf.proto.CodedInputStream(buffer)); 329 bean.frozen=this; 330 } catch (org.fusesource.hawtbuf.proto.InvalidProtocolBufferException e) { 331 throw new RuntimeException(e); 332 } catch (java.io.IOException e) { 333 throw new RuntimeException("An IOException was thrown (should never happen in this method).", e); 334 } 335 } 336 return bean; 337 } 338 339 public String toString() { 340 return bean().toString(); 341 } 342 343 public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix) { 344 return bean().toString(sb, prefix); 345 } 346 347 // required bytes key = 1; 348 public boolean hasKey() { 349 return bean().hasKey(); 350 } 351 352 public org.fusesource.hawtbuf.Buffer getKey() { 353 return bean().getKey(); 354 } 355 356 // optional bytes value = 2; 357 public boolean hasValue() { 358 return bean().hasValue(); 359 } 360 361 public org.fusesource.hawtbuf.Buffer getValue() { 362 return bean().getValue(); 363 } 364 365 public org.fusesource.hawtbuf.Buffer toUnframedBuffer() { 366 if( buffer !=null ) { 367 return buffer; 368 } 369 return org.fusesource.hawtbuf.proto.MessageBufferSupport.toUnframedBuffer(this); 370 } 371 372 public org.fusesource.hawtbuf.Buffer toFramedBuffer() { 373 return org.fusesource.hawtbuf.proto.MessageBufferSupport.toFramedBuffer(this); 374 } 375 376 public byte[] toUnframedByteArray() { 377 return toUnframedBuffer().toByteArray(); 378 } 379 380 public byte[] toFramedByteArray() { 381 return toFramedBuffer().toByteArray(); 382 } 383 384 public void writeFramed(org.fusesource.hawtbuf.proto.CodedOutputStream output) throws java.io.IOException { 385 output.writeRawVarint32(serializedSizeUnframed()); 386 writeUnframed(output); 387 } 388 389 public void writeFramed(java.io.OutputStream output) throws java.io.IOException { 390 org.fusesource.hawtbuf.proto.CodedOutputStream codedOutput = new org.fusesource.hawtbuf.proto.CodedOutputStream(output); 391 writeFramed(codedOutput); 392 codedOutput.flush(); 393 } 394 395 public void writeUnframed(java.io.OutputStream output) throws java.io.IOException { 396 org.fusesource.hawtbuf.proto.CodedOutputStream codedOutput = new org.fusesource.hawtbuf.proto.CodedOutputStream(output); 397 writeUnframed(codedOutput); 398 codedOutput.flush(); 399 } 400 401 public void writeUnframed(org.fusesource.hawtbuf.proto.CodedOutputStream output) throws java.io.IOException { 402 if (buffer == null) { 403 int size = serializedSizeUnframed(); 404 buffer = output.getNextBuffer(size); 405 org.fusesource.hawtbuf.proto.CodedOutputStream original=null; 406 if( buffer == null ) { 407 buffer = new org.fusesource.hawtbuf.Buffer(new byte[size]); 408 original = output; 409 output = new org.fusesource.hawtbuf.proto.CodedOutputStream(buffer); 410 } 411 output.writeBytes(1, bean.getKey()); 412 if (bean.hasValue()) { 413 output.writeBytes(2, bean.getValue()); 414 } 415 if( original !=null ) { 416 output.checkNoSpaceLeft(); 417 output = original; 418 output.writeRawBytes(buffer); 419 } 420 } else { 421 output.writeRawBytes(buffer); 422 } 423 } 424 425 public int serializedSizeFramed() { 426 int t = serializedSizeUnframed(); 427 return org.fusesource.hawtbuf.proto.CodedOutputStream.computeRawVarint32Size(t) + t; 428 } 429 430 public int serializedSizeUnframed() { 431 if (buffer != null) { 432 return buffer.length; 433 } 434 if (size != -1) 435 return size; 436 437 size = 0; 438 size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeBytesSize(1, getKey()); 439 if (hasValue()) { 440 size += org.fusesource.hawtbuf.proto.CodedOutputStream.computeBytesSize(2, getValue()); 441 } 442 return size; 443 } 444 445 public boolean equals(Object obj) { 446 if( obj==this ) 447 return true; 448 449 if( obj==null || obj.getClass()!=Buffer.class ) 450 return false; 451 452 return equals((Buffer)obj); 453 } 454 455 public boolean equals(Buffer obj) { 456 return toUnframedBuffer().equals(obj.toUnframedBuffer()); 457 } 458 459 public int hashCode() { 460 if( hashCode==0 ) { 461 hashCode=2000715872 ^ toUnframedBuffer().hashCode(); 462 } 463 return hashCode; 464 } 465 466 public boolean frozen() { 467 return true; 468 } 469 } 470 471} 472