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