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.Beancopy()booleanequals(Object obj)booleanequals(QueueEntryPB.Buffer obj)QueueEntryPB.Bufferfreeze()booleanfrozen()org.fusesource.hawtbuf.BuffergetAttachment()longgetExpiration()longgetMessageKey()org.fusesource.hawtbuf.BuffergetMessageLocator()longgetQueueKey()longgetQueueSeq()intgetRedeliveries()org.fusesource.hawtbuf.BuffergetSender(int index)intgetSenderCount()List<org.fusesource.hawtbuf.Buffer>getSenderList()intgetSize()booleanhasAttachment()booleanhasExpiration()inthashCode()booleanhasMessageKey()booleanhasMessageLocator()booleanhasQueueKey()booleanhasQueueSeq()booleanhasRedeliveries()booleanhasSender()booleanhasSize()intserializedSizeFramed()intserializedSizeUnframed()org.fusesource.hawtbuf.BuffertoFramedBuffer()byte[]toFramedByteArray()StringtoString()StringBuildertoString(StringBuilder sb, String prefix)org.fusesource.hawtbuf.BuffertoUnframedBuffer()byte[]toUnframedByteArray()voidwriteFramed(OutputStream output)voidwriteFramed(org.fusesource.hawtbuf.proto.CodedOutputStream output)voidwriteUnframed(OutputStream output)voidwriteUnframed(org.fusesource.hawtbuf.proto.CodedOutputStream output)
-
-
-
Method Detail
-
copy
public QueueEntryPB.Bean copy()
- Specified by:
copyin interfaceorg.fusesource.hawtbuf.proto.PBMessage<QueueEntryPB.Bean,QueueEntryPB.Buffer>- Specified by:
copyin interfaceQueueEntryPB.Getter
-
freeze
public QueueEntryPB.Buffer freeze()
- Specified by:
freezein interfaceorg.fusesource.hawtbuf.proto.PBMessage<QueueEntryPB.Bean,QueueEntryPB.Buffer>- Specified by:
freezein interfaceQueueEntryPB.Getter
-
toString
public StringBuilder toString(StringBuilder sb, String prefix)
- Specified by:
toStringin interfaceQueueEntryPB.Getter
-
hasQueueKey
public boolean hasQueueKey()
- Specified by:
hasQueueKeyin interfaceQueueEntryPB.Getter
-
getQueueKey
public long getQueueKey()
- Specified by:
getQueueKeyin interfaceQueueEntryPB.Getter
-
hasQueueSeq
public boolean hasQueueSeq()
- Specified by:
hasQueueSeqin interfaceQueueEntryPB.Getter
-
getQueueSeq
public long getQueueSeq()
- Specified by:
getQueueSeqin interfaceQueueEntryPB.Getter
-
hasMessageKey
public boolean hasMessageKey()
- Specified by:
hasMessageKeyin interfaceQueueEntryPB.Getter
-
getMessageKey
public long getMessageKey()
- Specified by:
getMessageKeyin interfaceQueueEntryPB.Getter
-
hasSize
public boolean hasSize()
- Specified by:
hasSizein interfaceQueueEntryPB.Getter
-
getSize
public int getSize()
- Specified by:
getSizein interfaceQueueEntryPB.Getter
-
hasAttachment
public boolean hasAttachment()
- Specified by:
hasAttachmentin interfaceQueueEntryPB.Getter
-
getAttachment
public org.fusesource.hawtbuf.Buffer getAttachment()
- Specified by:
getAttachmentin interfaceQueueEntryPB.Getter
-
hasRedeliveries
public boolean hasRedeliveries()
- Specified by:
hasRedeliveriesin interfaceQueueEntryPB.Getter
-
getRedeliveries
public int getRedeliveries()
- Specified by:
getRedeliveriesin interfaceQueueEntryPB.Getter
-
hasExpiration
public boolean hasExpiration()
- Specified by:
hasExpirationin interfaceQueueEntryPB.Getter
-
getExpiration
public long getExpiration()
- Specified by:
getExpirationin interfaceQueueEntryPB.Getter
-
hasMessageLocator
public boolean hasMessageLocator()
- Specified by:
hasMessageLocatorin interfaceQueueEntryPB.Getter
-
getMessageLocator
public org.fusesource.hawtbuf.Buffer getMessageLocator()
- Specified by:
getMessageLocatorin interfaceQueueEntryPB.Getter
-
hasSender
public boolean hasSender()
- Specified by:
hasSenderin interfaceQueueEntryPB.Getter
-
getSenderList
public List<org.fusesource.hawtbuf.Buffer> getSenderList()
- Specified by:
getSenderListin interfaceQueueEntryPB.Getter
-
getSenderCount
public int getSenderCount()
- Specified by:
getSenderCountin interfaceQueueEntryPB.Getter
-
getSender
public org.fusesource.hawtbuf.Buffer getSender(int index)
- Specified by:
getSenderin interfaceQueueEntryPB.Getter
-
toUnframedBuffer
public org.fusesource.hawtbuf.Buffer toUnframedBuffer()
- Specified by:
toUnframedBufferin interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
-
toFramedBuffer
public org.fusesource.hawtbuf.Buffer toFramedBuffer()
- Specified by:
toFramedBufferin interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
-
toUnframedByteArray
public byte[] toUnframedByteArray()
- Specified by:
toUnframedByteArrayin interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
-
toFramedByteArray
public byte[] toFramedByteArray()
- Specified by:
toFramedByteArrayin interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
-
writeFramed
public void writeFramed(org.fusesource.hawtbuf.proto.CodedOutputStream output) throws IOException- Specified by:
writeFramedin interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>- Throws:
IOException
-
writeFramed
public void writeFramed(OutputStream output) throws IOException
- Specified by:
writeFramedin interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>- Throws:
IOException
-
writeUnframed
public void writeUnframed(OutputStream output) throws IOException
- Specified by:
writeUnframedin 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:
writeUnframedin interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>- Throws:
IOException
-
serializedSizeFramed
public int serializedSizeFramed()
- Specified by:
serializedSizeFramedin interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
-
serializedSizeUnframed
public int serializedSizeUnframed()
- Specified by:
serializedSizeUnframedin interfaceorg.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
-
equals
public boolean equals(QueueEntryPB.Buffer obj)
-
frozen
public boolean frozen()
- Specified by:
frozenin interfaceorg.fusesource.hawtbuf.proto.PBMessage<QueueEntryPB.Bean,QueueEntryPB.Buffer>
-
-