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

Class MessagingTransportFactory

java.lang.Object

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

All Implemented Interfaces:

TransportFactory

public final class MessagingTransportFactory
extends Object
implements TransportFactory

Factory that creates a messaging 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.

Methods inherited from class java.lang.Object

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

Method Detail

newInstance

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

Creates a transport.

Specified by:

newInstance in interface TransportFactory

Parameters:

port - a listening port

clientHandler - a transport client side handler

serverHandler - a transport server side handler

exHandler - a exception handler

Returns:

transport

newInstance

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

Creates a transport.

Specified by:

newInstance in interface TransportFactory

Parameters:

hostAddress - a host address

port - a listening port

clientStage - a client stage

serverStage - a server stage

numberOfTries - a number of tries

retryTimeout - a timeout for retry

Returns:

transport

newInstance

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

Creates a transport.

Specified by:

newInstance in interface TransportFactory

Parameters:

hostAddress - a host address

port - a listening port

clientStage - a client stage

serverStage - a server stage

numberOfTries - a number of tries

retryTimeout - a timeout for retry

tcpPortProvider - a provider for TCP port

Returns:

transport