001//
002// Generated by protoc, do not edit by hand.
003//
004package org.apache.activemq.store.kahadb.data;
005
006
007public final class KahaAddMessageCommand extends KahaAddMessageCommandBase<KahaAddMessageCommand> implements org.apache.activemq.store.kahadb.JournalCommand<KahaAddMessageCommand> {
008
009   public java.util.ArrayList<String> missingFields() {
010      java.util.ArrayList<String> missingFields = super.missingFields();
011      if(  !hasDestination() ) {
012         missingFields.add("destination");
013      }
014      if(  !hasMessageId() ) {
015         missingFields.add("messageId");
016      }
017      if(  !hasMessage() ) {
018         missingFields.add("message");
019      }
020      if( hasTransactionInfo() ) {
021         try {
022            getTransactionInfo().assertInitialized();
023         } catch (org.apache.activemq.protobuf.UninitializedMessageException e){
024            missingFields.addAll(prefix(e.getMissingFields(),"transaction_info."));
025         }
026      }
027      if( hasDestination() ) {
028         try {
029            getDestination().assertInitialized();
030         } catch (org.apache.activemq.protobuf.UninitializedMessageException e){
031            missingFields.addAll(prefix(e.getMissingFields(),"destination."));
032         }
033      }
034      return missingFields;
035   }
036
037   public void clear() {
038      super.clear();
039      clearTransactionInfo();
040      clearDestination();
041      clearMessageId();
042      clearMessage();
043      clearPriority();
044      clearPrioritySupported();
045   }
046
047   public KahaAddMessageCommand clone() {
048      return new KahaAddMessageCommand().mergeFrom(this);
049   }
050
051   public KahaAddMessageCommand mergeFrom(KahaAddMessageCommand other) {
052      if (other.hasTransactionInfo()) {
053         if (hasTransactionInfo()) {
054            getTransactionInfo().mergeFrom(other.getTransactionInfo());
055         } else {
056            setTransactionInfo(other.getTransactionInfo().clone());
057         }
058      }
059      if (other.hasDestination()) {
060         if (hasDestination()) {
061            getDestination().mergeFrom(other.getDestination());
062         } else {
063            setDestination(other.getDestination().clone());
064         }
065      }
066      if (other.hasMessageId()) {
067         setMessageId(other.getMessageId());
068      }
069      if (other.hasMessage()) {
070         setMessage(other.getMessage());
071      }
072      if (other.hasPriority()) {
073         setPriority(other.getPriority());
074      }
075      if (other.hasPrioritySupported()) {
076         setPrioritySupported(other.getPrioritySupported());
077      }
078      return this;
079   }
080
081   public int serializedSizeUnframed() {
082      if (memoizedSerializedSize != -1)
083         return memoizedSerializedSize;
084
085      int size = 0;
086      if (hasTransactionInfo()) {
087         size += computeMessageSize(1, getTransactionInfo());
088      }
089      if (hasDestination()) {
090         size += computeMessageSize(2, getDestination());
091      }
092      if (hasMessageId()) {
093         size += org.apache.activemq.protobuf.CodedOutputStream.computeStringSize(3, getMessageId());
094      }
095      if (hasMessage()) {
096         size += org.apache.activemq.protobuf.CodedOutputStream.computeBytesSize(4, getMessage());
097      }
098      if (hasPriority()) {
099         size += org.apache.activemq.protobuf.CodedOutputStream.computeInt32Size(5, getPriority());
100      }
101      if (hasPrioritySupported()) {
102         size += org.apache.activemq.protobuf.CodedOutputStream.computeBoolSize(6, getPrioritySupported());
103      }
104      memoizedSerializedSize = size;
105      return size;
106   }
107
108   public KahaAddMessageCommand mergeUnframed(org.apache.activemq.protobuf.CodedInputStream input) throws java.io.IOException {
109      while (true) {
110         int tag = input.readTag();
111         if ((tag & 0x07) == 4) {
112            return this;
113         }
114         switch (tag) {
115         case 0:
116            return this;
117         default: {
118            break;
119         }
120         case 10:
121            if (hasTransactionInfo()) {
122               getTransactionInfo().mergeFramed(input);
123            } else {
124               setTransactionInfo(new KahaTransactionInfo().mergeFramed(input));
125            }
126            break;
127         case 18:
128            if (hasDestination()) {
129               getDestination().mergeFramed(input);
130            } else {
131               setDestination(new KahaDestination().mergeFramed(input));
132            }
133            break;
134         case 26:
135            setMessageId(input.readString());
136            break;
137         case 34:
138            setMessage(input.readBytes());
139            break;
140         case 40:
141            setPriority(input.readInt32());
142            break;
143         case 48:
144            setPrioritySupported(input.readBool());
145            break;
146         }
147      }
148   }
149   public void writeUnframed(org.apache.activemq.protobuf.CodedOutputStream output) throws java.io.IOException {
150      if (hasTransactionInfo()) {
151         writeMessage(output, 1, getTransactionInfo());
152      }
153      if (hasDestination()) {
154         writeMessage(output, 2, getDestination());
155      }
156      if (hasMessageId()) {
157         output.writeString(3, getMessageId());
158      }
159      if (hasMessage()) {
160         output.writeBytes(4, getMessage());
161      }
162      if (hasPriority()) {
163         output.writeInt32(5, getPriority());
164      }
165      if (hasPrioritySupported()) {
166         output.writeBool(6, getPrioritySupported());
167      }
168   }
169
170   public static KahaAddMessageCommand parseUnframed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException {
171      return new KahaAddMessageCommand().mergeUnframed(data).checktInitialized();
172   }
173
174   public static KahaAddMessageCommand parseUnframed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException {
175      return new KahaAddMessageCommand().mergeUnframed(data).checktInitialized();
176   }
177
178   public static KahaAddMessageCommand parseUnframed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException {
179      return new KahaAddMessageCommand().mergeUnframed(data).checktInitialized();
180   }
181
182   public static KahaAddMessageCommand parseUnframed(java.io.InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException {
183      return new KahaAddMessageCommand().mergeUnframed(data).checktInitialized();
184   }
185
186   public static KahaAddMessageCommand parseFramed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException {
187      return new KahaAddMessageCommand().mergeFramed(data).checktInitialized();
188   }
189
190   public static KahaAddMessageCommand parseFramed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException {
191      return new KahaAddMessageCommand().mergeFramed(data).checktInitialized();
192   }
193
194   public static KahaAddMessageCommand parseFramed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException {
195      return new KahaAddMessageCommand().mergeFramed(data).checktInitialized();
196   }
197
198   public static KahaAddMessageCommand parseFramed(java.io.InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException {
199      return new KahaAddMessageCommand().mergeFramed(data).checktInitialized();
200   }
201
202   public String toString() {
203      return toString(new java.lang.StringBuilder(), "").toString();
204   }
205
206   public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix) {
207      if(  hasTransactionInfo() ) {
208         sb.append(prefix+"transaction_info {\n");
209         getTransactionInfo().toString(sb, prefix+"  ");
210         sb.append(prefix+"}\n");
211      }
212      if(  hasDestination() ) {
213         sb.append(prefix+"destination {\n");
214         getDestination().toString(sb, prefix+"  ");
215         sb.append(prefix+"}\n");
216      }
217      if(  hasMessageId() ) {
218         sb.append(prefix+"messageId: ");
219         sb.append(getMessageId());
220         sb.append("\n");
221      }
222      if(  hasMessage() ) {
223         sb.append(prefix+"message: ");
224         sb.append(getMessage());
225         sb.append("\n");
226      }
227      if(  hasPriority() ) {
228         sb.append(prefix+"priority: ");
229         sb.append(getPriority());
230         sb.append("\n");
231      }
232      if(  hasPrioritySupported() ) {
233         sb.append(prefix+"prioritySupported: ");
234         sb.append(getPrioritySupported());
235         sb.append("\n");
236      }
237      return sb;
238   }
239
240   public void visit(org.apache.activemq.store.kahadb.Visitor visitor) throws java.io.IOException {
241      visitor.visit(this);
242   }
243
244   public KahaEntryType type() {
245      return KahaEntryType.KAHA_ADD_MESSAGE_COMMAND;
246   }
247
248   public boolean equals(Object obj) {
249      if( obj==this )
250         return true;
251      
252      if( obj==null || obj.getClass()!=KahaAddMessageCommand.class )
253         return false;
254      
255      return equals((KahaAddMessageCommand)obj);
256   }
257   
258   public boolean equals(KahaAddMessageCommand obj) {
259      if (hasTransactionInfo() ^ obj.hasTransactionInfo() ) 
260         return false;
261      if (hasTransactionInfo() && ( !getTransactionInfo().equals(obj.getTransactionInfo()) ))
262         return false;
263      if (hasDestination() ^ obj.hasDestination() ) 
264         return false;
265      if (hasDestination() && ( !getDestination().equals(obj.getDestination()) ))
266         return false;
267      if (hasMessageId() ^ obj.hasMessageId() ) 
268         return false;
269      if (hasMessageId() && ( !getMessageId().equals(obj.getMessageId()) ))
270         return false;
271      if (hasMessage() ^ obj.hasMessage() ) 
272         return false;
273      if (hasMessage() && ( !getMessage().equals(obj.getMessage()) ))
274         return false;
275      if (hasPriority() ^ obj.hasPriority() ) 
276         return false;
277      if (hasPriority() && ( getPriority()!=obj.getPriority() ))
278         return false;
279      if (hasPrioritySupported() ^ obj.hasPrioritySupported() ) 
280         return false;
281      if (hasPrioritySupported() && ( getPrioritySupported()!=obj.getPrioritySupported() ))
282         return false;
283      return true;
284   }
285   
286   public int hashCode() {
287      int rc=1601475350;
288      if (hasTransactionInfo()) {
289         rc ^= ( 265667724^getTransactionInfo().hashCode() );
290      }
291      if (hasDestination()) {
292         rc ^= ( 238021614^getDestination().hashCode() );
293      }
294      if (hasMessageId()) {
295         rc ^= ( 563954530^getMessageId().hashCode() );
296      }
297      if (hasMessage()) {
298         rc ^= ( -1675388953^getMessage().hashCode() );
299      }
300      if (hasPriority()) {
301         rc ^= ( -1100816956^getPriority() );
302      }
303      if (hasPrioritySupported()) {
304         rc ^= ( 889475914^ (getPrioritySupported()? 6:-6) );
305      }
306      return rc;
307   }
308   
309}
310
311abstract class KahaAddMessageCommandBase<T> extends org.apache.activemq.protobuf.BaseMessage<T> {
312
313   // optional KahaTransactionInfo transaction_info = 1;
314   private KahaTransactionInfo f_transactionInfo = null;
315
316   public boolean hasTransactionInfo() {
317      return this.f_transactionInfo!=null;
318   }
319
320   public KahaTransactionInfo getTransactionInfo() {
321      if( this.f_transactionInfo == null ) {
322         this.f_transactionInfo = new KahaTransactionInfo();
323      }
324      return this.f_transactionInfo;
325   }
326
327   public T setTransactionInfo(KahaTransactionInfo transactionInfo) {
328      loadAndClear();
329      this.f_transactionInfo = transactionInfo;
330      return (T)this;
331   }
332
333   public void clearTransactionInfo() {
334      loadAndClear();
335      this.f_transactionInfo = null;
336   }
337
338   // required KahaDestination destination = 2;
339   private KahaDestination f_destination = null;
340
341   public boolean hasDestination() {
342      return this.f_destination!=null;
343   }
344
345   public KahaDestination getDestination() {
346      if( this.f_destination == null ) {
347         this.f_destination = new KahaDestination();
348      }
349      return this.f_destination;
350   }
351
352   public T setDestination(KahaDestination destination) {
353      loadAndClear();
354      this.f_destination = destination;
355      return (T)this;
356   }
357
358   public void clearDestination() {
359      loadAndClear();
360      this.f_destination = null;
361   }
362
363   // required string messageId = 3;
364   private java.lang.String f_messageId = null;
365   private boolean b_messageId;
366
367   public boolean hasMessageId() {
368      return this.b_messageId;
369   }
370
371   public java.lang.String getMessageId() {
372      return this.f_messageId;
373   }
374
375   public T setMessageId(java.lang.String messageId) {
376      loadAndClear();
377      this.b_messageId = true;
378      this.f_messageId = messageId;
379      return (T)this;
380   }
381
382   public void clearMessageId() {
383      loadAndClear();
384      this.b_messageId = false;
385      this.f_messageId = null;
386   }
387
388   // required bytes message = 4;
389   private org.apache.activemq.protobuf.Buffer f_message = null;
390   private boolean b_message;
391
392   public boolean hasMessage() {
393      return this.b_message;
394   }
395
396   public org.apache.activemq.protobuf.Buffer getMessage() {
397      return this.f_message;
398   }
399
400   public T setMessage(org.apache.activemq.protobuf.Buffer message) {
401      loadAndClear();
402      this.b_message = true;
403      this.f_message = message;
404      return (T)this;
405   }
406
407   public void clearMessage() {
408      loadAndClear();
409      this.b_message = false;
410      this.f_message = null;
411   }
412
413   // optional int32 priority = 5;
414   private int f_priority = 4;
415   private boolean b_priority;
416
417   public boolean hasPriority() {
418      return this.b_priority;
419   }
420
421   public int getPriority() {
422      return this.f_priority;
423   }
424
425   public T setPriority(int priority) {
426      loadAndClear();
427      this.b_priority = true;
428      this.f_priority = priority;
429      return (T)this;
430   }
431
432   public void clearPriority() {
433      loadAndClear();
434      this.b_priority = false;
435      this.f_priority = 4;
436   }
437
438   // optional bool prioritySupported = 6;
439   private boolean f_prioritySupported = false;
440   private boolean b_prioritySupported;
441
442   public boolean hasPrioritySupported() {
443      return this.b_prioritySupported;
444   }
445
446   public boolean getPrioritySupported() {
447      return this.f_prioritySupported;
448   }
449
450   public T setPrioritySupported(boolean prioritySupported) {
451      loadAndClear();
452      this.b_prioritySupported = true;
453      this.f_prioritySupported = prioritySupported;
454      return (T)this;
455   }
456
457   public void clearPrioritySupported() {
458      loadAndClear();
459      this.b_prioritySupported = false;
460      this.f_prioritySupported = false;
461   }
462
463}
464