org.apache.reef.wake.remote.transport.netty

Class NettyLink<T>

java.lang.Object

org.apache.reef.wake.remote.transport.netty.NettyLink<T>

All Implemented Interfaces:

Link<T>

public class NettyLink<T>
extends Object
implements Link<T>

Link implementation with Netty. If you set a LinkListener<T>, it keeps message until writeAndFlush operation completes and notifies whether the sent message transferred successfully through the listener.

Field Summary

Fields

Modifier and Type	Field and Description
static int	INT_SIZE

Constructor Summary

Constructors

Constructor and Description
NettyLink(io.netty.channel.Channel channel, Encoder<? super T> encoder) Constructs a link.
NettyLink(io.netty.channel.Channel channel, Encoder<? super T> encoder, LinkListener<? super T> listener) Constructs a link.

Method Summary

Methods

Modifier and Type	Method and Description
SocketAddress	getLocalAddress() Gets a local address of the link.
SocketAddress	getRemoteAddress() Gets a remote address of the link.
String	toString()
void	write(T message) Writes the message to this link.

Methods inherited from class java.lang.Object

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

Field Detail

INT_SIZE

public static final int INT_SIZE

See Also:

Constant Field Values

Constructor Detail

NettyLink

public NettyLink(io.netty.channel.Channel channel,
         Encoder<? super T> encoder)

Constructs a link.

Parameters:

channel - the channel

encoder - the encoder

NettyLink

public NettyLink(io.netty.channel.Channel channel,
         Encoder<? super T> encoder,
         LinkListener<? super T> listener)

Constructs a link.

Parameters:

channel - the channel

encoder - the encoder

listener - the link listener

Method Detail

write

public void write(T message)

Writes the message to this link.

Specified by:

write in interface Link<T>

Parameters:

message - the message

getLocalAddress

public SocketAddress getLocalAddress()

Gets a local address of the link.

Specified by:

getLocalAddress in interface Link<T>

Returns:

a local socket address

getRemoteAddress

public SocketAddress getRemoteAddress()

Gets a remote address of the link.

Specified by:

getRemoteAddress in interface Link<T>

Returns:

a remote socket address

toString

public String toString()

Overrides:

toString in class Object