Class KahaRemoveScheduledJobCommand
- java.lang.Object
-
- org.apache.activemq.protobuf.BaseMessage<T>
-
- org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
-
- All Implemented Interfaces:
org.apache.activemq.protobuf.Message<KahaRemoveScheduledJobCommand>,JournalCommand<KahaRemoveScheduledJobCommand>
public final class KahaRemoveScheduledJobCommand extends org.apache.activemq.protobuf.BaseMessage<T> implements JournalCommand<KahaRemoveScheduledJobCommand>
-
-
Constructor Summary
Constructors Constructor Description KahaRemoveScheduledJobCommand()
-
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:
missingFieldsin classorg.apache.activemq.protobuf.BaseMessage<KahaRemoveScheduledJobCommand>
-
clear
public void clear()
- Specified by:
clearin interfaceorg.apache.activemq.protobuf.Message<KahaRemoveScheduledJobCommand>- Overrides:
clearin classorg.apache.activemq.protobuf.BaseMessage<KahaRemoveScheduledJobCommand>
-
clone
public KahaRemoveScheduledJobCommand clone()
- Specified by:
clonein interfaceorg.apache.activemq.protobuf.Message<KahaRemoveScheduledJobCommand>- Specified by:
clonein classorg.apache.activemq.protobuf.BaseMessage<KahaRemoveScheduledJobCommand>
-
mergeFrom
public KahaRemoveScheduledJobCommand mergeFrom(KahaRemoveScheduledJobCommand other)
- Specified by:
mergeFromin interfaceorg.apache.activemq.protobuf.Message<KahaRemoveScheduledJobCommand>- Overrides:
mergeFromin classorg.apache.activemq.protobuf.BaseMessage<KahaRemoveScheduledJobCommand>
-
serializedSizeUnframed
public int serializedSizeUnframed()
- Specified by:
serializedSizeUnframedin interfaceorg.apache.activemq.protobuf.Message<KahaRemoveScheduledJobCommand>
-
mergeUnframed
public KahaRemoveScheduledJobCommand mergeUnframed(org.apache.activemq.protobuf.CodedInputStream input) throws IOException
- Specified by:
mergeUnframedin interfaceorg.apache.activemq.protobuf.Message<KahaRemoveScheduledJobCommand>- Throws:
IOException
-
writeUnframed
public void writeUnframed(org.apache.activemq.protobuf.CodedOutputStream output) throws IOException- Specified by:
writeUnframedin interfaceorg.apache.activemq.protobuf.Message<KahaRemoveScheduledJobCommand>- Overrides:
writeUnframedin classorg.apache.activemq.protobuf.BaseMessage<KahaRemoveScheduledJobCommand>- Throws:
IOException
-
parseUnframed
public static KahaRemoveScheduledJobCommand parseUnframed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferExceptionIOException
-
parseUnframed
public static KahaRemoveScheduledJobCommand parseUnframed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
-
parseUnframed
public static KahaRemoveScheduledJobCommand parseUnframed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
-
parseUnframed
public static KahaRemoveScheduledJobCommand parseUnframed(InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferExceptionIOException
-
parseFramed
public static KahaRemoveScheduledJobCommand parseFramed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferExceptionIOException
-
parseFramed
public static KahaRemoveScheduledJobCommand parseFramed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
-
parseFramed
public static KahaRemoveScheduledJobCommand parseFramed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
-
parseFramed
public static KahaRemoveScheduledJobCommand parseFramed(InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferExceptionIOException
-
toString
public StringBuilder toString(StringBuilder sb, String prefix)
-
visit
public void visit(Visitor visitor) throws IOException
- Specified by:
visitin interfaceJournalCommand<KahaRemoveScheduledJobCommand>- Throws:
IOException
-
type
public KahaEntryType type()
- Specified by:
typein interfaceJournalCommand<KahaRemoveScheduledJobCommand>
-
equals
public boolean equals(KahaRemoveScheduledJobCommand obj)
-
hasScheduler
public boolean hasScheduler()
-
getScheduler
public String getScheduler()
-
setScheduler
public T setScheduler(String scheduler)
-
clearScheduler
public void clearScheduler()
-
hasJobId
public boolean hasJobId()
-
getJobId
public String getJobId()
-
setJobId
public T setJobId(String jobId)
-
clearJobId
public void clearJobId()
-
hasNextExecutionTime
public boolean hasNextExecutionTime()
-
getNextExecutionTime
public long getNextExecutionTime()
-
setNextExecutionTime
public T setNextExecutionTime(long nextExecutionTime)
-
clearNextExecutionTime
public void clearNextExecutionTime()
-
-