001//
002// Generated by protoc, do not edit by hand.
003//
004package org.apache.activemq.store.kahadb.data;
005
006
007public final class KahaLocalTransactionId extends KahaLocalTransactionIdBase<KahaLocalTransactionId> {
008
009   public java.util.ArrayList<String> missingFields() {
010      java.util.ArrayList<String> missingFields = super.missingFields();
011      if(  !hasConnectionId() ) {
012         missingFields.add("connection_id");
013      }
014      if(  !hasTransactionId() ) {
015         missingFields.add("transaction_id");
016      }
017      return missingFields;
018   }
019
020   public void clear() {
021      super.clear();
022      clearConnectionId();
023      clearTransactionId();
024   }
025
026   public KahaLocalTransactionId clone() {
027      return new KahaLocalTransactionId().mergeFrom(this);
028   }
029
030   public KahaLocalTransactionId mergeFrom(KahaLocalTransactionId other) {
031      if (other.hasConnectionId()) {
032         setConnectionId(other.getConnectionId());
033      }
034      if (other.hasTransactionId()) {
035         setTransactionId(other.getTransactionId());
036      }
037      return this;
038   }
039
040   public int serializedSizeUnframed() {
041      if (memoizedSerializedSize != -1)
042         return memoizedSerializedSize;
043
044      int size = 0;
045      if (hasConnectionId()) {
046         size += org.apache.activemq.protobuf.CodedOutputStream.computeStringSize(1, getConnectionId());
047      }
048      if (hasTransactionId()) {
049         size += org.apache.activemq.protobuf.CodedOutputStream.computeInt64Size(1, getTransactionId());
050      }
051      memoizedSerializedSize = size;
052      return size;
053   }
054
055   public KahaLocalTransactionId mergeUnframed(org.apache.activemq.protobuf.CodedInputStream input) throws java.io.IOException {
056      while (true) {
057         int tag = input.readTag();
058         if ((tag & 0x07) == 4) {
059            return this;
060         }
061         switch (tag) {
062         case 0:
063            return this;
064         default: {
065            break;
066         }
067         case 10:
068            setConnectionId(input.readString());
069            break;
070         case 8:
071            setTransactionId(input.readInt64());
072            break;
073         }
074      }
075   }
076   public void writeUnframed(org.apache.activemq.protobuf.CodedOutputStream output) throws java.io.IOException {
077      if (hasConnectionId()) {
078         output.writeString(1, getConnectionId());
079      }
080      if (hasTransactionId()) {
081         output.writeInt64(1, getTransactionId());
082      }
083   }
084
085   public static KahaLocalTransactionId parseUnframed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException {
086      return new KahaLocalTransactionId().mergeUnframed(data).checktInitialized();
087   }
088
089   public static KahaLocalTransactionId parseUnframed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException {
090      return new KahaLocalTransactionId().mergeUnframed(data).checktInitialized();
091   }
092
093   public static KahaLocalTransactionId parseUnframed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException {
094      return new KahaLocalTransactionId().mergeUnframed(data).checktInitialized();
095   }
096
097   public static KahaLocalTransactionId parseUnframed(java.io.InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException {
098      return new KahaLocalTransactionId().mergeUnframed(data).checktInitialized();
099   }
100
101   public static KahaLocalTransactionId parseFramed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException {
102      return new KahaLocalTransactionId().mergeFramed(data).checktInitialized();
103   }
104
105   public static KahaLocalTransactionId parseFramed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException {
106      return new KahaLocalTransactionId().mergeFramed(data).checktInitialized();
107   }
108
109   public static KahaLocalTransactionId parseFramed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException {
110      return new KahaLocalTransactionId().mergeFramed(data).checktInitialized();
111   }
112
113   public static KahaLocalTransactionId parseFramed(java.io.InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException {
114      return new KahaLocalTransactionId().mergeFramed(data).checktInitialized();
115   }
116
117   public String toString() {
118      return toString(new java.lang.StringBuilder(), "").toString();
119   }
120
121   public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix) {
122      if(  hasConnectionId() ) {
123         sb.append(prefix+"connection_id: ");
124         sb.append(getConnectionId());
125         sb.append("\n");
126      }
127      if(  hasTransactionId() ) {
128         sb.append(prefix+"transaction_id: ");
129         sb.append(getTransactionId());
130         sb.append("\n");
131      }
132      return sb;
133   }
134
135   public boolean equals(Object obj) {
136      if( obj==this )
137         return true;
138      
139      if( obj==null || obj.getClass()!=KahaLocalTransactionId.class )
140         return false;
141      
142      return equals((KahaLocalTransactionId)obj);
143   }
144   
145   public boolean equals(KahaLocalTransactionId obj) {
146      if (hasConnectionId() ^ obj.hasConnectionId() ) 
147         return false;
148      if (hasConnectionId() && ( !getConnectionId().equals(obj.getConnectionId()) ))
149         return false;
150      if (hasTransactionId() ^ obj.hasTransactionId() ) 
151         return false;
152      if (hasTransactionId() && ( getTransactionId()!=obj.getTransactionId() ))
153         return false;
154      return true;
155   }
156   
157   public int hashCode() {
158      int rc=1725637181;
159      if (hasConnectionId()) {
160         rc ^= ( 2087427257^getConnectionId().hashCode() );
161      }
162      if (hasTransactionId()) {
163         rc ^= ( 1247202425^(new Long(getTransactionId())).hashCode() );
164      }
165      return rc;
166   }
167   
168}
169
170abstract class KahaLocalTransactionIdBase<T> extends org.apache.activemq.protobuf.BaseMessage<T> {
171
172   // required string connection_id = 1;
173   private java.lang.String f_connectionId = null;
174   private boolean b_connectionId;
175
176   public boolean hasConnectionId() {
177      return this.b_connectionId;
178   }
179
180   public java.lang.String getConnectionId() {
181      return this.f_connectionId;
182   }
183
184   public T setConnectionId(java.lang.String connectionId) {
185      loadAndClear();
186      this.b_connectionId = true;
187      this.f_connectionId = connectionId;
188      return (T)this;
189   }
190
191   public void clearConnectionId() {
192      loadAndClear();
193      this.b_connectionId = false;
194      this.f_connectionId = null;
195   }
196
197   // required int64 transaction_id = 1;
198   private long f_transactionId = 0;
199   private boolean b_transactionId;
200
201   public boolean hasTransactionId() {
202      return this.b_transactionId;
203   }
204
205   public long getTransactionId() {
206      return this.f_transactionId;
207   }
208
209   public T setTransactionId(long transactionId) {
210      loadAndClear();
211      this.b_transactionId = true;
212      this.f_transactionId = transactionId;
213      return (T)this;
214   }
215
216   public void clearTransactionId() {
217      loadAndClear();
218      this.b_transactionId = false;
219      this.f_transactionId = 0;
220   }
221
222}
223