org.apache.reef.io.network.impl

Class MessagingTransportFactory

java.lang.Object

org.apache.reef.io.network.impl.MessagingTransportFactory

All Implemented Interfaces:

TransportFactory

public class MessagingTransportFactory
extends Object
implements TransportFactory

Factory that creates a messaging transport

Constructor Summary

Constructors

Constructor and Description
MessagingTransportFactory()

Method Summary

Methods

Modifier and Type	Method and Description
Transport	create(int port, EventHandler<TransportEvent> clientHandler, EventHandler<TransportEvent> serverHandler, EventHandler<Exception> exHandler) Creates a transport

Methods inherited from class java.lang.Object

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

Constructor Detail

MessagingTransportFactory

@Inject
public MessagingTransportFactory()

Method Detail

create

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

Creates a transport

Specified by:

create 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: