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

Class SimpleClientChannel<T>

java.lang.Object

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

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

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

All Implemented Interfaces:

IChannel<T>, MessageListener<T>, OutConnListener<T>

public class SimpleClientChannel<T>
extends SingleThreadedClientChannel<T,T>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	SimpleClientChannel.State

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 short	SIMPLE_CLIENT_MAGIC_NUMBER
static final String	WORKER_GROUP_KEY

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	onDeliverMessage(T msg, Connection<T> conn)

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

outboundConnectionDown, outboundConnectionFailed, outboundConnectionUp

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

SIMPLE_CLIENT_MAGIC_NUMBER

public static final short SIMPLE_CLIENT_MAGIC_NUMBER

See Also:

• Constant Field Values

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

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

SimpleClientChannel

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

Throws:

UnknownHostException

Method Details

onDeliverMessage

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