org.gradle.messaging.remote.internal

Interface MultiChannelConnection<T>

All Superinterfaces:

Addressable, AsyncStoppable, Stoppable

public interface MultiChannelConnection<T>
extends Addressable, AsyncStoppable

Method Summary

Methods

Modifier and Type	Method and Description
void	addIncomingChannel(String channelKey, Dispatch<T> dispatch) Adds a handler for incoming messages on the given channel.
Dispatch<T>	addOutgoingChannel(String channelKey) Adds a destination for outgoing messages on the given channel.
void	requestStop() Commences graceful stop of this connection.
void	stop() Performs a graceful stop of this connection.

Methods inherited from interface org.gradle.messaging.remote.Addressable

getLocalAddress, getRemoteAddress

Method Detail

addOutgoingChannel

Dispatch<T> addOutgoingChannel(String channelKey)

Adds a destination for outgoing messages on the given channel. The returned value is thread-safe.

addIncomingChannel

void addIncomingChannel(String channelKey,
                      Dispatch<T> dispatch)

Adds a handler for incoming messages on the given channel. The given dispatch is only ever used by a single thread at any given time.

requestStop

void requestStop()

Commences graceful stop of this connection. Stops accepting any more outgoing messages, and requests that the peer stop sending incoming messages.

Specified by:

requestStop in interface AsyncStoppable

stop

void stop()

Performs a graceful stop of this connection. Blocks until all dispatched incoming messages have been handled, and all outgoing messages have been delivered.

Specified by:

stop in interface Stoppable