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

Class AckosChannel<T>

java.lang.Object

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

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

pt.unl.fct.di.novasys.channel.ackos.AckosChannel<T>

All Implemented Interfaces:

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

public class AckosChannel<T>
extends SingleThreadedBiChannel<T,AckosMessage<T>>
implements AttributeValidator

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_PORT

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

ALWAYS_VALID, CHANNEL_MAGIC_ATTRIBUTE

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	onDeliverMessage(AckosMessage<T> msg, Connection<AckosMessage<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.SingleThreadedBiChannel

inboundConnectionDown, inboundConnectionUp, outboundConnectionDown, outboundConnectionFailed, outboundConnectionUp, 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

DEFAULT_PORT

public static final int DEFAULT_PORT

See Also:

• Constant Field Values

Constructor Details

AckosChannel

public AckosChannel(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(AckosMessage<T> msg,
 Connection<AckosMessage<T>> conn)

validateAttributes

public boolean validateAttributes(Attributes attr)

Specified by:

validateAttributes in interface AttributeValidator