org.gradle.messaging.remote.internal

Class DefaultObjectConnection

java.lang.Object

org.gradle.messaging.remote.internal.DefaultObjectConnection

All Implemented Interfaces:

Stoppable, AsyncStoppable, Addressable, ObjectConnection

public class DefaultObjectConnection
extends Object
implements ObjectConnection

Constructor Summary

Constructors

Constructor and Description
DefaultObjectConnection(Addressable addressable, AsyncStoppable stopControl, OutgoingMethodInvocationHandler outgoing, IncomingMethodInvocationHandler incoming)

Method Summary

Methods

Modifier and Type	Method and Description
void	addIncoming(Class<?> type, Dispatch<? super MethodInvocation> dispatch) Registers a handler for incoming messages on the given type.
<T> void	addIncoming(Class<T> type, T instance) Registers a handler for incoming messages on the given type.
<T> T	addOutgoing(Class<T> type) Creates a transmitter for outgoing messages on the given type.
Address	getLocalAddress()
Address	getRemoteAddress()
void	requestStop() Commences a graceful stop of this connection.
void	stop() Performs a graceful stop of this connection.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultObjectConnection

public DefaultObjectConnection(Addressable addressable,
                       AsyncStoppable stopControl,
                       OutgoingMethodInvocationHandler outgoing,
                       IncomingMethodInvocationHandler incoming)

Method Detail

getRemoteAddress

public Address getRemoteAddress()

Specified by:

getRemoteAddress in interface Addressable

getLocalAddress

public Address getLocalAddress()

Specified by:

getLocalAddress in interface Addressable

addIncoming

public <T> void addIncoming(Class<T> type,
                   T instance)

Description copied from interface: ObjectConnection

Registers a handler for incoming messages on the given type. The provided handler is not required to be thread-safe. Messages are delivered to the handler by a single thread.

Specified by:

addIncoming in interface ObjectConnection

Parameters:

type - The type.

instance - The handler instance. Incoming messages on the given type are delivered to this handler.

addIncoming

public void addIncoming(Class<?> type,
               Dispatch<? super MethodInvocation> dispatch)

Description copied from interface: ObjectConnection

Registers a handler for incoming messages on the given type. The provided handler is not required to be thread-safe. Messages are delivered to the handler by a single thread.

Specified by:

addIncoming in interface ObjectConnection

Parameters:

type - The type.

dispatch - The handler instance. Incoming messages on the given type are delivered to this handler.

addOutgoing

public <T> T addOutgoing(Class<T> type)

Description copied from interface: ObjectConnection

Creates a transmitter for outgoing messages on the given type. The returned object is thread-safe.

Specified by:

addOutgoing in interface ObjectConnection

Parameters:

type - The type

Returns:

A sink. Method calls made on this object are sent as outgoing messages.

requestStop

public void requestStop()

Description copied from interface: ObjectConnection

Commences a graceful stop of this connection. Stops accepting outgoing messages. Requests that the peer stop sending incoming messages.

Specified by:

requestStop in interface AsyncStoppable

Specified by:

requestStop in interface ObjectConnection

stop

public void stop()

Description copied from interface: ObjectConnection

Performs a graceful stop of this connection. Stops accepting outgoing message. Blocks until all incoming messages have been handled, and all outgoing messages have been handled by the peer.

Specified by:

stop in interface Stoppable

Specified by:

stop in interface ObjectConnection