public class MindRpcSerializer extends java.lang.Object implements org.springframework.core.serializer.Serializer<MindRpcMessageHolder>, org.springframework.core.serializer.Deserializer<MindRpcMessageHolder>
Serializer、Deserializer インターフェース。| 修飾子と型 | フィールドと説明 |
|---|---|
protected int | maxMessageSize |
| コンストラクターと説明 |
|---|
MindRpcSerializer() |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected void | checkClosure(int bite) |
MindRpcMessageHolder | deserialize(java.io.InputStream inputStream) |
protected byte[] | readBytes(java.io.InputStream inputStream, int length) ストリームからバイトを読み取るヘルパーメソッド。 |
protected int[] | readHeader(java.io.InputStream inputStream) 最初の行をプロトコルヘッダーとして読み取り、基になるヘッダーとコンテンツのサイズを解析します。 |
protected java.util.Map<java.lang.String,java.lang.String> | readHeaders(java.io.InputStream inputStream, int length) 指定された長さの入力ストリームからメッセージヘッダーを読み取ります。 |
void | serialize(MindRpcMessageHolder object, java.io.OutputStream outputStream) |
void | setMaxMessageSize(int maxMessageSize) トランスポートの最大メッセージサイズを設定します。 |
public MindRpcMessageHolder deserialize(java.io.InputStream inputStream) throws java.io.IOException
org.springframework.core.serializer.Deserializer<MindRpcMessageHolder> 内の deserialize java.io.IOExceptionDeserializer.deserialize(java.io.InputStream)public void serialize(MindRpcMessageHolder object, java.io.OutputStream outputStream) throws java.io.IOException
org.springframework.core.serializer.Serializer<MindRpcMessageHolder> 内の serialize java.io.IOExceptionSerializer.serialize(java.lang.Object, java.io.OutputStream)public void setMaxMessageSize(int maxMessageSize)
maxMessageSize - 最大メッセージの長さ protected int[] readHeader(java.io.InputStream inputStream)
throws java.io.IOExceptioninputStream - 入力ストリーム java.io.IOException - 読み取りエラーが発生した場合 protected java.util.Map<java.lang.String,java.lang.String> readHeaders(java.io.InputStream inputStream,
int length)
throws java.io.IOExceptioninputStream - 入力ストリーム length - ストリームからどれだけ読み取るか java.io.IOException - エラーが発生した場合 protected byte[] readBytes(java.io.InputStream inputStream,
int length)
throws java.io.IOExceptioninputStream - 入力ストリーム length - どれくらい読むか java.io.IOException - エラーが発生した場合 protected void checkClosure(int bite)
throws java.io.IOExceptionjava.io.IOException