org.apache.activemq.protobuf
Class MessageBufferSupport
java.lang.Object
org.apache.activemq.protobuf.MessageBufferSupport
public final class MessageBufferSupport
- extends java.lang.Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
FORZEN_ERROR_MESSAGE
public static final java.lang.String FORZEN_ERROR_MESSAGE
- See Also:
- Constant Field Values
MessageBufferSupport
public MessageBufferSupport()
toUnframedBuffer
public static Buffer toUnframedBuffer(MessageBuffer message)
toFramedBuffer
public static Buffer toFramedBuffer(MessageBuffer message)
writeMessage
public static void writeMessage(CodedOutputStream output,
int tag,
MessageBuffer message)
throws java.io.IOException
- Throws:
java.io.IOException
computeMessageSize
public static int computeMessageSize(int tag,
MessageBuffer message)
readFrame
public static Buffer readFrame(java.io.InputStream input)
throws java.io.IOException
- Throws:
java.io.IOException
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
public static byte readRawByte(java.io.InputStream is)
throws java.io.IOException
- Throws:
java.io.IOException
addAll
public static <T> void addAll(java.lang.Iterable<T> values,
java.util.Collection<? super T> list)
Copyright © 2011. All Rights Reserved.