org.gradle.messaging.remote.internal

Class HandshakeIncomingConnector

java.lang.Object

org.gradle.messaging.remote.internal.HandshakeIncomingConnector

All Implemented Interfaces:

IncomingConnector<Message>

public class HandshakeIncomingConnector
extends Object
implements IncomingConnector<Message>

Constructor Summary

Constructors

Constructor and Description
HandshakeIncomingConnector(IncomingConnector<Message> connector, Executor executor)

Method Summary

Methods

Modifier and Type	Method and Description
Address	accept(Action<ConnectEvent<Connection<Message>>> action, boolean allowRemote) Allocates a new incoming endpoint.

Methods inherited from class java.lang.Object

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

Constructor Detail

HandshakeIncomingConnector

public HandshakeIncomingConnector(IncomingConnector<Message> connector,
                          Executor executor)

Method Detail

accept

public Address accept(Action<ConnectEvent<Connection<Message>>> action,
             boolean allowRemote)

Description copied from interface: IncomingConnector

Allocates a new incoming endpoint.

Specified by:

accept in interface IncomingConnector<Message>

Parameters:

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.

Returns:

the address of the endpoint which the connector is listening on.