org.apache.activemq.protobuf
public final class MessageBufferSupport extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
FORZEN_ERROR_MESSAGE |
Constructor and Description |
---|
MessageBufferSupport() |
Modifier and Type | Method and Description |
---|---|
static <T> void |
addAll(java.lang.Iterable<T> values,
java.util.Collection<? super T> list) |
static int |
computeMessageSize(int tag,
MessageBuffer message) |
static Buffer |
readFrame(java.io.InputStream input) |
static byte |
readRawByte(java.io.InputStream is) |
static int |
readRawVarint32(java.io.InputStream is)
Read a raw Varint from the stream.
|
static Buffer |
toFramedBuffer(MessageBuffer message) |
static Buffer |
toUnframedBuffer(MessageBuffer message) |
static void |
writeMessage(CodedOutputStream output,
int tag,
MessageBuffer message) |
public static final java.lang.String FORZEN_ERROR_MESSAGE
public static Buffer toUnframedBuffer(MessageBuffer message)
public static Buffer toFramedBuffer(MessageBuffer message)
public static void writeMessage(CodedOutputStream output, int tag, MessageBuffer message) throws java.io.IOException
java.io.IOException
public static int computeMessageSize(int tag, MessageBuffer message)
public static Buffer readFrame(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static int readRawVarint32(java.io.InputStream is) throws java.io.IOException
java.io.IOException
public static byte readRawByte(java.io.InputStream is) throws java.io.IOException
java.io.IOException
public static <T> void addAll(java.lang.Iterable<T> values, java.util.Collection<? super T> list)
Copyright © 2014. All Rights Reserved.