Class QueueEntryPB.Buffer
- java.lang.Object
-
- org.apache.activemq.console.command.store.proto.QueueEntryPB.Buffer
-
- All Implemented Interfaces:
QueueEntryPB.Getter
,org.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
,org.fusesource.hawtbuf.proto.PBMessage<QueueEntryPB.Bean,QueueEntryPB.Buffer>
- Enclosing class:
- QueueEntryPB
public static final class QueueEntryPB.Buffer extends Object implements org.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>, QueueEntryPB.Getter
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description QueueEntryPB.Bean
copy()
boolean
equals(Object obj)
boolean
equals(QueueEntryPB.Buffer obj)
QueueEntryPB.Buffer
freeze()
boolean
frozen()
org.fusesource.hawtbuf.Buffer
getAttachment()
long
getExpiration()
long
getMessageKey()
org.fusesource.hawtbuf.Buffer
getMessageLocator()
long
getQueueKey()
long
getQueueSeq()
int
getRedeliveries()
org.fusesource.hawtbuf.Buffer
getSender(int index)
int
getSenderCount()
List<org.fusesource.hawtbuf.Buffer>
getSenderList()
int
getSize()
boolean
hasAttachment()
boolean
hasExpiration()
int
hashCode()
boolean
hasMessageKey()
boolean
hasMessageLocator()
boolean
hasQueueKey()
boolean
hasQueueSeq()
boolean
hasRedeliveries()
boolean
hasSender()
boolean
hasSize()
int
serializedSizeFramed()
int
serializedSizeUnframed()
org.fusesource.hawtbuf.Buffer
toFramedBuffer()
byte[]
toFramedByteArray()
String
toString()
StringBuilder
toString(StringBuilder sb, String prefix)
org.fusesource.hawtbuf.Buffer
toUnframedBuffer()
byte[]
toUnframedByteArray()
void
writeFramed(OutputStream output)
void
writeFramed(org.fusesource.hawtbuf.proto.CodedOutputStream output)
void
writeUnframed(OutputStream output)
void
writeUnframed(org.fusesource.hawtbuf.proto.CodedOutputStream output)
-
-
-
Method Detail
-
copy
public QueueEntryPB.Bean copy()
- Specified by:
copy
in interfaceorg.fusesource.hawtbuf.proto.PBMessage<QueueEntryPB.Bean,QueueEntryPB.Buffer>
- Specified by:
copy
in interfaceQueueEntryPB.Getter
-
freeze
public QueueEntryPB.Buffer freeze()
- Specified by:
freeze
in interfaceorg.fusesource.hawtbuf.proto.PBMessage<QueueEntryPB.Bean,QueueEntryPB.Buffer>
- Specified by:
freeze
in interfaceQueueEntryPB.Getter
-
toString
public StringBuilder toString(StringBuilder sb, String prefix)
- Specified by:
toString
in interfaceQueueEntryPB.Getter
-
hasQueueKey
public boolean hasQueueKey()
- Specified by:
hasQueueKey
in interfaceQueueEntryPB.Getter
-
getQueueKey
public long getQueueKey()
- Specified by:
getQueueKey
in interfaceQueueEntryPB.Getter
-
hasQueueSeq
public boolean hasQueueSeq()
- Specified by:
hasQueueSeq
in interfaceQueueEntryPB.Getter
-
getQueueSeq
public long getQueueSeq()
- Specified by:
getQueueSeq
in interfaceQueueEntryPB.Getter
-
hasMessageKey
public boolean hasMessageKey()
- Specified by:
hasMessageKey
in interfaceQueueEntryPB.Getter
-
getMessageKey
public long getMessageKey()
- Specified by:
getMessageKey
in interfaceQueueEntryPB.Getter
-
hasSize
public boolean hasSize()
- Specified by:
hasSize
in interfaceQueueEntryPB.Getter
-
getSize
public int getSize()
- Specified by:
getSize
in interfaceQueueEntryPB.Getter
-
hasAttachment
public boolean hasAttachment()
- Specified by:
hasAttachment
in interfaceQueueEntryPB.Getter
-
getAttachment
public org.fusesource.hawtbuf.Buffer getAttachment()
- Specified by:
getAttachment
in interfaceQueueEntryPB.Getter
-
hasRedeliveries
public boolean hasRedeliveries()
- Specified by:
hasRedeliveries
in interfaceQueueEntryPB.Getter
-
getRedeliveries
public int getRedeliveries()
- Specified by:
getRedeliveries
in interfaceQueueEntryPB.Getter
-
hasExpiration
public boolean hasExpiration()
- Specified by:
hasExpiration
in interfaceQueueEntryPB.Getter
-
getExpiration
public long getExpiration()
- Specified by:
getExpiration
in interfaceQueueEntryPB.Getter
-
hasMessageLocator
public boolean hasMessageLocator()
- Specified by:
hasMessageLocator
in interfaceQueueEntryPB.Getter
-
getMessageLocator
public org.fusesource.hawtbuf.Buffer getMessageLocator()
- Specified by:
getMessageLocator
in interfaceQueueEntryPB.Getter
-
hasSender
public boolean hasSender()
- Specified by:
hasSender
in interfaceQueueEntryPB.Getter
-
getSenderList
public List<org.fusesource.hawtbuf.Buffer> getSenderList()
- Specified by:
getSenderList
in interfaceQueueEntryPB.Getter
-
getSenderCount
public int getSenderCount()
- Specified by:
getSenderCount
in interfaceQueueEntryPB.Getter
-
getSender
public org.fusesource.hawtbuf.Buffer getSender(int index)
- Specified by:
getSender
in interfaceQueueEntryPB.Getter
-
toUnframedBuffer
public org.fusesource.hawtbuf.Buffer toUnframedBuffer()
- Specified by:
toUnframedBuffer
in interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
-
toFramedBuffer
public org.fusesource.hawtbuf.Buffer toFramedBuffer()
- Specified by:
toFramedBuffer
in interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
-
toUnframedByteArray
public byte[] toUnframedByteArray()
- Specified by:
toUnframedByteArray
in interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
-
toFramedByteArray
public byte[] toFramedByteArray()
- Specified by:
toFramedByteArray
in interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
-
writeFramed
public void writeFramed(org.fusesource.hawtbuf.proto.CodedOutputStream output) throws IOException
- Specified by:
writeFramed
in interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
- Throws:
IOException
-
writeFramed
public void writeFramed(OutputStream output) throws IOException
- Specified by:
writeFramed
in interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
- Throws:
IOException
-
writeUnframed
public void writeUnframed(OutputStream output) throws IOException
- Specified by:
writeUnframed
in interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
- Throws:
IOException
-
writeUnframed
public void writeUnframed(org.fusesource.hawtbuf.proto.CodedOutputStream output) throws IOException
- Specified by:
writeUnframed
in interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
- Throws:
IOException
-
serializedSizeFramed
public int serializedSizeFramed()
- Specified by:
serializedSizeFramed
in interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
-
serializedSizeUnframed
public int serializedSizeUnframed()
- Specified by:
serializedSizeUnframed
in interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
-
equals
public boolean equals(QueueEntryPB.Buffer obj)
-
frozen
public boolean frozen()
- Specified by:
frozen
in interfaceorg.fusesource.hawtbuf.proto.PBMessage<QueueEntryPB.Bean,QueueEntryPB.Buffer>
-
-