org.infinispan.protostream

Class ProtobufUtil

java.lang.Object

org.infinispan.protostream.ProtobufUtil

public final class ProtobufUtil
extends java.lang.Object

Since:

1.0

Field Summary

Fields

Modifier and Type	Field and Description
private static java.lang.String	WRAPPING_DEFINITIONS_RES

Constructor Summary

Constructors

Constructor and Description
ProtobufUtil()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

WRAPPING_DEFINITIONS_RES

private static final java.lang.String WRAPPING_DEFINITIONS_RES

See Also:

Constant Field Values

Constructor Detail

ProtobufUtil

public ProtobufUtil()

Method Detail

newSerializationContext

public static SerializationContext newSerializationContext(Configuration configuration)

writeTo

private static <A> void writeTo(SerializationContext ctx,
                                RawProtoStreamWriter out,
                                A t)
                         throws java.io.IOException

Throws:

java.io.IOException

writeTo

public static void writeTo(SerializationContext ctx,
                           java.io.OutputStream out,
                           java.lang.Object t)
                    throws java.io.IOException

Throws:

java.io.IOException

toByteArray

public static byte[] toByteArray(SerializationContext ctx,
                                 java.lang.Object t)
                          throws java.io.IOException

Throws:

java.io.IOException

toByteBuffer

public static java.nio.ByteBuffer toByteBuffer(SerializationContext ctx,
                                               java.lang.Object t)
                                        throws java.io.IOException

Throws:

java.io.IOException

readFrom

private static <A> A readFrom(SerializationContext ctx,
                              RawProtoStreamReader in,
                              java.lang.Class<A> clazz)
                       throws java.io.IOException

Throws:

java.io.IOException

readFrom

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

Throws:

java.io.IOException

fromByteArray

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

Throws:

java.io.IOException

fromByteArray

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

Throws:

java.io.IOException

fromByteBuffer

public static <A> A fromByteBuffer(SerializationContext ctx,
                                   java.nio.ByteBuffer byteBuffer,
                                   java.lang.Class<A> clazz)
                            throws java.io.IOException

Throws:

java.io.IOException

fromWrappedByteArray

public static java.lang.Object fromWrappedByteArray(SerializationContext ctx,
                                                    byte[] bytes)
                                             throws java.io.IOException

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

Parameters:

ctx -

bytes -

Returns:

Throws:

java.io.IOException

fromWrappedByteArray

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

Throws:

java.io.IOException

fromWrappedByteBuffer

public static java.lang.Object fromWrappedByteBuffer(SerializationContext ctx,
                                                     java.nio.ByteBuffer byteBuffer)
                                              throws java.io.IOException

Throws:

java.io.IOException

toWrappedByteArray

public static byte[] toWrappedByteArray(SerializationContext ctx,
                                        java.lang.Object t)
                                 throws java.io.IOException

Throws:

java.io.IOException

toWrappedByteBuffer

public static java.nio.ByteBuffer toWrappedByteBuffer(SerializationContext ctx,
                                                      java.lang.Object t)
                                               throws java.io.IOException

Throws:

java.io.IOException