org.infinispan.protostream

Class ProtobufUtil

java.lang.Object

org.infinispan.protostream.ProtobufUtil

public final class ProtobufUtil
extends Object

Since:

1.0

Author:

anistor@redhat.com

Constructor Summary

Constructors

Constructor and Description
ProtobufUtil()

Method Summary

Modifier and Type	Method and Description
static <A> A	fromByteArray(SerializationContext ctx, byte[] bytes, Class<A> clazz)
static <A> A	fromByteArray(SerializationContext ctx, byte[] bytes, int offset, int length, Class<A> clazz)
static <A> A	fromByteBuffer(SerializationContext ctx, ByteBuffer byteBuffer, Class<A> clazz)
static Object	fromWrappedByteArray(SerializationContext ctx, byte[] bytes) Parses a top-level message that was wrapped according to the org.infinispan.protostream.WrappedMessage proto definition.
static Object	fromWrappedByteArray(SerializationContext ctx, byte[] bytes, int offset, int length)
static Object	fromWrappedByteBuffer(SerializationContext ctx, ByteBuffer byteBuffer)
static SerializationContext	newSerializationContext(Configuration configuration)
static <A> A	readFrom(SerializationContext ctx, InputStream in, Class<A> clazz)
static byte[]	toByteArray(SerializationContext ctx, Object t)
static ByteBuffer	toByteBuffer(SerializationContext ctx, Object t)
static byte[]	toWrappedByteArray(SerializationContext ctx, Object t)
static ByteBuffer	toWrappedByteBuffer(SerializationContext ctx, Object t)
static void	writeTo(SerializationContext ctx, OutputStream out, Object t)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProtobufUtil

public ProtobufUtil()

Method Detail

newSerializationContext

public static SerializationContext newSerializationContext(Configuration configuration)

writeTo

public static void writeTo(SerializationContext ctx,
                           OutputStream out,
                           Object t)
                    throws IOException

Throws:

IOException

toByteArray

public static byte[] toByteArray(SerializationContext ctx,
                                 Object t)
                          throws IOException

Throws:

IOException

toByteBuffer

public static ByteBuffer toByteBuffer(SerializationContext ctx,
                                      Object t)
                               throws IOException

Throws:

IOException

readFrom

public static <A> A readFrom(SerializationContext ctx,
                             InputStream in,
                             Class<A> clazz)
                      throws IOException

Throws:

IOException

fromByteArray

public static <A> A fromByteArray(SerializationContext ctx,
                                  byte[] bytes,
                                  Class<A> clazz)
                           throws IOException

Throws:

IOException

fromByteArray

public static <A> A fromByteArray(SerializationContext ctx,
                                  byte[] bytes,
                                  int offset,
                                  int length,
                                  Class<A> clazz)
                           throws IOException

Throws:

IOException

fromByteBuffer

public static <A> A fromByteBuffer(SerializationContext ctx,
                                   ByteBuffer byteBuffer,
                                   Class<A> clazz)
                            throws IOException

Throws:

IOException

fromWrappedByteArray

public static Object fromWrappedByteArray(SerializationContext ctx,
                                          byte[] bytes)
                                   throws IOException

Parses a top-level message that was wrapped according to the org.infinispan.protostream.WrappedMessage proto definition.

Parameters:

ctx -

bytes -

Returns:

Throws:

IOException

fromWrappedByteArray

public static Object fromWrappedByteArray(SerializationContext ctx,
                                          byte[] bytes,
                                          int offset,
                                          int length)
                                   throws IOException

Throws:

IOException

fromWrappedByteBuffer

public static Object fromWrappedByteBuffer(SerializationContext ctx,
                                           ByteBuffer byteBuffer)
                                    throws IOException

Throws:

IOException

toWrappedByteArray

public static byte[] toWrappedByteArray(SerializationContext ctx,
                                        Object t)
                                 throws IOException

Throws:

IOException

toWrappedByteBuffer

public static ByteBuffer toWrappedByteBuffer(SerializationContext ctx,
                                             Object t)
                                      throws IOException

Throws:

IOException