services.moleculer.transporter.tcp

Class TcpReader

java.lang.Object

services.moleculer.transporter.tcp.TcpReader

All Implemented Interfaces:

java.lang.Runnable

public class TcpReader
extends java.lang.Object
implements java.lang.Runnable

Packet receiver Thread of the TCP Transporter.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	currentPort Current TPC port
protected boolean	debug Debug mode
protected java.util.concurrent.ExecutorService	executor Server's executor
protected static org.slf4j.Logger	logger
protected int	maxPacketSize Maximum size of an incoming packet
protected java.nio.channels.Selector	selector
protected java.nio.channels.ServerSocketChannel	serverChannel
protected TcpTransporter	transporter Parent transporter

Constructor Summary

Constructors

Constructor and Description
TcpReader(TcpTransporter transporter)

Method Summary

Modifier and Type	Method and Description
protected void	close(java.nio.channels.SelectionKey key, java.lang.Exception cause)
void	connect()
void	disconnect()
protected void	finalize()
int	getCurrentPort()
protected int	processPacket(byte[] bytes, int pos)
void	run()

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

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 java.util.concurrent.ExecutorService executor

Server's executor

currentPort

protected int currentPort

Current TPC port

transporter

protected final TcpTransporter transporter

Parent transporter

serverChannel

protected java.nio.channels.ServerSocketChannel serverChannel

selector

protected java.nio.channels.Selector selector

Constructor Detail

TcpReader

public TcpReader(TcpTransporter transporter)

Method Detail

connect

public void connect()
             throws java.lang.Exception

Throws:

java.lang.Exception

getCurrentPort

public int getCurrentPort()

finalize

protected void finalize()
                 throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

disconnect

public void disconnect()

run

public void run()

Specified by:

run in interface java.lang.Runnable

processPacket

protected int processPacket(byte[] bytes,
                            int pos)
                     throws java.lang.Exception

Throws:

java.lang.Exception

close

protected void close(java.nio.channels.SelectionKey key,
                     java.lang.Exception cause)