org.apache.tinkerpop.gremlin.driver.ser

Class GryoMessageSerializerV1d0

java.lang.Object

org.apache.tinkerpop.gremlin.driver.ser.GryoMessageSerializerV1d0

All Implemented Interfaces:

MessageSerializer

public final class GryoMessageSerializerV1d0
extends Object
implements MessageSerializer

Author:

Stephen Mallette (http://stephen.genoprime.com)

Field Summary

Fields inherited from interface org.apache.tinkerpop.gremlin.driver.MessageSerializer

logger

Constructor Summary

Constructors

Constructor and Description
GryoMessageSerializerV1d0() Creates an instance with a standard GryoMapper instance.
GryoMessageSerializerV1d0(GryoMapper kryo) Creates an instance with a provided mapper configured GryoMapper instance.

Method Summary

Modifier and Type	Method and Description
void	configure(Map<String,Object> config, Map<String,Graph> graphs) Configure the serializer with mapper settings as required.
RequestMessage	deserializeRequest(ByteBuf msg) Deserialize a Netty ByteBuf into a RequestMessage.
ResponseMessage	deserializeResponse(ByteBuf msg) Deserialize a Netty ByteBuf into a ResponseMessage.
String[]	mimeTypesSupported() The list of mime types that the serializer supports.
ByteBuf	serializeRequestAsBinary(RequestMessage requestMessage, ByteBufAllocator allocator) Serialize a ResponseMessage to a Netty ByteBuf.
ByteBuf	serializeResponseAsBinary(ResponseMessage responseMessage, ByteBufAllocator allocator) Serialize a ResponseMessage to a Netty ByteBuf.

Methods inherited from class java.lang.Object

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

Constructor Detail

GryoMessageSerializerV1d0

public GryoMessageSerializerV1d0()

Creates an instance with a standard GryoMapper instance. Note that this instance will be overriden by configure(java.util.Map<java.lang.String, java.lang.Object>, java.util.Map<java.lang.String, org.apache.tinkerpop.gremlin.structure.Graph>) is called.

GryoMessageSerializerV1d0

public GryoMessageSerializerV1d0(GryoMapper kryo)

Creates an instance with a provided mapper configured GryoMapper instance. Note that this instance will be overriden by configure(java.util.Map<java.lang.String, java.lang.Object>, java.util.Map<java.lang.String, org.apache.tinkerpop.gremlin.structure.Graph>) is called.

Method Detail

configure

public void configure(Map<String,Object> config,
                      Map<String,Graph> graphs)

Description copied from interface: MessageSerializer

Configure the serializer with mapper settings as required. The default implementation does not perform any function and it is up to the interface implementation to determine how the configuration will be executed and what its requirements are. An implementation may choose to use the list of available graphs to help initialize a serializer. The implementation should account for the possibility of a null value being provided for that parameter.

Specified by:

configure in interface MessageSerializer

mimeTypesSupported

public String[] mimeTypesSupported()

Description copied from interface: MessageSerializer

The list of mime types that the serializer supports.

Specified by:

mimeTypesSupported in interface MessageSerializer

deserializeResponse

public ResponseMessage deserializeResponse(ByteBuf msg)
                                    throws SerializationException

Description copied from interface: MessageSerializer

Deserialize a Netty ByteBuf into a ResponseMessage.

Specified by:

deserializeResponse in interface MessageSerializer

Throws:

SerializationException

serializeResponseAsBinary

public ByteBuf serializeResponseAsBinary(ResponseMessage responseMessage,
                                         ByteBufAllocator allocator)
                                  throws SerializationException

Description copied from interface: MessageSerializer

Serialize a ResponseMessage to a Netty ByteBuf.

Specified by:

serializeResponseAsBinary in interface MessageSerializer

Parameters:

responseMessage - The response message to serialize to bytes.

allocator - The Netty allocator for the ByteBuf to return back.

Throws:

SerializationException

deserializeRequest

public RequestMessage deserializeRequest(ByteBuf msg)
                                  throws SerializationException

Description copied from interface: MessageSerializer

Deserialize a Netty ByteBuf into a RequestMessage.

Specified by:

deserializeRequest in interface MessageSerializer

Throws:

SerializationException

serializeRequestAsBinary

public ByteBuf serializeRequestAsBinary(RequestMessage requestMessage,
                                        ByteBufAllocator allocator)
                                 throws SerializationException

Description copied from interface: MessageSerializer

Serialize a ResponseMessage to a Netty ByteBuf.

Specified by:

serializeRequestAsBinary in interface MessageSerializer

Parameters:

requestMessage - The request message to serialize to bytes.

allocator - The Netty allocator for the ByteBuf to return back.

Throws:

SerializationException