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