001//
002// Generated by protoc, do not edit by hand.
003//
004package org.apache.activemq.store.kahadb.data;
005
006
007public final class KahaRemoveScheduledJobsCommand extends KahaRemoveScheduledJobsCommandBase<KahaRemoveScheduledJobsCommand> implements org.apache.activemq.store.kahadb.JournalCommand<KahaRemoveScheduledJobsCommand> {
008
009   public java.util.ArrayList<String> missingFields() {
010      java.util.ArrayList<String> missingFields = super.missingFields();
011      if(  !hasScheduler() ) {
012         missingFields.add("scheduler");
013      }
014      if(  !hasStartTime() ) {
015         missingFields.add("start_time");
016      }
017      if(  !hasEndTime() ) {
018         missingFields.add("end_time");
019      }
020      return missingFields;
021   }
022
023   public void clear() {
024      super.clear();
025      clearScheduler();
026      clearStartTime();
027      clearEndTime();
028   }
029
030   public KahaRemoveScheduledJobsCommand clone() {
031      return new KahaRemoveScheduledJobsCommand().mergeFrom(this);
032   }
033
034   public KahaRemoveScheduledJobsCommand mergeFrom(KahaRemoveScheduledJobsCommand other) {
035      if (other.hasScheduler()) {
036         setScheduler(other.getScheduler());
037      }
038      if (other.hasStartTime()) {
039         setStartTime(other.getStartTime());
040      }
041      if (other.hasEndTime()) {
042         setEndTime(other.getEndTime());
043      }
044      return this;
045   }
046
047   public int serializedSizeUnframed() {
048      if (memoizedSerializedSize != -1)
049         return memoizedSerializedSize;
050
051      int size = 0;
052      if (hasScheduler()) {
053         size += org.apache.activemq.protobuf.CodedOutputStream.computeStringSize(1, getScheduler());
054      }
055      if (hasStartTime()) {
056         size += org.apache.activemq.protobuf.CodedOutputStream.computeInt64Size(2, getStartTime());
057      }
058      if (hasEndTime()) {
059         size += org.apache.activemq.protobuf.CodedOutputStream.computeInt64Size(3, getEndTime());
060      }
061      memoizedSerializedSize = size;
062      return size;
063   }
064
065   public KahaRemoveScheduledJobsCommand mergeUnframed(org.apache.activemq.protobuf.CodedInputStream input) throws java.io.IOException {
066      while (true) {
067         int tag = input.readTag();
068         if ((tag & 0x07) == 4) {
069            return this;
070         }
071         switch (tag) {
072         case 0:
073            return this;
074         default: {
075            break;
076         }
077         case 10:
078            setScheduler(input.readString());
079            break;
080         case 16:
081            setStartTime(input.readInt64());
082            break;
083         case 24:
084            setEndTime(input.readInt64());
085            break;
086         }
087      }
088   }
089   public void writeUnframed(org.apache.activemq.protobuf.CodedOutputStream output) throws java.io.IOException {
090      if (hasScheduler()) {
091         output.writeString(1, getScheduler());
092      }
093      if (hasStartTime()) {
094         output.writeInt64(2, getStartTime());
095      }
096      if (hasEndTime()) {
097         output.writeInt64(3, getEndTime());
098      }
099   }
100
101   public static KahaRemoveScheduledJobsCommand parseUnframed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException {
102      return new KahaRemoveScheduledJobsCommand().mergeUnframed(data).checktInitialized();
103   }
104
105   public static KahaRemoveScheduledJobsCommand parseUnframed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException {
106      return new KahaRemoveScheduledJobsCommand().mergeUnframed(data).checktInitialized();
107   }
108
109   public static KahaRemoveScheduledJobsCommand parseUnframed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException {
110      return new KahaRemoveScheduledJobsCommand().mergeUnframed(data).checktInitialized();
111   }
112
113   public static KahaRemoveScheduledJobsCommand parseUnframed(java.io.InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException {
114      return new KahaRemoveScheduledJobsCommand().mergeUnframed(data).checktInitialized();
115   }
116
117   public static KahaRemoveScheduledJobsCommand parseFramed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException {
118      return new KahaRemoveScheduledJobsCommand().mergeFramed(data).checktInitialized();
119   }
120
121   public static KahaRemoveScheduledJobsCommand parseFramed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException {
122      return new KahaRemoveScheduledJobsCommand().mergeFramed(data).checktInitialized();
123   }
124
125   public static KahaRemoveScheduledJobsCommand parseFramed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException {
126      return new KahaRemoveScheduledJobsCommand().mergeFramed(data).checktInitialized();
127   }
128
129   public static KahaRemoveScheduledJobsCommand parseFramed(java.io.InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException {
130      return new KahaRemoveScheduledJobsCommand().mergeFramed(data).checktInitialized();
131   }
132
133   public String toString() {
134      return toString(new java.lang.StringBuilder(), "").toString();
135   }
136
137   public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix) {
138      if(  hasScheduler() ) {
139         sb.append(prefix+"scheduler: ");
140         sb.append(getScheduler());
141         sb.append("\n");
142      }
143      if(  hasStartTime() ) {
144         sb.append(prefix+"start_time: ");
145         sb.append(getStartTime());
146         sb.append("\n");
147      }
148      if(  hasEndTime() ) {
149         sb.append(prefix+"end_time: ");
150         sb.append(getEndTime());
151         sb.append("\n");
152      }
153      return sb;
154   }
155
156   public void visit(org.apache.activemq.store.kahadb.Visitor visitor) throws java.io.IOException {
157      visitor.visit(this);
158   }
159
160   public KahaEntryType type() {
161      return KahaEntryType.KAHA_REMOVE_SCHEDULED_JOBS_COMMAND;
162   }
163
164   public boolean equals(Object obj) {
165      if( obj==this )
166         return true;
167      
168      if( obj==null || obj.getClass()!=KahaRemoveScheduledJobsCommand.class )
169         return false;
170      
171      return equals((KahaRemoveScheduledJobsCommand)obj);
172   }
173   
174   public boolean equals(KahaRemoveScheduledJobsCommand obj) {
175      if (hasScheduler() ^ obj.hasScheduler() ) 
176         return false;
177      if (hasScheduler() && ( !getScheduler().equals(obj.getScheduler()) ))
178         return false;
179      if (hasStartTime() ^ obj.hasStartTime() ) 
180         return false;
181      if (hasStartTime() && ( getStartTime()!=obj.getStartTime() ))
182         return false;
183      if (hasEndTime() ^ obj.hasEndTime() ) 
184         return false;
185      if (hasEndTime() && ( getEndTime()!=obj.getEndTime() ))
186         return false;
187      return true;
188   }
189   
190   public int hashCode() {
191      int rc=2030791195;
192      if (hasScheduler()) {
193         rc ^= ( 1843257499^getScheduler().hashCode() );
194      }
195      if (hasStartTime()) {
196         rc ^= ( -125326801^(new Long(getStartTime())).hashCode() );
197      }
198      if (hasEndTime()) {
199         rc ^= ( 57410088^(new Long(getEndTime())).hashCode() );
200      }
201      return rc;
202   }
203   
204}
205
206abstract class KahaRemoveScheduledJobsCommandBase<T> extends org.apache.activemq.protobuf.BaseMessage<T> {
207
208   // required string scheduler = 1;
209   private java.lang.String f_scheduler = null;
210   private boolean b_scheduler;
211
212   public boolean hasScheduler() {
213      return this.b_scheduler;
214   }
215
216   public java.lang.String getScheduler() {
217      return this.f_scheduler;
218   }
219
220   public T setScheduler(java.lang.String scheduler) {
221      loadAndClear();
222      this.b_scheduler = true;
223      this.f_scheduler = scheduler;
224      return (T)this;
225   }
226
227   public void clearScheduler() {
228      loadAndClear();
229      this.b_scheduler = false;
230      this.f_scheduler = null;
231   }
232
233   // required int64 start_time = 2;
234   private long f_startTime = 0;
235   private boolean b_startTime;
236
237   public boolean hasStartTime() {
238      return this.b_startTime;
239   }
240
241   public long getStartTime() {
242      return this.f_startTime;
243   }
244
245   public T setStartTime(long startTime) {
246      loadAndClear();
247      this.b_startTime = true;
248      this.f_startTime = startTime;
249      return (T)this;
250   }
251
252   public void clearStartTime() {
253      loadAndClear();
254      this.b_startTime = false;
255      this.f_startTime = 0;
256   }
257
258   // required int64 end_time = 3;
259   private long f_endTime = 0;
260   private boolean b_endTime;
261
262   public boolean hasEndTime() {
263      return this.b_endTime;
264   }
265
266   public long getEndTime() {
267      return this.f_endTime;
268   }
269
270   public T setEndTime(long endTime) {
271      loadAndClear();
272      this.b_endTime = true;
273      this.f_endTime = endTime;
274      return (T)this;
275   }
276
277   public void clearEndTime() {
278      loadAndClear();
279      this.b_endTime = false;
280      this.f_endTime = 0;
281   }
282
283}
284