org.apache.activemq.store.kahadb.data
Class KahaRemoveMessageCommand
java.lang.Object
org.apache.activemq.protobuf.BaseMessage<T>
org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
- All Implemented Interfaces:
- org.apache.activemq.protobuf.Message<KahaRemoveMessageCommand>, JournalCommand<KahaRemoveMessageCommand>
public final class KahaRemoveMessageCommand
- extends org.apache.activemq.protobuf.BaseMessage<T>
- implements JournalCommand<KahaRemoveMessageCommand>
Fields inherited from class org.apache.activemq.protobuf.BaseMessage |
memoizedSerializedSize |
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 interface org.apache.activemq.protobuf.Message |
assertInitialized, mergeFramed, mergeFramed, mergeFramed, mergeFramed, mergeUnframed, mergeUnframed, mergeUnframed, serializedSizeFramed, toFramedBuffer, toFramedByteArray, toUnframedBuffer, toUnframedByteArray, writeFramed, writeFramed, writeUnframed |
KahaRemoveMessageCommand
public KahaRemoveMessageCommand()
missingFields
public ArrayList<String> missingFields()
- Overrides:
missingFields
in class org.apache.activemq.protobuf.BaseMessage<KahaRemoveMessageCommand>
clear
public void clear()
- Specified by:
clear
in interface org.apache.activemq.protobuf.Message<KahaRemoveMessageCommand>
- Overrides:
clear
in class org.apache.activemq.protobuf.BaseMessage<KahaRemoveMessageCommand>
clone
public KahaRemoveMessageCommand clone()
- Specified by:
clone
in interface org.apache.activemq.protobuf.Message<KahaRemoveMessageCommand>
- Specified by:
clone
in class org.apache.activemq.protobuf.BaseMessage<KahaRemoveMessageCommand>
mergeFrom
public KahaRemoveMessageCommand mergeFrom(KahaRemoveMessageCommand other)
- Specified by:
mergeFrom
in interface org.apache.activemq.protobuf.Message<KahaRemoveMessageCommand>
- Overrides:
mergeFrom
in class org.apache.activemq.protobuf.BaseMessage<KahaRemoveMessageCommand>
serializedSizeUnframed
public int serializedSizeUnframed()
- Specified by:
serializedSizeUnframed
in interface org.apache.activemq.protobuf.Message<KahaRemoveMessageCommand>
mergeUnframed
public KahaRemoveMessageCommand mergeUnframed(org.apache.activemq.protobuf.CodedInputStream input)
throws IOException
- Specified by:
mergeUnframed
in interface org.apache.activemq.protobuf.Message<KahaRemoveMessageCommand>
- Throws:
IOException
writeUnframed
public void writeUnframed(org.apache.activemq.protobuf.CodedOutputStream output)
throws IOException
- Specified by:
writeUnframed
in interface org.apache.activemq.protobuf.Message<KahaRemoveMessageCommand>
- Overrides:
writeUnframed
in class org.apache.activemq.protobuf.BaseMessage<KahaRemoveMessageCommand>
- Throws:
IOException
parseUnframed
public static KahaRemoveMessageCommand parseUnframed(org.apache.activemq.protobuf.CodedInputStream data)
throws org.apache.activemq.protobuf.InvalidProtocolBufferException,
IOException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
IOException
parseUnframed
public static KahaRemoveMessageCommand parseUnframed(org.apache.activemq.protobuf.Buffer data)
throws org.apache.activemq.protobuf.InvalidProtocolBufferException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
parseUnframed
public static KahaRemoveMessageCommand parseUnframed(byte[] data)
throws org.apache.activemq.protobuf.InvalidProtocolBufferException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
parseUnframed
public static KahaRemoveMessageCommand parseUnframed(InputStream data)
throws org.apache.activemq.protobuf.InvalidProtocolBufferException,
IOException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
IOException
parseFramed
public static KahaRemoveMessageCommand parseFramed(org.apache.activemq.protobuf.CodedInputStream data)
throws org.apache.activemq.protobuf.InvalidProtocolBufferException,
IOException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
IOException
parseFramed
public static KahaRemoveMessageCommand parseFramed(org.apache.activemq.protobuf.Buffer data)
throws org.apache.activemq.protobuf.InvalidProtocolBufferException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
parseFramed
public static KahaRemoveMessageCommand parseFramed(byte[] data)
throws org.apache.activemq.protobuf.InvalidProtocolBufferException
- Throws:
org.apache.activemq.protobuf.InvalidProtocolBufferException
parseFramed
public static KahaRemoveMessageCommand 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<KahaRemoveMessageCommand>
- Throws:
IOException
type
public KahaEntryType type()
- Specified by:
type
in interface JournalCommand<KahaRemoveMessageCommand>
equals
public boolean equals(Object obj)
- Overrides:
equals
in class Object
equals
public boolean equals(KahaRemoveMessageCommand 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()
hasAck
public boolean hasAck()
getAck
public org.apache.activemq.protobuf.Buffer getAck()
setAck
public T setAck(org.apache.activemq.protobuf.Buffer ack)
clearAck
public void clearAck()
hasSubscriptionKey
public boolean hasSubscriptionKey()
getSubscriptionKey
public String getSubscriptionKey()
setSubscriptionKey
public T setSubscriptionKey(String subscriptionKey)
clearSubscriptionKey
public void clearSubscriptionKey()
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.