org.gradle.messaging.remote.internal.inet

Class TcpIncomingConnector<T>

java.lang.Object

org.gradle.messaging.remote.internal.inet.TcpIncomingConnector<T>

All Implemented Interfaces:

Stoppable, AsyncStoppable, IncomingConnector<T>

public class TcpIncomingConnector<T>
extends Object
implements IncomingConnector<T>, AsyncStoppable

Constructor Summary

Constructors

Constructor and Description
TcpIncomingConnector(ExecutorFactory executorFactory, MessageSerializer<T> serializer, InetAddressFactory addressFactory, IdGenerator<?> idGenerator)

Method Summary

Methods

Modifier and Type	Method and Description
Address	accept(Action<ConnectEvent<Connection<T>>> action, boolean allowRemote) Allocates a new incoming endpoint.
void	requestStop() Requests that this stoppable commence a graceful stop.
void	stop() Requests a graceful stop of this object.

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpIncomingConnector

public TcpIncomingConnector(ExecutorFactory executorFactory,
                    MessageSerializer<T> serializer,
                    InetAddressFactory addressFactory,
                    IdGenerator<?> idGenerator)

Method Detail

accept

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

Description copied from interface: IncomingConnector

Allocates a new incoming endpoint.

Specified by:

accept in interface IncomingConnector<T>

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.

requestStop

public void requestStop()

Description copied from interface: AsyncStoppable

Requests that this stoppable commence a graceful stop. Does not block. You should call Stoppable.stop() to wait for the stop process to complete.

Generally, an AsyncStoppable should continue to complete existing work after this method has returned. It should, however, stop accepting new work.

Requesting stopping does not guarantee the stoppable actually stops. Requesting stopping means preparing for stopping; stopping accepting new work. You have to call stop at some point anyway if your intention is to completely stop the stoppable.

Specified by:

requestStop in interface AsyncStoppable

stop

public void stop()

Description copied from interface: Stoppable

Requests a graceful stop of this object. Blocks until all concurrent activity has been completed.

If this object has already been stopped, this method does nothing.

Specified by:

stop in interface Stoppable