Class TcpReader

java.lang.Object
services.moleculer.transporter.tcp.TcpReader
All Implemented Interfaces:
Runnable
public class TcpReader extends Object implements Runnable
Packet receiver Thread of the TCP Transporter.

  • Field Details

    • logger

      protected static final org.slf4j.Logger logger

    • maxPacketSize

      protected int maxPacketSize
      Maximum size of an incoming packet

    • debug

      protected final boolean debug
      Debug mode

    • executor

      protected ExecutorService executor
      Server's executor

    • currentPort

      protected int currentPort
      Current TPC port

    • transporter

      protected final TcpTransporter transporter
      Parent transporter

    • serverChannel

      protected ServerSocketChannel serverChannel

    • selector

      protected Selector selector

  • Constructor Details

  • Method Details