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