Class KahaRewrittenDataFileCommand
- java.lang.Object
-
- org.apache.activemq.protobuf.BaseMessage<T>
-
- org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
-
- All Implemented Interfaces:
org.apache.activemq.protobuf.Message<KahaRewrittenDataFileCommand>
,JournalCommand<KahaRewrittenDataFileCommand>
public final class KahaRewrittenDataFileCommand extends org.apache.activemq.protobuf.BaseMessage<T> implements JournalCommand<KahaRewrittenDataFileCommand>
-
-
Constructor Summary
Constructors Constructor Description KahaRewrittenDataFileCommand()
-
Method Summary
-
Methods inherited from class org.apache.activemq.protobuf.BaseMessage
addAll, assertInitialized, checktInitialized, computeGroupSize, computeMessageSize, isInitialized, load, loadAndClear, mergeFramed, mergeFramed, mergeFramed, mergeFramed, mergeUnframed, mergeUnframed, mergeUnframed, prefix, readGroup, readRawByte, readRawVarint32, serializedSizeFramed, toFramedBuffer, toFramedByteArray, toUnframedBuffer, toUnframedByteArray, writeFramed, writeFramed, writeGroup, writeMessage, writeUnframed
-
Methods inherited from class java.lang.Object
finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.activemq.protobuf.Message
assertInitialized, mergeFramed, mergeFramed, mergeFramed, mergeFramed, mergeUnframed, mergeUnframed, mergeUnframed, serializedSizeFramed, toFramedBuffer, toFramedByteArray, toUnframedBuffer, toUnframedByteArray, writeFramed, writeFramed, writeUnframed
-
-
-
-
Method Detail
-
missingFields
public ArrayList<String> missingFields()
- Overrides:
missingFields
in classorg.apache.activemq.protobuf.BaseMessage<KahaRewrittenDataFileCommand>
-
clear
public void clear()
- Specified by:
clear
in interfaceorg.apache.activemq.protobuf.Message<KahaRewrittenDataFileCommand>
- Overrides:
clear
in classorg.apache.activemq.protobuf.BaseMessage<KahaRewrittenDataFileCommand>
-
clone
public KahaRewrittenDataFileCommand clone()
- Specified by:
clone
in interfaceorg.apache.activemq.protobuf.Message<KahaRewrittenDataFileCommand>
- Specified by:
clone
in classorg.apache.activemq.protobuf.BaseMessage<KahaRewrittenDataFileCommand>
-
mergeFrom
public KahaRewrittenDataFileCommand mergeFrom(KahaRewrittenDataFileCommand other)
- Specified by:
mergeFrom
in interfaceorg.apache.activemq.protobuf.Message<KahaRewrittenDataFileCommand>
- Overrides:
mergeFrom
in classorg.apache.activemq.protobuf.BaseMessage<KahaRewrittenDataFileCommand>
-
serializedSizeUnframed
public int serializedSizeUnframed()
- Specified by:
serializedSizeUnframed
in interfaceorg.apache.activemq.protobuf.Message<KahaRewrittenDataFileCommand>
-
mergeUnframed
public KahaRewrittenDataFileCommand mergeUnframed(org.apache.activemq.protobuf.CodedInputStream input) throws IOException
- Specified by:
mergeUnframed
in interfaceorg.apache.activemq.protobuf.Message<KahaRewrittenDataFileCommand>
- Throws:
IOException
-
writeUnframed
public void writeUnframed(org.apache.activemq.protobuf.CodedOutputStream output) throws IOException
- Specified by:
writeUnframed
in interfaceorg.apache.activemq.protobuf.Message<KahaRewrittenDataFileCommand>
- Overrides:
writeUnframed
in classorg.apache.activemq.protobuf.BaseMessage<KahaRewrittenDataFileCommand>
- Throws:
IOException
-
parseUnframed
public static KahaRewrittenDataFileCommand parseUnframed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
IOException
-
parseUnframed
public static KahaRewrittenDataFileCommand parseUnframed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
-
parseUnframed
public static KahaRewrittenDataFileCommand parseUnframed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
-
parseUnframed
public static KahaRewrittenDataFileCommand parseUnframed(InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
IOException
-
parseFramed
public static KahaRewrittenDataFileCommand parseFramed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
IOException
-
parseFramed
public static KahaRewrittenDataFileCommand parseFramed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
-
parseFramed
public static KahaRewrittenDataFileCommand parseFramed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
-
parseFramed
public static KahaRewrittenDataFileCommand parseFramed(InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
IOException
-
toString
public StringBuilder toString(StringBuilder sb, String prefix)
-
visit
public void visit(Visitor visitor) throws IOException
- Specified by:
visit
in interfaceJournalCommand<KahaRewrittenDataFileCommand>
- Throws:
IOException
-
type
public KahaEntryType type()
- Specified by:
type
in interfaceJournalCommand<KahaRewrittenDataFileCommand>
-
equals
public boolean equals(KahaRewrittenDataFileCommand obj)
-
hasSourceDataFileId
public boolean hasSourceDataFileId()
-
getSourceDataFileId
public int getSourceDataFileId()
-
setSourceDataFileId
public T setSourceDataFileId(int sourceDataFileId)
-
clearSourceDataFileId
public void clearSourceDataFileId()
-
hasRewriteType
public boolean hasRewriteType()
-
getRewriteType
public int getRewriteType()
-
setRewriteType
public T setRewriteType(int rewriteType)
-
clearRewriteType
public void clearRewriteType()
-
hasSkipIfSourceExists
public boolean hasSkipIfSourceExists()
-
getSkipIfSourceExists
public boolean getSkipIfSourceExists()
-
setSkipIfSourceExists
public T setSkipIfSourceExists(boolean skipIfSourceExists)
-
clearSkipIfSourceExists
public void clearSkipIfSourceExists()
-
-