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