public class GraphBinaryMessageSerializerV1 extends AbstractMessageSerializer
| Modifier and Type | Field and Description |
|---|---|
static String |
TOKEN_BUILDER |
static String |
TOKEN_CUSTOM |
TOKEN_IO_REGISTRIESlogger| Constructor and Description |
|---|
GraphBinaryMessageSerializerV1()
Creates a new instance of the message serializer using the default type serializers.
|
GraphBinaryMessageSerializerV1(TypeSerializerRegistry.Builder builder) |
GraphBinaryMessageSerializerV1(TypeSerializerRegistry registry) |
| 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. |
addIoRegistries, getListStringFromConfig, tryInstanceMethodpublic static final String TOKEN_CUSTOM
public static final String TOKEN_BUILDER
public GraphBinaryMessageSerializerV1()
public GraphBinaryMessageSerializerV1(TypeSerializerRegistry registry)
public GraphBinaryMessageSerializerV1(TypeSerializerRegistry.Builder builder)
public void configure(Map<String,Object> config, Map<String,Graph> graphs)
MessageSerializerpublic ByteBuf serializeResponseAsBinary(ResponseMessage responseMessage, ByteBufAllocator allocator) throws SerializationException
MessageSerializerResponseMessage to a Netty ByteBuf.responseMessage - The response message to serialize to bytes.allocator - The Netty allocator for the ByteBuf to return back.SerializationExceptionpublic ByteBuf serializeRequestAsBinary(RequestMessage requestMessage, ByteBufAllocator allocator) throws SerializationException
MessageSerializerResponseMessage to a Netty ByteBuf.requestMessage - The request message to serialize to bytes.allocator - The Netty allocator for the ByteBuf to return back.SerializationExceptionpublic RequestMessage deserializeRequest(ByteBuf msg) throws SerializationException
MessageSerializerByteBuf into a RequestMessage.SerializationExceptionpublic ResponseMessage deserializeResponse(ByteBuf msg) throws SerializationException
MessageSerializerByteBuf into a ResponseMessage.SerializationExceptionpublic String[] mimeTypesSupported()
MessageSerializerCopyright © 2013–2019 Apache Software Foundation. All rights reserved.