org.springframework.yarn.integration.ip.mind

Class MindRpcSerializer

java.lang.Object

org.springframework.yarn.integration.ip.mind.MindRpcSerializer

All Implemented Interfaces:

org.springframework.core.serializer.Deserializer<MindRpcMessageHolder>, org.springframework.core.serializer.Serializer<MindRpcMessageHolder>

public class MindRpcSerializer
extends java.lang.Object
implements org.springframework.core.serializer.Serializer<MindRpcMessageHolder>, org.springframework.core.serializer.Deserializer<MindRpcMessageHolder>

Spring Serializer and Deserializer interfaces for mind protocol.

Author:

Janne Valkealahti

Field Summary

Fields

Modifier and Type	Field and Description
protected int	maxMessageSize

Constructor Summary

Constructors

Constructor and Description
MindRpcSerializer()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	checkClosure(int bite)
MindRpcMessageHolder	deserialize(java.io.InputStream inputStream)
protected byte[]	readBytes(java.io.InputStream inputStream, int length) Helper method to read bytes from a stream.
protected int[]	readHeader(java.io.InputStream inputStream) Reads the first line as a protocol header and parses sizes of underlying headers and content.
protected java.util.Map<java.lang.String,java.lang.String>	readHeaders(java.io.InputStream inputStream, int length) Reads a message headers from inputstream with a given length.
void	serialize(MindRpcMessageHolder object, java.io.OutputStream outputStream)
void	setMaxMessageSize(int maxMessageSize) Sets the max message size for transport.

Methods inherited from class java.lang.Object

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

Field Detail

maxMessageSize

protected int maxMessageSize

Constructor Detail

MindRpcSerializer

public MindRpcSerializer()

Method Detail

deserialize

public MindRpcMessageHolder deserialize(java.io.InputStream inputStream)
                                 throws java.io.IOException

Specified by:

deserialize in interface org.springframework.core.serializer.Deserializer<MindRpcMessageHolder>

Throws:

java.io.IOException

See Also:

Deserializer.deserialize(java.io.InputStream)

serialize

public void serialize(MindRpcMessageHolder object,
             java.io.OutputStream outputStream)
               throws java.io.IOException

Specified by:

serialize in interface org.springframework.core.serializer.Serializer<MindRpcMessageHolder>

Throws:

java.io.IOException

See Also:

Serializer.serialize(java.lang.Object, java.io.OutputStream)

setMaxMessageSize

public void setMaxMessageSize(int maxMessageSize)

Sets the max message size for transport.

Parameters:

maxMessageSize - the length of max message

readHeader

protected int[] readHeader(java.io.InputStream inputStream)
                    throws java.io.IOException

Reads the first line as a protocol header and parses sizes of underlying headers and content.

Parameters:

inputStream - the input stream

Returns:

int array containing sizes of headers and content

Throws:

java.io.IOException - if read error occured

readHeaders

protected java.util.Map<java.lang.String,java.lang.String> readHeaders(java.io.InputStream inputStream,
                                                           int length)
                                                                throws java.io.IOException

Reads a message headers from inputstream with a given length.

Parameters:

inputStream - the input stream

length - how much to read from a stream

Returns:

Map of headers

Throws:

java.io.IOException - if error occured

readBytes

protected byte[] readBytes(java.io.InputStream inputStream,
               int length)
                    throws java.io.IOException

Helper method to read bytes from a stream.

Parameters:

inputStream - the input stream

length - how much to read

Returns:

bytes to read

Throws:

java.io.IOException - if error occured

checkClosure

protected void checkClosure(int bite)
                     throws java.io.IOException

Throws:

java.io.IOException