org.apache.activemq.store.kahadb.data
Class KahaRemoveMessageCommand

java.lang.Object
  extended by org.apache.activemq.protobuf.BaseMessage<T>
      extended by 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>


Field Summary
 
Fields inherited from class org.apache.activemq.protobuf.BaseMessage
memoizedSerializedSize
 
Constructor Summary
KahaRemoveMessageCommand()
           
 
Method Summary
 void clear()
           
 void clearAck()
           
 void clearDestination()
           
 void clearMessageId()
           
 void clearSubscriptionKey()
           
 void clearTransactionInfo()
           
 KahaRemoveMessageCommand clone()
           
 boolean equals(KahaRemoveMessageCommand obj)
           
 boolean equals(Object obj)
           
 org.apache.activemq.protobuf.Buffer getAck()
           
 KahaDestination getDestination()
           
 String getMessageId()
           
 String getSubscriptionKey()
           
 KahaTransactionInfo getTransactionInfo()
           
 boolean hasAck()
           
 boolean hasDestination()
           
 int hashCode()
           
 boolean hasMessageId()
           
 boolean hasSubscriptionKey()
           
 boolean hasTransactionInfo()
           
 KahaRemoveMessageCommand mergeFrom(KahaRemoveMessageCommand other)
           
 KahaRemoveMessageCommand mergeUnframed(org.apache.activemq.protobuf.CodedInputStream input)
           
 ArrayList<String> missingFields()
           
static KahaRemoveMessageCommand parseFramed(org.apache.activemq.protobuf.Buffer data)
           
static KahaRemoveMessageCommand parseFramed(byte[] data)
           
static KahaRemoveMessageCommand parseFramed(org.apache.activemq.protobuf.CodedInputStream data)
           
static KahaRemoveMessageCommand parseFramed(InputStream data)
           
static KahaRemoveMessageCommand parseUnframed(org.apache.activemq.protobuf.Buffer data)
           
static KahaRemoveMessageCommand parseUnframed(byte[] data)
           
static KahaRemoveMessageCommand parseUnframed(org.apache.activemq.protobuf.CodedInputStream data)
           
static KahaRemoveMessageCommand parseUnframed(InputStream data)
           
 int serializedSizeUnframed()
           
 T setAck(org.apache.activemq.protobuf.Buffer ack)
           
 T setDestination(KahaDestination destination)
           
 T setMessageId(String messageId)
           
 T setSubscriptionKey(String subscriptionKey)
           
 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

KahaRemoveMessageCommand

public KahaRemoveMessageCommand()
Method Detail

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-2013 The Apache Software Foundation. All Rights Reserved.