Package org.apache.activemq.store.kahadb.data

Class KahaAddMessageCommand

java.lang.Object

org.apache.activemq.protobuf.BaseMessage<T>

org.apache.activemq.store.kahadb.data.KahaAddMessageCommand

All Implemented Interfaces:

org.apache.activemq.protobuf.Message<KahaAddMessageCommand>, JournalCommand<KahaAddMessageCommand>

public final class KahaAddMessageCommand
extends org.apache.activemq.protobuf.BaseMessage<T>
implements JournalCommand<KahaAddMessageCommand>

Field Summary

Fields inherited from class org.apache.activemq.protobuf.BaseMessage

memoizedSerializedSize

Constructor Summary

Constructors

Constructor	Description
KahaAddMessageCommand()

Method Summary

Modifier and Type	Method	Description
void	clear()
void	clearDestination()
void	clearMessage()
void	clearMessageId()
void	clearPriority()
void	clearPrioritySupported()
void	clearTransactionInfo()
KahaAddMessageCommand	clone()
boolean	equals(Object obj)
boolean	equals(KahaAddMessageCommand obj)
KahaDestination	getDestination()
org.apache.activemq.protobuf.Buffer	getMessage()
String	getMessageId()
int	getPriority()
boolean	getPrioritySupported()
KahaTransactionInfo	getTransactionInfo()
boolean	hasDestination()
int	hashCode()
boolean	hasMessage()
boolean	hasMessageId()
boolean	hasPriority()
boolean	hasPrioritySupported()
boolean	hasTransactionInfo()
KahaAddMessageCommand	mergeFrom(KahaAddMessageCommand other)
KahaAddMessageCommand	mergeUnframed(org.apache.activemq.protobuf.CodedInputStream input)
ArrayList<String>	missingFields()
static KahaAddMessageCommand	parseFramed(byte[] data)
static KahaAddMessageCommand	parseFramed(InputStream data)
static KahaAddMessageCommand	parseFramed(org.apache.activemq.protobuf.Buffer data)
static KahaAddMessageCommand	parseFramed(org.apache.activemq.protobuf.CodedInputStream data)
static KahaAddMessageCommand	parseUnframed(byte[] data)
static KahaAddMessageCommand	parseUnframed(InputStream data)
static KahaAddMessageCommand	parseUnframed(org.apache.activemq.protobuf.Buffer data)
static KahaAddMessageCommand	parseUnframed(org.apache.activemq.protobuf.CodedInputStream data)
int	serializedSizeUnframed()
T	setDestination(KahaDestination destination)
T	setMessage(org.apache.activemq.protobuf.Buffer message)
T	setMessageId(String messageId)
T	setPriority(int priority)
T	setPrioritySupported(boolean prioritySupported)
T	setTransactionInfo(KahaTransactionInfo transactionInfo)
String	toString()
StringBuilder	toString(StringBuilder sb, String prefix)
KahaEntryType	type()
void	visit(Visitor visitor)
void	writeUnframed(org.apache.activemq.protobuf.CodedOutputStream output)

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

Constructor Detail

KahaAddMessageCommand

public KahaAddMessageCommand()

Method Detail

missingFields

public ArrayList<String> missingFields()

Overrides:

missingFields in class org.apache.activemq.protobuf.BaseMessage<KahaAddMessageCommand>

clear

public void clear()

Specified by:

clear in interface org.apache.activemq.protobuf.Message<KahaAddMessageCommand>

Overrides:

clear in class org.apache.activemq.protobuf.BaseMessage<KahaAddMessageCommand>

clone

public KahaAddMessageCommand clone()

Specified by:

clone in interface org.apache.activemq.protobuf.Message<KahaAddMessageCommand>

Specified by:

clone in class org.apache.activemq.protobuf.BaseMessage<KahaAddMessageCommand>

mergeFrom

public KahaAddMessageCommand mergeFrom(KahaAddMessageCommand other)

Specified by:

mergeFrom in interface org.apache.activemq.protobuf.Message<KahaAddMessageCommand>

Overrides:

mergeFrom in class org.apache.activemq.protobuf.BaseMessage<KahaAddMessageCommand>

serializedSizeUnframed

public int serializedSizeUnframed()

Specified by:

serializedSizeUnframed in interface org.apache.activemq.protobuf.Message<KahaAddMessageCommand>

mergeUnframed

public KahaAddMessageCommand mergeUnframed(org.apache.activemq.protobuf.CodedInputStream input)
                                    throws IOException

Specified by:

mergeUnframed in interface org.apache.activemq.protobuf.Message<KahaAddMessageCommand>

Throws:

IOException

writeUnframed

public void writeUnframed(org.apache.activemq.protobuf.CodedOutputStream output)
                   throws IOException

Specified by:

writeUnframed in interface org.apache.activemq.protobuf.Message<KahaAddMessageCommand>

Overrides:

writeUnframed in class org.apache.activemq.protobuf.BaseMessage<KahaAddMessageCommand>

Throws:

IOException

parseUnframed

public static KahaAddMessageCommand parseUnframed(org.apache.activemq.protobuf.CodedInputStream data)
                                           throws org.apache.activemq.protobuf.InvalidProtocolBufferException,
                                                  IOException

Throws:

org.apache.activemq.protobuf.InvalidProtocolBufferException

IOException

parseUnframed

public static KahaAddMessageCommand parseUnframed(org.apache.activemq.protobuf.Buffer data)
                                           throws org.apache.activemq.protobuf.InvalidProtocolBufferException

Throws:

org.apache.activemq.protobuf.InvalidProtocolBufferException

parseUnframed

public static KahaAddMessageCommand parseUnframed(byte[] data)
                                           throws org.apache.activemq.protobuf.InvalidProtocolBufferException

Throws:

org.apache.activemq.protobuf.InvalidProtocolBufferException

parseUnframed

public static KahaAddMessageCommand parseUnframed(InputStream data)
                                           throws org.apache.activemq.protobuf.InvalidProtocolBufferException,
                                                  IOException

Throws:

org.apache.activemq.protobuf.InvalidProtocolBufferException

IOException

parseFramed

public static KahaAddMessageCommand parseFramed(org.apache.activemq.protobuf.CodedInputStream data)
                                         throws org.apache.activemq.protobuf.InvalidProtocolBufferException,
                                                IOException

Throws:

org.apache.activemq.protobuf.InvalidProtocolBufferException

IOException

parseFramed

public static KahaAddMessageCommand parseFramed(org.apache.activemq.protobuf.Buffer data)
                                         throws org.apache.activemq.protobuf.InvalidProtocolBufferException

Throws:

org.apache.activemq.protobuf.InvalidProtocolBufferException

parseFramed

public static KahaAddMessageCommand parseFramed(byte[] data)
                                         throws org.apache.activemq.protobuf.InvalidProtocolBufferException

Throws:

org.apache.activemq.protobuf.InvalidProtocolBufferException

parseFramed

public static KahaAddMessageCommand parseFramed(InputStream data)
                                         throws org.apache.activemq.protobuf.InvalidProtocolBufferException,
                                                IOException

Throws:

org.apache.activemq.protobuf.InvalidProtocolBufferException

IOException

toString

public String toString()

Overrides:

toString in class Object

toString

public StringBuilder toString(StringBuilder sb,
                              String prefix)

visit

public void visit(Visitor visitor)
           throws IOException

Specified by:

visit in interface JournalCommand<KahaAddMessageCommand>

Throws:

IOException

type

public KahaEntryType type()

Specified by:

type in interface JournalCommand<KahaAddMessageCommand>

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

equals

public boolean equals(KahaAddMessageCommand obj)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

hasTransactionInfo

public boolean hasTransactionInfo()

getTransactionInfo

public KahaTransactionInfo getTransactionInfo()

setTransactionInfo

public T setTransactionInfo(KahaTransactionInfo transactionInfo)

clearTransactionInfo

public void clearTransactionInfo()

hasDestination

public boolean hasDestination()

getDestination

public KahaDestination getDestination()

setDestination

public T setDestination(KahaDestination destination)

clearDestination

public void clearDestination()

hasMessageId

public boolean hasMessageId()

getMessageId

public String getMessageId()

setMessageId

public T setMessageId(String messageId)

clearMessageId

public void clearMessageId()

hasMessage

public boolean hasMessage()

getMessage

public org.apache.activemq.protobuf.Buffer getMessage()

setMessage

public T setMessage(org.apache.activemq.protobuf.Buffer message)

clearMessage

public void clearMessage()

hasPriority

public boolean hasPriority()

getPriority

public int getPriority()

setPriority

public T setPriority(int priority)

clearPriority

public void clearPriority()

hasPrioritySupported

public boolean hasPrioritySupported()

getPrioritySupported

public boolean getPrioritySupported()

setPrioritySupported

public T setPrioritySupported(boolean prioritySupported)

clearPrioritySupported

public void clearPrioritySupported()