public static final class QueueEntryPB.Buffer extends Object implements org.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>, QueueEntryPB.Getter
Modifier and Type | Method and 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(org.fusesource.hawtbuf.proto.CodedOutputStream output) |
void |
writeFramed(OutputStream output) |
void |
writeUnframed(org.fusesource.hawtbuf.proto.CodedOutputStream output) |
void |
writeUnframed(OutputStream output) |
public QueueEntryPB.Bean copy()
copy
in interface QueueEntryPB.Getter
copy
in interface org.fusesource.hawtbuf.proto.PBMessage<QueueEntryPB.Bean,QueueEntryPB.Buffer>
public QueueEntryPB.Buffer freeze()
freeze
in interface QueueEntryPB.Getter
freeze
in interface org.fusesource.hawtbuf.proto.PBMessage<QueueEntryPB.Bean,QueueEntryPB.Buffer>
public StringBuilder toString(StringBuilder sb, String prefix)
toString
in interface QueueEntryPB.Getter
public boolean hasQueueKey()
hasQueueKey
in interface QueueEntryPB.Getter
public long getQueueKey()
getQueueKey
in interface QueueEntryPB.Getter
public boolean hasQueueSeq()
hasQueueSeq
in interface QueueEntryPB.Getter
public long getQueueSeq()
getQueueSeq
in interface QueueEntryPB.Getter
public boolean hasMessageKey()
hasMessageKey
in interface QueueEntryPB.Getter
public long getMessageKey()
getMessageKey
in interface QueueEntryPB.Getter
public boolean hasSize()
hasSize
in interface QueueEntryPB.Getter
public int getSize()
getSize
in interface QueueEntryPB.Getter
public boolean hasAttachment()
hasAttachment
in interface QueueEntryPB.Getter
public org.fusesource.hawtbuf.Buffer getAttachment()
getAttachment
in interface QueueEntryPB.Getter
public boolean hasRedeliveries()
hasRedeliveries
in interface QueueEntryPB.Getter
public int getRedeliveries()
getRedeliveries
in interface QueueEntryPB.Getter
public boolean hasExpiration()
hasExpiration
in interface QueueEntryPB.Getter
public long getExpiration()
getExpiration
in interface QueueEntryPB.Getter
public boolean hasMessageLocator()
hasMessageLocator
in interface QueueEntryPB.Getter
public org.fusesource.hawtbuf.Buffer getMessageLocator()
getMessageLocator
in interface QueueEntryPB.Getter
public boolean hasSender()
hasSender
in interface QueueEntryPB.Getter
public List<org.fusesource.hawtbuf.Buffer> getSenderList()
getSenderList
in interface QueueEntryPB.Getter
public int getSenderCount()
getSenderCount
in interface QueueEntryPB.Getter
public org.fusesource.hawtbuf.Buffer getSender(int index)
getSender
in interface QueueEntryPB.Getter
public org.fusesource.hawtbuf.Buffer toUnframedBuffer()
toUnframedBuffer
in interface org.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
public org.fusesource.hawtbuf.Buffer toFramedBuffer()
toFramedBuffer
in interface org.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
public byte[] toUnframedByteArray()
toUnframedByteArray
in interface org.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
public byte[] toFramedByteArray()
toFramedByteArray
in interface org.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
public void writeFramed(org.fusesource.hawtbuf.proto.CodedOutputStream output) throws IOException
writeFramed
in interface org.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
IOException
public void writeFramed(OutputStream output) throws IOException
writeFramed
in interface org.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
IOException
public void writeUnframed(OutputStream output) throws IOException
writeUnframed
in interface org.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
IOException
public void writeUnframed(org.fusesource.hawtbuf.proto.CodedOutputStream output) throws IOException
writeUnframed
in interface org.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
IOException
public int serializedSizeFramed()
serializedSizeFramed
in interface org.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
public int serializedSizeUnframed()
serializedSizeUnframed
in interface org.fusesource.hawtbuf.proto.MessageBuffer<QueueEntryPB.Bean,QueueEntryPB.Buffer>
public boolean equals(QueueEntryPB.Buffer obj)
public boolean frozen()
frozen
in interface org.fusesource.hawtbuf.proto.PBMessage<QueueEntryPB.Bean,QueueEntryPB.Buffer>
Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.