public final class KahaAddMessageCommand extends org.apache.activemq.protobuf.BaseMessage<T> implements JournalCommand<KahaAddMessageCommand>
Constructor and Description |
---|
KahaAddMessageCommand() |
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
finalize, getClass, notify, notifyAll, wait, wait, wait
assertInitialized, mergeFramed, mergeFramed, mergeFramed, mergeFramed, mergeUnframed, mergeUnframed, mergeUnframed, serializedSizeFramed, toFramedBuffer, toFramedByteArray, toUnframedBuffer, toUnframedByteArray, writeFramed, writeFramed, writeUnframed
public ArrayList<String> missingFields()
missingFields
in class org.apache.activemq.protobuf.BaseMessage<KahaAddMessageCommand>
public void clear()
clear
in interface org.apache.activemq.protobuf.Message<KahaAddMessageCommand>
clear
in class org.apache.activemq.protobuf.BaseMessage<KahaAddMessageCommand>
public KahaAddMessageCommand clone()
clone
in interface org.apache.activemq.protobuf.Message<KahaAddMessageCommand>
clone
in class org.apache.activemq.protobuf.BaseMessage<KahaAddMessageCommand>
public KahaAddMessageCommand mergeFrom(KahaAddMessageCommand other)
mergeFrom
in interface org.apache.activemq.protobuf.Message<KahaAddMessageCommand>
mergeFrom
in class org.apache.activemq.protobuf.BaseMessage<KahaAddMessageCommand>
public int serializedSizeUnframed()
serializedSizeUnframed
in interface org.apache.activemq.protobuf.Message<KahaAddMessageCommand>
public KahaAddMessageCommand mergeUnframed(org.apache.activemq.protobuf.CodedInputStream input) throws IOException
mergeUnframed
in interface org.apache.activemq.protobuf.Message<KahaAddMessageCommand>
IOException
public void writeUnframed(org.apache.activemq.protobuf.CodedOutputStream output) throws IOException
writeUnframed
in interface org.apache.activemq.protobuf.Message<KahaAddMessageCommand>
writeUnframed
in class org.apache.activemq.protobuf.BaseMessage<KahaAddMessageCommand>
IOException
public static KahaAddMessageCommand parseUnframed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
org.apache.activemq.protobuf.InvalidProtocolBufferException
IOException
public static KahaAddMessageCommand parseUnframed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
org.apache.activemq.protobuf.InvalidProtocolBufferException
public static KahaAddMessageCommand parseUnframed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
org.apache.activemq.protobuf.InvalidProtocolBufferException
public static KahaAddMessageCommand parseUnframed(InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
org.apache.activemq.protobuf.InvalidProtocolBufferException
IOException
public static KahaAddMessageCommand parseFramed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
org.apache.activemq.protobuf.InvalidProtocolBufferException
IOException
public static KahaAddMessageCommand parseFramed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
org.apache.activemq.protobuf.InvalidProtocolBufferException
public static KahaAddMessageCommand parseFramed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
org.apache.activemq.protobuf.InvalidProtocolBufferException
public static KahaAddMessageCommand parseFramed(InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
org.apache.activemq.protobuf.InvalidProtocolBufferException
IOException
public StringBuilder toString(StringBuilder sb, String prefix)
public void visit(Visitor visitor) throws IOException
visit
in interface JournalCommand<KahaAddMessageCommand>
IOException
public KahaEntryType type()
type
in interface JournalCommand<KahaAddMessageCommand>
public boolean equals(KahaAddMessageCommand obj)
public boolean hasTransactionInfo()
public KahaTransactionInfo getTransactionInfo()
public T setTransactionInfo(KahaTransactionInfo transactionInfo)
public void clearTransactionInfo()
public boolean hasDestination()
public KahaDestination getDestination()
public T setDestination(KahaDestination destination)
public void clearDestination()
public boolean hasMessageId()
public String getMessageId()
public T setMessageId(String messageId)
public void clearMessageId()
public boolean hasMessage()
public org.apache.activemq.protobuf.Buffer getMessage()
public T setMessage(org.apache.activemq.protobuf.Buffer message)
public void clearMessage()
public boolean hasPriority()
public int getPriority()
public T setPriority(int priority)
public void clearPriority()
public boolean hasPrioritySupported()
public boolean getPrioritySupported()
public T setPrioritySupported(boolean prioritySupported)
public void clearPrioritySupported()
Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.