| Package | Description |
|---|---|
| org.apache.reef.io.network |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
| org.apache.reef.io.network.impl |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
| org.apache.reef.wake.remote.impl | |
| org.apache.reef.wake.remote.transport.netty |
| Modifier and Type | Method and Description |
|---|---|
Transport |
TransportFactory.create(int port,
EventHandler<TransportEvent> clientHandler,
EventHandler<TransportEvent> serverHandler,
EventHandler<Exception> exHandler)
Creates a transport
|
Transport |
TransportFactory.create(int port,
EventHandler<TransportEvent> clientHandler,
EventHandler<TransportEvent> serverHandler,
EventHandler<Exception> exHandler)
Creates a transport
|
| Modifier and Type | Method and Description |
|---|---|
Transport |
MessagingTransportFactory.create(int port,
EventHandler<TransportEvent> clientHandler,
EventHandler<TransportEvent> serverHandler,
EventHandler<Exception> exHandler)
Creates a transport
|
Transport |
MessagingTransportFactory.create(int port,
EventHandler<TransportEvent> clientHandler,
EventHandler<TransportEvent> serverHandler,
EventHandler<Exception> exHandler)
Creates a transport
|
| Modifier and Type | Method and Description |
|---|---|
void |
RemoteReceiverStage.onNext(TransportEvent value)
Handles the received event
|
void |
OrderedRemoteReceiverStage.onNext(TransportEvent value) |
| Constructor and Description |
|---|
NettyMessagingTransport(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout)
Constructs a messaging transport
|
NettyMessagingTransport(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout)
Constructs a messaging transport
|
Copyright © 2015 The Apache Software Foundation. All rights reserved.