org.apache.activemq.apollo.broker.store
Class MessagePB.Buffer

java.lang.Object
  extended by org.apache.activemq.apollo.broker.store.MessagePB.Buffer
All Implemented Interfaces:
MessagePB.Getter, org.fusesource.hawtbuf.proto.MessageBuffer<MessagePB.Bean,MessagePB.Buffer>, org.fusesource.hawtbuf.proto.PBMessage<MessagePB.Bean,MessagePB.Buffer>
Enclosing class:
MessagePB

public static final class MessagePB.Buffer
extends java.lang.Object
implements org.fusesource.hawtbuf.proto.MessageBuffer<MessagePB.Bean,MessagePB.Buffer>, MessagePB.Getter


Method Summary
 MessagePB.Bean copy()
           
 boolean equals(MessagePB.Buffer obj)
           
 boolean equals(java.lang.Object obj)
           
 MessagePB.Buffer freeze()
           
 boolean frozen()
           
 long getExpiration()
           
 long getMessageKey()
           
 org.fusesource.hawtbuf.AsciiBuffer getProtocol()
           
 int getSize()
           
 org.fusesource.hawtbuf.Buffer getValue()
           
 org.fusesource.hawtbuf.Buffer getZcpData()
           
 int getZcpFile()
           
 long getZcpOffset()
           
 int getZcpSize()
           
 boolean hasExpiration()
           
 int hashCode()
           
 boolean hasMessageKey()
           
 boolean hasProtocol()
           
 boolean hasSize()
           
 boolean hasValue()
           
 boolean hasZcpData()
           
 boolean hasZcpFile()
           
 boolean hasZcpOffset()
           
 boolean hasZcpSize()
           
 int serializedSizeFramed()
           
 int serializedSizeUnframed()
           
 org.fusesource.hawtbuf.Buffer toFramedBuffer()
           
 byte[] toFramedByteArray()
           
 java.lang.String toString()
           
 java.lang.StringBuilder toString(java.lang.StringBuilder sb, java.lang.String prefix)
           
 org.fusesource.hawtbuf.Buffer toUnframedBuffer()
           
 byte[] toUnframedByteArray()
           
 void writeFramed(org.fusesource.hawtbuf.proto.CodedOutputStream output)
           
 void writeFramed(java.io.OutputStream output)
           
 void writeUnframed(org.fusesource.hawtbuf.proto.CodedOutputStream output)
           
 void writeUnframed(java.io.OutputStream output)
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Method Detail

copy

public MessagePB.Bean copy()
Specified by:
copy in interface MessagePB.Getter
Specified by:
copy in interface org.fusesource.hawtbuf.proto.PBMessage<MessagePB.Bean,MessagePB.Buffer>

freeze

public MessagePB.Buffer freeze()
Specified by:
freeze in interface MessagePB.Getter
Specified by:
freeze in interface org.fusesource.hawtbuf.proto.PBMessage<MessagePB.Bean,MessagePB.Buffer>

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object

toString

public java.lang.StringBuilder toString(java.lang.StringBuilder sb,
                                        java.lang.String prefix)
Specified by:
toString in interface MessagePB.Getter

hasMessageKey

public boolean hasMessageKey()
Specified by:
hasMessageKey in interface MessagePB.Getter

getMessageKey

public long getMessageKey()
Specified by:
getMessageKey in interface MessagePB.Getter

hasProtocol

public boolean hasProtocol()
Specified by:
hasProtocol in interface MessagePB.Getter

getProtocol

public org.fusesource.hawtbuf.AsciiBuffer getProtocol()
Specified by:
getProtocol in interface MessagePB.Getter

hasSize

public boolean hasSize()
Specified by:
hasSize in interface MessagePB.Getter

getSize

public int getSize()
Specified by:
getSize in interface MessagePB.Getter

hasValue

public boolean hasValue()
Specified by:
hasValue in interface MessagePB.Getter

getValue

public org.fusesource.hawtbuf.Buffer getValue()
Specified by:
getValue in interface MessagePB.Getter

hasExpiration

public boolean hasExpiration()
Specified by:
hasExpiration in interface MessagePB.Getter

getExpiration

public long getExpiration()
Specified by:
getExpiration in interface MessagePB.Getter

hasZcpData

public boolean hasZcpData()
Specified by:
hasZcpData in interface MessagePB.Getter

getZcpData

public org.fusesource.hawtbuf.Buffer getZcpData()
Specified by:
getZcpData in interface MessagePB.Getter

hasZcpFile

public boolean hasZcpFile()
Specified by:
hasZcpFile in interface MessagePB.Getter

getZcpFile

public int getZcpFile()
Specified by:
getZcpFile in interface MessagePB.Getter

hasZcpOffset

public boolean hasZcpOffset()
Specified by:
hasZcpOffset in interface MessagePB.Getter

getZcpOffset

public long getZcpOffset()
Specified by:
getZcpOffset in interface MessagePB.Getter

hasZcpSize

public boolean hasZcpSize()
Specified by:
hasZcpSize in interface MessagePB.Getter

getZcpSize

public int getZcpSize()
Specified by:
getZcpSize in interface MessagePB.Getter

toUnframedBuffer

public org.fusesource.hawtbuf.Buffer toUnframedBuffer()
Specified by:
toUnframedBuffer in interface org.fusesource.hawtbuf.proto.MessageBuffer<MessagePB.Bean,MessagePB.Buffer>

toFramedBuffer

public org.fusesource.hawtbuf.Buffer toFramedBuffer()
Specified by:
toFramedBuffer in interface org.fusesource.hawtbuf.proto.MessageBuffer<MessagePB.Bean,MessagePB.Buffer>

toUnframedByteArray

public byte[] toUnframedByteArray()
Specified by:
toUnframedByteArray in interface org.fusesource.hawtbuf.proto.MessageBuffer<MessagePB.Bean,MessagePB.Buffer>

toFramedByteArray

public byte[] toFramedByteArray()
Specified by:
toFramedByteArray in interface org.fusesource.hawtbuf.proto.MessageBuffer<MessagePB.Bean,MessagePB.Buffer>

writeFramed

public void writeFramed(org.fusesource.hawtbuf.proto.CodedOutputStream output)
                 throws java.io.IOException
Specified by:
writeFramed in interface org.fusesource.hawtbuf.proto.MessageBuffer<MessagePB.Bean,MessagePB.Buffer>
Throws:
java.io.IOException

writeFramed

public void writeFramed(java.io.OutputStream output)
                 throws java.io.IOException
Specified by:
writeFramed in interface org.fusesource.hawtbuf.proto.MessageBuffer<MessagePB.Bean,MessagePB.Buffer>
Throws:
java.io.IOException

writeUnframed

public void writeUnframed(java.io.OutputStream output)
                   throws java.io.IOException
Specified by:
writeUnframed in interface org.fusesource.hawtbuf.proto.MessageBuffer<MessagePB.Bean,MessagePB.Buffer>
Throws:
java.io.IOException

writeUnframed

public void writeUnframed(org.fusesource.hawtbuf.proto.CodedOutputStream output)
                   throws java.io.IOException
Specified by:
writeUnframed in interface org.fusesource.hawtbuf.proto.MessageBuffer<MessagePB.Bean,MessagePB.Buffer>
Throws:
java.io.IOException

serializedSizeFramed

public int serializedSizeFramed()
Specified by:
serializedSizeFramed in interface org.fusesource.hawtbuf.proto.MessageBuffer<MessagePB.Bean,MessagePB.Buffer>

serializedSizeUnframed

public int serializedSizeUnframed()
Specified by:
serializedSizeUnframed in interface org.fusesource.hawtbuf.proto.MessageBuffer<MessagePB.Bean,MessagePB.Buffer>

equals

public boolean equals(java.lang.Object obj)
Overrides:
equals in class java.lang.Object

equals

public boolean equals(MessagePB.Buffer obj)

hashCode

public int hashCode()
Overrides:
hashCode in class java.lang.Object

frozen

public boolean frozen()
Specified by:
frozen in interface org.fusesource.hawtbuf.proto.PBMessage<MessagePB.Bean,MessagePB.Buffer>


Copyright © 2005-2011 The Apache Software Foundation. All Rights Reserved.