org.apache.activemq.protobuf
Class BaseMessage<T>

java.lang.Object
  extended by org.apache.activemq.protobuf.BaseMessage<T>
All Implemented Interfaces:
Message<T>
Direct Known Subclasses:
DeferredDecodeMessage

public abstract class BaseMessage<T>
extends java.lang.Object
implements Message<T>


Field Summary
protected  int memoizedSerializedSize
           
 
Constructor Summary
BaseMessage()
           
 
Method Summary
protected static
<T> void
addAll(java.lang.Iterable<T> values, java.util.Collection<? super T> list)
           
 T assertInitialized()
           
protected  T checktInitialized()
           
 void clear()
           
abstract  T clone()
           
protected static int computeGroupSize(int tag, BaseMessage message)
           
protected static int computeMessageSize(int tag, BaseMessage message)
           
 boolean isInitialized()
           
protected  void load()
           
protected  void loadAndClear()
           
 T mergeFramed(Buffer data)
           
 T mergeFramed(byte[] data)
           
 T mergeFramed(CodedInputStream input)
           
 T mergeFramed(java.io.InputStream input)
           
 T mergeFrom(T other)
           
 T mergeUnframed(Buffer data)
           
 T mergeUnframed(byte[] data)
           
 T mergeUnframed(java.io.InputStream input)
           
 java.util.ArrayList<java.lang.String> missingFields()
           
protected  java.util.List<java.lang.String> prefix(java.util.List<java.lang.String> missingFields, java.lang.String prefix)
           
protected static
<T extends BaseMessage>
T
readGroup(CodedInputStream input, int tag, T group)
           
protected static byte readRawByte(java.io.InputStream is)
           
static int readRawVarint32(java.io.InputStream is)
          Read a raw Varint from the stream.
 int serializedSizeFramed()
           
 Buffer toFramedBuffer()
           
 byte[] toFramedByteArray()
           
 Buffer toUnframedBuffer()
           
 byte[] toUnframedByteArray()
           
 void writeFramed(CodedOutputStream output)
           
 void writeFramed(java.io.OutputStream output)
           
protected static void writeGroup(CodedOutputStream output, int tag, BaseMessage message)
           
protected static void writeMessage(CodedOutputStream output, int tag, BaseMessage message)
           
 void writeUnframed(CodedOutputStream output)
           
 void writeUnframed(java.io.OutputStream output)
           
 
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.activemq.protobuf.Message
mergeUnframed, serializedSizeUnframed
 

Field Detail

memoizedSerializedSize

protected int memoizedSerializedSize
Constructor Detail

BaseMessage

public BaseMessage()
Method Detail

clone

public abstract T clone()
                 throws java.lang.CloneNotSupportedException
Specified by:
clone in interface Message<T>
Overrides:
clone in class java.lang.Object
Throws:
java.lang.CloneNotSupportedException

clear

public void clear()
Specified by:
clear in interface Message<T>

isInitialized

public boolean isInitialized()

assertInitialized

public T assertInitialized()
                    throws UninitializedMessageException
Specified by:
assertInitialized in interface Message<T>
Throws:
UninitializedMessageException

checktInitialized

protected T checktInitialized()
                       throws InvalidProtocolBufferException
Throws:
InvalidProtocolBufferException

missingFields

public java.util.ArrayList<java.lang.String> missingFields()

loadAndClear

protected void loadAndClear()

load

protected void load()

mergeFrom

public T mergeFrom(T other)
Specified by:
mergeFrom in interface Message<T>

writeUnframed

public void writeUnframed(CodedOutputStream output)
                   throws java.io.IOException
Specified by:
writeUnframed in interface Message<T>
Throws:
java.io.IOException

writeFramed

public void writeFramed(CodedOutputStream output)
                 throws java.io.IOException
Specified by:
writeFramed in interface Message<T>
Throws:
java.io.IOException

toUnframedBuffer

public Buffer toUnframedBuffer()
Specified by:
toUnframedBuffer in interface Message<T>

toFramedBuffer

public Buffer toFramedBuffer()
Specified by:
toFramedBuffer in interface Message<T>

toUnframedByteArray

public byte[] toUnframedByteArray()
Specified by:
toUnframedByteArray in interface Message<T>

toFramedByteArray

public byte[] toFramedByteArray()
Specified by:
toFramedByteArray in interface Message<T>

writeFramed

public void writeFramed(java.io.OutputStream output)
                 throws java.io.IOException
Specified by:
writeFramed in interface Message<T>
Throws:
java.io.IOException

writeUnframed

public void writeUnframed(java.io.OutputStream output)
                   throws java.io.IOException
Specified by:
writeUnframed in interface Message<T>
Throws:
java.io.IOException

serializedSizeFramed

public int serializedSizeFramed()
Specified by:
serializedSizeFramed in interface Message<T>

mergeFramed

public T mergeFramed(CodedInputStream input)
              throws java.io.IOException
Specified by:
mergeFramed in interface Message<T>
Throws:
java.io.IOException

mergeUnframed

public T mergeUnframed(Buffer data)
                throws InvalidProtocolBufferException
Specified by:
mergeUnframed in interface Message<T>
Throws:
InvalidProtocolBufferException

mergeFramed

public T mergeFramed(Buffer data)
              throws InvalidProtocolBufferException
Specified by:
mergeFramed in interface Message<T>
Throws:
InvalidProtocolBufferException

mergeUnframed

public T mergeUnframed(byte[] data)
                throws InvalidProtocolBufferException
Specified by:
mergeUnframed in interface Message<T>
Throws:
InvalidProtocolBufferException

mergeFramed

public T mergeFramed(byte[] data)
              throws InvalidProtocolBufferException
Specified by:
mergeFramed in interface Message<T>
Throws:
InvalidProtocolBufferException

mergeUnframed

public T mergeUnframed(java.io.InputStream input)
                throws java.io.IOException
Specified by:
mergeUnframed in interface Message<T>
Throws:
java.io.IOException

mergeFramed

public T mergeFramed(java.io.InputStream input)
              throws java.io.IOException
Specified by:
mergeFramed in interface Message<T>
Throws:
java.io.IOException

addAll

protected static <T> void addAll(java.lang.Iterable<T> values,
                                 java.util.Collection<? super T> list)

writeGroup

protected static void writeGroup(CodedOutputStream output,
                                 int tag,
                                 BaseMessage message)
                          throws java.io.IOException
Throws:
java.io.IOException

readGroup

protected static <T extends BaseMessage> T readGroup(CodedInputStream input,
                                                     int tag,
                                                     T group)
                                          throws java.io.IOException
Throws:
java.io.IOException

computeGroupSize

protected static int computeGroupSize(int tag,
                                      BaseMessage message)

writeMessage

protected static void writeMessage(CodedOutputStream output,
                                   int tag,
                                   BaseMessage message)
                            throws java.io.IOException
Throws:
java.io.IOException

computeMessageSize

protected static int computeMessageSize(int tag,
                                        BaseMessage message)

prefix

protected java.util.List<java.lang.String> prefix(java.util.List<java.lang.String> missingFields,
                                                  java.lang.String prefix)

readRawVarint32

public static int readRawVarint32(java.io.InputStream is)
                           throws java.io.IOException
Read a raw Varint from the stream. If larger than 32 bits, discard the upper bits.

Throws:
java.io.IOException

readRawByte

protected static byte readRawByte(java.io.InputStream is)
                           throws java.io.IOException
Throws:
java.io.IOException


Copyright © 2011 Apache Software Foundation. All Rights Reserved.