フィールドの詳細

• maxMessageSize

  protected int maxMessageSize

コンストラクターの詳細

• MindRpcSerializer

  public MindRpcSerializer()

メソッドの詳細

• deserialize

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

  次で指定:

  インターフェース org.springframework.core.serializer.Deserializer<MindRpcMessageHolder> の deserialize 

  例外:

  java.io.IOException

  関連事項:

  Deserializer.deserialize(java.io.InputStream)

• serialize

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

  次で指定:

  インターフェース org.springframework.core.serializer.Serializer<MindRpcMessageHolder> の serialize 

  例外:

  java.io.IOException

  関連事項:

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

• setMaxMessageSize

  public void setMaxMessageSize(int maxMessageSize)

  トランスポートの最大メッセージサイズを設定します。

  パラメーター:

  maxMessageSize - 最大メッセージの長さ

• readHeader

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

  最初の行をプロトコルヘッダーとして読み取り、基になるヘッダーとコンテンツのサイズを解析します。

  パラメーター:

  inputStream - 入力ストリーム

  戻り値:

  ヘッダーとコンテンツのサイズを含む int 配列

  例外:

  java.io.IOException - 読み取りエラーが発生した場合

• readHeaders

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

  指定された長さの入力ストリームからメッセージヘッダーを読み取ります。

  パラメーター:

  inputStream - 入力ストリーム

  length - ストリームからどれだけ読み取るか

  戻り値:

  ヘッダーのマップ

  例外:

  java.io.IOException - エラーが発生した場合

• readBytes

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

  ストリームからバイトを読み取るヘルパーメソッド。

  パラメーター:

  inputStream - 入力ストリーム

  length - どれくらい読むか

  戻り値:

  読み取るバイト数

  例外:

  java.io.IOException - エラーが発生した場合

• checkClosure

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

  例外:

  java.io.IOException