Package org.infinispan.commons.marshall

Class ImmutableProtoStreamMarshaller

java.lang.Object

org.infinispan.commons.marshall.AbstractMarshaller

org.infinispan.commons.marshall.ImmutableProtoStreamMarshaller

All Implemented Interfaces:

Marshaller

Direct Known Subclasses:

ProtoStreamMarshaller

public class ImmutableProtoStreamMarshaller
extends AbstractMarshaller

A ProtoStream Marshaller implementation that uses Protobuf encoding.

Since:

12.0

Author:

Ryan Emerson

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.infinispan.protostream.ImmutableSerializationContext	serializationContext

Fields inherited from class org.infinispan.commons.marshall.AbstractMarshaller

marshallableTypeHints

Constructor Summary

Constructors

Constructor	Description
ImmutableProtoStreamMarshaller(org.infinispan.protostream.ImmutableSerializationContext serializationContext)

Method Summary

Modifier and Type	Method	Description
org.infinispan.protostream.ImmutableSerializationContext	getSerializationContext()
boolean	isMarshallable(Object o)	A method that checks whether the given object is marshallable as per the rules of this marshaller.
MediaType	mediaType()
Object	objectFromByteBuffer(byte[] buf, int offset, int length)	Unmarshalls an object from a specific portion of a byte array.
Object	objectFromInputStream(InputStream inputStream)	This method implements StreamingMarshaller.objectFromInputStream(java.io.InputStream), but its implementation has been moved here rather that keeping under a class that implements StreamingMarshaller in order to avoid code duplication.
protected ByteBuffer	objectToBuffer(Object o, int estimatedSize)	This is a convenience method for converting an object into a ByteBuffer which takes an estimated size as parameter.

Methods inherited from class org.infinispan.commons.marshall.AbstractMarshaller

getBufferSizePredictor, objectFromByteBuffer, objectToBuffer, objectToByteBuffer, objectToByteBuffer, objectToOutputStream

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.commons.marshall.Marshaller

initialize, start, stop

Field Details

serializationContext

protected final org.infinispan.protostream.ImmutableSerializationContext serializationContext

Constructor Details

ImmutableProtoStreamMarshaller

public ImmutableProtoStreamMarshaller(org.infinispan.protostream.ImmutableSerializationContext serializationContext)

Method Details

getSerializationContext

public org.infinispan.protostream.ImmutableSerializationContext getSerializationContext()

objectFromByteBuffer

public Object objectFromByteBuffer(byte[] buf,
 int offset,
 int length)
                            throws IOException,
ClassNotFoundException

Description copied from interface: Marshaller

Unmarshalls an object from a specific portion of a byte array.

Parameters:

buf - byte array containing the binary representation of an object. Must not be null.

offset - point in buffer to start reading

length - number of bytes to consider

Returns:

an object

Throws:

IOException - if unmarshalling cannot complete due to some I/O error

ClassNotFoundException - if the class of the object trying to unmarshall is unknown

objectFromInputStream

public Object objectFromInputStream(InputStream inputStream)
                             throws IOException

Description copied from class: AbstractMarshaller

This method implements StreamingMarshaller.objectFromInputStream(java.io.InputStream), but its implementation has been moved here rather that keeping under a class that implements StreamingMarshaller in order to avoid code duplication.

Overrides:

objectFromInputStream in class AbstractMarshaller

Throws:

IOException

isMarshallable

public boolean isMarshallable(Object o)

Description copied from interface: Marshaller

A method that checks whether the given object is marshallable as per the rules of this marshaller.

Parameters:

o - object to verify whether it's marshallable or not

Returns:

true if the object is marshallable, otherwise false

objectToBuffer

protected ByteBuffer objectToBuffer(Object o,
 int estimatedSize)
                             throws IOException

Description copied from class: AbstractMarshaller

This is a convenience method for converting an object into a ByteBuffer which takes an estimated size as parameter. A ByteBuffer allows direct access to the byte array with minimal array copying

Specified by:

objectToBuffer in class AbstractMarshaller

Parameters:

o - object to marshall

estimatedSize - an estimate of how large the resulting byte array may be

Throws:

IOException

mediaType

public MediaType mediaType()

Returns:

the MediaType associated with the content produced by the marshaller