org.apache.reef.wake.remote.transport

Interface Transport

All Superinterfaces:

AutoCloseable, Stage

All Known Implementing Classes:

NettyMessagingTransport

public interface Transport
extends Stage

Transport for sending and receiving data.

Method Summary

Methods

Modifier and Type	Method and Description
<T> Link<T>	get(SocketAddress remoteAddr) Returns a link for the remote address if already cached; otherwise, returns null.
int	getListeningPort() Gets a server listening port of this transport.
SocketAddress	getLocalAddress() Gets a server local socket address of this transport.
<T> Link<T>	open(SocketAddress remoteAddr, Encoder<? super T> encoder, LinkListener<? super T> listener) Returns a link for the remote address if cached; otherwise opens, caches and returns.
void	registerErrorHandler(EventHandler<Exception> handler) Registers the exception handler.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

open

<T> Link<T> open(SocketAddress remoteAddr,
               Encoder<? super T> encoder,
               LinkListener<? super T> listener)
             throws IOException

Returns a link for the remote address if cached; otherwise opens, caches and returns. When it opens a link for the remote address, only one attempt for the address is made at a given time

Parameters:

remoteAddr - the remote socket address

encoder - the encoder

listener - the link listener

Returns:

a link associated with the address

Throws:

IOException

get

<T> Link<T> get(SocketAddress remoteAddr)

Returns a link for the remote address if already cached; otherwise, returns null.

Parameters:

remoteAddr - the remote address

Returns:

a link if already cached; otherwise, null

getListeningPort

int getListeningPort()

Gets a server listening port of this transport.

Returns:

a listening port number

getLocalAddress

SocketAddress getLocalAddress()

Gets a server local socket address of this transport.

Returns:

a server local socket address

registerErrorHandler

void registerErrorHandler(EventHandler<Exception> handler)

Registers the exception handler.

Parameters:

handler - the exception handler