Class PlainClient

  • Direct Known Subclasses:
    StompClient

    public abstract class PlainClient
    extends StompCommonClient
    ReactorClient implementation to provide not encrypted communication.
    • Field Detail

      • selector

        protected final java.nio.channels.Selector selector
    • Constructor Detail

      • PlainClient

        public PlainClient​(Reactor reactor,
                           java.nio.channels.Selector selector,
                           java.lang.String hostname,
                           int port)
    • Method Detail

      • read

        protected int read​(java.nio.ByteBuffer buff)
                    throws java.io.IOException
        Description copied from class: ReactorClient
        Reads provided buffer.
        Specified by:
        read in class ReactorClient
        Parameters:
        buff - provided buffer to be read.
        Returns:
        Number of bytes read.
        Throws:
        java.io.IOException - when networking issue occurs.
      • write

        protected void write​(java.nio.ByteBuffer buff)
                      throws java.io.IOException
        Description copied from class: ReactorClient
        Writes provided buffer.
        Specified by:
        write in class ReactorClient
        Parameters:
        buff - provided buffer to be written.
        Throws:
        java.io.IOException - when networking issue occurs.