Package pt.unl.fct.di.novasys.channel.tcp

Class MultithreadedTCPChannel<T>

java.lang.Object

pt.unl.fct.di.novasys.channel.tcp.MultithreadedTCPChannel<T>

All Implemented Interfaces:

IChannel<T>, AttributeValidator, InConnListener<T>, MessageListener<T>, OutConnListener<T>

public class MultithreadedTCPChannel<T>
extends Object
implements IChannel<T>, MessageListener<T>, InConnListener<T>, OutConnListener<T>, AttributeValidator

Multithreaded channel with explicit openConnection.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ADDRESS_KEY
static final int	CONNECTION_IN
static final int	CONNECTION_OUT
static final int	DEFAULT_PORT
static final String	LISTEN_ADDRESS_ATTRIBUTE
static final String	NAME
static final String	PORT_KEY
static final String	WORKER_GROUP_KEY

Fields inherited from interface pt.unl.fct.di.novasys.network.AttributeValidator

ALWAYS_VALID, CHANNEL_MAGIC_ATTRIBUTE

Constructor Summary

Constructors

Constructor	Description
MultithreadedTCPChannel(ISerializer<T> serializer, ChannelListener<T> list, Properties properties)

Method Summary

Modifier and Type	Method	Description
void	closeConnection(Host peer, int connection)
void	deliverMessage(T msg, Connection<T> conn)	Method that is called to deliver a message from the network layer to the application
void	inboundConnectionDown(Connection<T> conn, Throwable cause)
void	inboundConnectionUp(Connection<T> con)
void	openConnection(Host peer)
void	outboundConnectionDown(Connection<T> conn, Throwable cause)
void	outboundConnectionFailed(Connection<T> conn, Throwable cause)
void	outboundConnectionUp(Connection<T> conn)
void	sendMessage(T msg, Host peer, int connection)
void	serverSocketBind(boolean success, Throwable cause)
void	serverSocketClose(boolean success, Throwable cause)
boolean	validateAttributes(Attributes attr)

Methods inherited from class java.lang.Object

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

Field Details

NAME

public static final String NAME

See Also:

• Constant Field Values

ADDRESS_KEY

public static final String ADDRESS_KEY

See Also:

• Constant Field Values

PORT_KEY

public static final String PORT_KEY

See Also:

• Constant Field Values

WORKER_GROUP_KEY

public static final String WORKER_GROUP_KEY

See Also:

• Constant Field Values

LISTEN_ADDRESS_ATTRIBUTE

public static final String LISTEN_ADDRESS_ATTRIBUTE

See Also:

• Constant Field Values

DEFAULT_PORT

public static final int DEFAULT_PORT

See Also:

• Constant Field Values

CONNECTION_OUT

public static final int CONNECTION_OUT

See Also:

• Constant Field Values

CONNECTION_IN

public static final int CONNECTION_IN

See Also:

• Constant Field Values

Constructor Details

MultithreadedTCPChannel

public MultithreadedTCPChannel(ISerializer<T> serializer,
 ChannelListener<T> list,
 Properties properties)
                        throws IOException

Throws:

IOException

Method Details

openConnection

public void openConnection(Host peer)

Specified by:

openConnection in interface IChannel<T>

sendMessage

public void sendMessage(T msg,
 Host peer,
 int connection)

Specified by:

sendMessage in interface IChannel<T>

closeConnection

public void closeConnection(Host peer,
 int connection)

Specified by:

closeConnection in interface IChannel<T>

outboundConnectionUp

public void outboundConnectionUp(Connection<T> conn)

Specified by:

outboundConnectionUp in interface OutConnListener<T>

outboundConnectionDown

public void outboundConnectionDown(Connection<T> conn,
 Throwable cause)

Specified by:

outboundConnectionDown in interface OutConnListener<T>

outboundConnectionFailed

public void outboundConnectionFailed(Connection<T> conn,
 Throwable cause)

Specified by:

outboundConnectionFailed in interface OutConnListener<T>

inboundConnectionUp

public void inboundConnectionUp(Connection<T> con)

Specified by:

inboundConnectionUp in interface InConnListener<T>

inboundConnectionDown

public void inboundConnectionDown(Connection<T> conn,
 Throwable cause)

Specified by:

inboundConnectionDown in interface InConnListener<T>

deliverMessage

public void deliverMessage(T msg,
 Connection<T> conn)

Description copied from interface: MessageListener

Method that is called to deliver a message from the network layer to the application

Specified by:

deliverMessage in interface MessageListener<T>

Parameters:

msg - The received message

serverSocketBind

public void serverSocketBind(boolean success,
 Throwable cause)

Specified by:

serverSocketBind in interface InConnListener<T>

serverSocketClose

public void serverSocketClose(boolean success,
 Throwable cause)

Specified by:

serverSocketClose in interface InConnListener<T>

validateAttributes

public boolean validateAttributes(Attributes attr)

Specified by:

validateAttributes in interface AttributeValidator