org.gradle.messaging.remote.internal

Class DefaultMessagingServer

java.lang.Object

org.gradle.messaging.remote.internal.DefaultMessagingServer

All Implemented Interfaces:

Stoppable, MessagingServer

public class DefaultMessagingServer
extends java.lang.Object
implements MessagingServer, Stoppable

Constructor Summary

Constructors

Constructor and Description
DefaultMessagingServer(MultiChannelConnector connector, java.lang.ClassLoader classLoader)

Method Summary

Methods

Modifier and Type	Method and Description
Address	accept(Action<ConnectEvent<ObjectConnection>> action) Creates an endpoint which a single peer can connect to.
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

DefaultMessagingServer

public DefaultMessagingServer(MultiChannelConnector connector,
                      java.lang.ClassLoader classLoader)

Method Detail

accept

public Address accept(Action<ConnectEvent<ObjectConnection>> action)

Description copied from interface: MessagingServer

Creates an endpoint which a single peer can connect to.

Specified by:

accept in interface MessagingServer

Parameters:

action - The action to execute when the connection has been established.

Returns:

The local address of the endpoint, for the peer to connect to.

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