public class HandshakeIncomingConnector extends Object implements IncomingConnector<Message>
| Constructor and Description |
|---|
HandshakeIncomingConnector(IncomingConnector<Message> connector,
Executor executor) |
| Modifier and Type | Method and Description |
|---|---|
Address |
accept(Action<ConnectEvent<Connection<Message>>> action,
boolean allowRemote)
Allocates a new incoming endpoint.
|
public HandshakeIncomingConnector(IncomingConnector<Message> connector, Executor executor)
public Address accept(Action<ConnectEvent<Connection<Message>>> action, boolean allowRemote)
IncomingConnectoraccept in interface IncomingConnector<Message>action - the action to execute on incoming connection. The supplied action is not required to be thread-safe.allowRemote - If true, only allow connections from remote machines. If false, allow only from the local machine.Copyright © 2013. All rights reserved