org.apache.reef.wake.remote.transport

Interface TransportFactory

All Known Implementing Classes:

MessagingTransportFactory

@DefaultImplementation(value=MessagingTransportFactory.class)
public interface TransportFactory

Factory that creates a transport.

Method Summary

Methods

Modifier and Type	Method and Description
Transport	newInstance(int port, EventHandler<TransportEvent> clientHandler, EventHandler<TransportEvent> serverHandler, EventHandler<Exception> exHandler) Creates a transport.
Transport	newInstance(String hostAddress, int port, EStage<TransportEvent> clientStage, EStage<TransportEvent> serverStage, int numberOfTries, int retryTimeout) Creates a transport.
Transport	newInstance(String hostAddress, int port, EStage<TransportEvent> clientStage, EStage<TransportEvent> serverStage, int numberOfTries, int retryTimeout, TcpPortProvider tcpPortProvider) Creates a transport.

Method Detail

newInstance

Transport newInstance(int port,
                    EventHandler<TransportEvent> clientHandler,
                    EventHandler<TransportEvent> serverHandler,
                    EventHandler<Exception> exHandler)

Creates a transport.

Parameters:

port - a listening port

clientHandler - a transport client-side handler

serverHandler - a transport server-side handler

exHandler - an exception handler

Returns:

transport

newInstance

Transport newInstance(String hostAddress,
                    int port,
                    EStage<TransportEvent> clientStage,
                    EStage<TransportEvent> serverStage,
                    int numberOfTries,
                    int retryTimeout)

Creates a transport.

Parameters:

hostAddress - a host address

port - a listening port

clientStage - a transport client-side stage

serverStage - a transport server-side stage

numberOfTries - the number of retries for connection

retryTimeout - retry timeout

Returns:

transport

newInstance

Transport newInstance(String hostAddress,
                    int port,
                    EStage<TransportEvent> clientStage,
                    EStage<TransportEvent> serverStage,
                    int numberOfTries,
                    int retryTimeout,
                    TcpPortProvider tcpPortProvider)

Creates a transport.

Parameters:

hostAddress - a host address

port - a listening port

clientStage - a transport client-side stage

serverStage - a transport server-side stage

numberOfTries - the number of retries for connection

retryTimeout - retry timeout

tcpPortProvider - tcpPortProvider

Returns:

transport