services.moleculer.transporter.tcp

Class TcpWriter

java.lang.Object

services.moleculer.transporter.tcp.TcpWriter

All Implemented Interfaces:

java.lang.Runnable

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

Packet sender Thread of the TCP Transporter.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TcpWriter(TcpTransporter transporter)

Method Summary

Modifier and Type	Method and Description
protected boolean	append(java.lang.String nodeID, SendBuffer buffer, byte[] packet)
protected void	cleanup()
protected void	close(java.nio.channels.SelectionKey key, java.lang.Exception cause)
void	close(java.lang.String nodeID)
void	connect()
void	disconnect()
protected void	finalize()
void	run()
void	send(java.lang.String nodeID, byte[] packet)

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

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 java.util.concurrent.ConcurrentLinkedQueue<SendBuffer> opened

buffers

protected final java.util.LinkedHashMap<java.lang.String,SendBuffer> buffers

selector

protected java.nio.channels.Selector selector

executor

protected java.util.concurrent.ExecutorService executor

Writer thread

Constructor Detail

TcpWriter

public TcpWriter(TcpTransporter transporter)

Method Detail

connect

public void connect()
             throws java.lang.Exception

Throws:

java.lang.Exception

finalize

protected void finalize()
                 throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

disconnect

public void disconnect()

close

public void close(java.lang.String nodeID)

send

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

append

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

run

public void run()

Specified by:

run in interface java.lang.Runnable

cleanup

protected void cleanup()

close

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