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

Class SimpleServerChannel<T>

java.lang.Object

pt.unl.fct.di.novasys.channel.base.SingleThreadedChannel<T,Y>

pt.unl.fct.di.novasys.channel.base.SingleThreadedServerChannel<T,T>

pt.unl.fct.di.novasys.channel.simpleclientserver.SimpleServerChannel<T>

All Implemented Interfaces:

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

public class SimpleServerChannel<T>
extends SingleThreadedServerChannel<T,T>
implements AttributeValidator

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ADDRESS_KEY
static final String	CONNECT_TIMEOUT_KEY
static final String	DEFAULT_CONNECT_TIMEOUT
static final String	DEFAULT_HB_INTERVAL
static final String	DEFAULT_HB_TOLERANCE
static final String	DEFAULT_PORT
static final String	HEARTBEAT_INTERVAL_KEY
static final String	HEARTBEAT_TOLERANCE_KEY
static final String	NAME
static final String	PORT_KEY
static final String	TRIGGER_SENT_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
SimpleServerChannel(ISerializer<T> serializer, ChannelListener<T> list, Properties properties)

Method Summary

Modifier and Type	Method	Description
void	onDeliverMessage(T msg, Connection<T> conn)
void	onServerSocketBind(boolean success, Throwable cause)
void	onServerSocketClose(boolean success, Throwable cause)
boolean	validateAttributes(Attributes attr)

Methods inherited from class pt.unl.fct.di.novasys.channel.base.SingleThreadedServerChannel

inboundConnectionDown, inboundConnectionUp, serverSocketBind, serverSocketClose

Methods inherited from class pt.unl.fct.di.novasys.channel.base.SingleThreadedChannel

closeConnection, deliverMessage, openConnection, sendMessage

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

HEARTBEAT_INTERVAL_KEY

public static final String HEARTBEAT_INTERVAL_KEY

See Also:

• Constant Field Values

HEARTBEAT_TOLERANCE_KEY

public static final String HEARTBEAT_TOLERANCE_KEY

See Also:

• Constant Field Values

CONNECT_TIMEOUT_KEY

public static final String CONNECT_TIMEOUT_KEY

See Also:

• Constant Field Values

TRIGGER_SENT_KEY

public static final String TRIGGER_SENT_KEY

See Also:

• Constant Field Values

DEFAULT_PORT

public static final String DEFAULT_PORT

See Also:

• Constant Field Values

DEFAULT_HB_INTERVAL

public static final String DEFAULT_HB_INTERVAL

See Also:

• Constant Field Values

DEFAULT_HB_TOLERANCE

public static final String DEFAULT_HB_TOLERANCE

See Also:

• Constant Field Values

DEFAULT_CONNECT_TIMEOUT

public static final String DEFAULT_CONNECT_TIMEOUT

See Also:

• Constant Field Values

Constructor Details

SimpleServerChannel

public SimpleServerChannel(ISerializer<T> serializer,
 ChannelListener<T> list,
 Properties properties)
                    throws UnknownHostException

Throws:

UnknownHostException

Method Details

onServerSocketBind

public void onServerSocketBind(boolean success,
 Throwable cause)

onServerSocketClose

public void onServerSocketClose(boolean success,
 Throwable cause)

onDeliverMessage

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

validateAttributes

public boolean validateAttributes(Attributes attr)

Specified by:

validateAttributes in interface AttributeValidator