001 // 002 // Generated by protoc, do not edit by hand. 003 // 004 package org.apache.activemq.store.kahadb.data; 005 006 007 public final class KahaTraceCommand extends KahaTraceCommandBase<KahaTraceCommand> implements org.apache.activemq.store.kahadb.JournalCommand<KahaTraceCommand> { 008 009 public java.util.ArrayList<String> missingFields() { 010 java.util.ArrayList<String> missingFields = super.missingFields(); 011 if( !hasMessage() ) { 012 missingFields.add("message"); 013 } 014 return missingFields; 015 } 016 017 public void clear() { 018 super.clear(); 019 clearMessage(); 020 } 021 022 public KahaTraceCommand clone() { 023 return new KahaTraceCommand().mergeFrom(this); 024 } 025 026 public KahaTraceCommand mergeFrom(KahaTraceCommand other) { 027 if (other.hasMessage()) { 028 setMessage(other.getMessage()); 029 } 030 return this; 031 } 032 033 public int serializedSizeUnframed() { 034 if (memoizedSerializedSize != -1) 035 return memoizedSerializedSize; 036 037 int size = 0; 038 if (hasMessage()) { 039 size += org.apache.activemq.protobuf.CodedOutputStream.computeStringSize(1, getMessage()); 040 } 041 memoizedSerializedSize = size; 042 return size; 043 } 044 045 public KahaTraceCommand mergeUnframed(org.apache.activemq.protobuf.CodedInputStream input) throws java.io.IOException { 046 while (true) { 047 int tag = input.readTag(); 048 if ((tag & 0x07) == 4) { 049 return this; 050 } 051 switch (tag) { 052 case 0: 053 return this; 054 default: { 055 break; 056 } 057 case 10: 058 setMessage(input.readString()); 059 break; 060 } 061 } 062 } 063 public void writeUnframed(org.apache.activemq.protobuf.CodedOutputStream output) throws java.io.IOException { 064 if (hasMessage()) { 065 output.writeString(1, getMessage()); 066 } 067 } 068 069 public static KahaTraceCommand parseUnframed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException { 070 return new KahaTraceCommand().mergeUnframed(data).checktInitialized(); 071 } 072 073 public static KahaTraceCommand parseUnframed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException { 074 return new KahaTraceCommand().mergeUnframed(data).checktInitialized(); 075 } 076 077 public static KahaTraceCommand parseUnframed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException { 078 return new KahaTraceCommand().mergeUnframed(data).checktInitialized(); 079 } 080 081 public static KahaTraceCommand parseUnframed(java.io.InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException { 082 return new KahaTraceCommand().mergeUnframed(data).checktInitialized(); 083 } 084 085 public static KahaTraceCommand parseFramed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException { 086 return new KahaTraceCommand().mergeFramed(data).checktInitialized(); 087 } 088 089 public static KahaTraceCommand parseFramed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException { 090 return new KahaTraceCommand().mergeFramed(data).checktInitialized(); 091 } 092 093 public static KahaTraceCommand parseFramed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException { 094 return new KahaTraceCommand().mergeFramed(data).checktInitialized(); 095 } 096 097 public static KahaTraceCommand parseFramed(java.io.InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, java.io.IOException { 098 return new KahaTraceCommand().mergeFramed(data).checktInitialized(); 099 } 100 101 public String toString() { 102 return toString(new java.lang.StringBuilder(), "").toString(); 103 } 104 105 public java.lang.StringBuilder toString(java.lang.StringBuilder sb, String prefix) { 106 if( hasMessage() ) { 107 sb.append(prefix+"message: "); 108 sb.append(getMessage()); 109 sb.append("\n"); 110 } 111 return sb; 112 } 113 114 public void visit(org.apache.activemq.store.kahadb.Visitor visitor) throws java.io.IOException { 115 visitor.visit(this); 116 } 117 118 public KahaEntryType type() { 119 return KahaEntryType.KAHA_TRACE_COMMAND; 120 } 121 122 public boolean equals(Object obj) { 123 if( obj==this ) 124 return true; 125 126 if( obj==null || obj.getClass()!=KahaTraceCommand.class ) 127 return false; 128 129 return equals((KahaTraceCommand)obj); 130 } 131 132 public boolean equals(KahaTraceCommand obj) { 133 if (hasMessage() ^ obj.hasMessage() ) 134 return false; 135 if (hasMessage() && ( !getMessage().equals(obj.getMessage()) )) 136 return false; 137 return true; 138 } 139 140 public int hashCode() { 141 int rc=-1782549291; 142 if (hasMessage()) { 143 rc ^= ( -1675388953^getMessage().hashCode() ); 144 } 145 return rc; 146 } 147 148 } 149 150 abstract class KahaTraceCommandBase<T> extends org.apache.activemq.protobuf.BaseMessage<T> { 151 152 // required string message = 1; 153 private java.lang.String f_message = null; 154 private boolean b_message; 155 156 public boolean hasMessage() { 157 return this.b_message; 158 } 159 160 public java.lang.String getMessage() { 161 return this.f_message; 162 } 163 164 public T setMessage(java.lang.String message) { 165 loadAndClear(); 166 this.b_message = true; 167 this.f_message = message; 168 return (T)this; 169 } 170 171 public void clearMessage() { 172 loadAndClear(); 173 this.b_message = false; 174 this.f_message = null; 175 } 176 177 } 178