Class InputStreamMessageReader

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, IMessageReader

    public class InputStreamMessageReader
    extends java.lang.Object
    implements IMessageReader
    • Field Summary

      Fields 
      Modifier and Type Field Description
      private byte[] body  
      private byte[] buf  
      private byte[] header  
      private java.nio.channels.SocketChannel inputChannel  
      private int[] len  
      private org.slf4j.Logger logger  
      private byte[] tbuf  
    • Constructor Summary

      Constructors 
      Constructor Description
      InputStreamMessageReader​(java.nio.channels.SocketChannel _in)  
    • Field Detail

      • logger

        private final org.slf4j.Logger logger
      • len

        private final int[] len
      • buf

        private final byte[] buf
      • tbuf

        private final byte[] tbuf
      • inputChannel

        private final java.nio.channels.SocketChannel inputChannel
      • header

        private byte[] header
      • body

        private byte[] body
    • Constructor Detail

      • InputStreamMessageReader

        public InputStreamMessageReader​(java.nio.channels.SocketChannel _in)
    • Method Detail

      • close

        public void close()
                   throws java.io.IOException
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Throws:
        java.io.IOException