Class TcpWriter

java.lang.Object

services.moleculer.transporter.tcp.TcpWriter

public class TcpWriter
extends Object

Packet sender Thread of the TCP Transporter.

Field Summary

Fields

Modifier and Type	Field	Description
protected final LinkedHashMap<String, SendBuffer>	buffers
protected final boolean	debug	Debug mode
protected ExecutorService	executor	Writer thread
protected static final org.slf4j.Logger	logger
protected final int	maxConnections	Max number of opened connections
protected final ConcurrentLinkedQueue<SendBuffer>	opened
protected Selector	selector
protected final TcpTransporter	transporter

Constructor Summary

Constructors

Constructor	Description
TcpWriter(TcpTransporter transporter)

Method Summary

Modifier and Type	Method	Description
protected boolean	append(String nodeID, SendBuffer buffer, byte[] packet)
protected void	cleanup()
void	close(String nodeID)
protected void	close(SelectionKey key, Exception cause)
void	connect()
void	disconnect()
protected void	finalize()
void	openConnections()
void	send(String nodeID, byte[] packet)
void	sendPackets()

Methods inherited from class Object

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

Field Details

logger

protected static final org.slf4j.Logger logger

maxConnections

protected final int maxConnections

Max number of opened connections

debug

protected final boolean debug

Debug mode

transporter

protected final TcpTransporter transporter

opened

protected final ConcurrentLinkedQueue<SendBuffer> opened

buffers

protected final LinkedHashMap<String, SendBuffer> buffers

selector

protected Selector selector

executor

protected ExecutorService executor

Writer thread

Constructor Details

TcpWriter

public TcpWriter(TcpTransporter transporter)

Method Details

connect

public void connect()
             throws Exception

Throws:

Exception

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

disconnect

public void disconnect()

close

public void close(String nodeID)

send

public void send(String nodeID,
 byte[] packet)

append

protected boolean append(String nodeID,
 SendBuffer buffer,
 byte[] packet)

openConnections

public void openConnections()

sendPackets

public void sendPackets()

cleanup

protected void cleanup()

close

protected void close(SelectionKey key,
 Exception cause)