org.gradle.messaging.dispatch

Class QueuingDispatch<T>

java.lang.Object

org.gradle.messaging.dispatch.QueuingDispatch<T>

All Implemented Interfaces:

Stoppable, Dispatch<T>

public class QueuingDispatch<T>
extends Object
implements Dispatch<T>, Stoppable

Queues messages until a receiver has been connected. This class is thread-safe.

Constructor Summary

Constructors

Constructor and Description
QueuingDispatch()

Method Summary

Methods

Modifier and Type	Method and Description
void	dispatch(T message) Dispatches the next message.
void	dispatchTo(Dispatch<? super T> dispatch) Dispatches to the given handler.
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

QueuingDispatch

public QueuingDispatch()

Method Detail

dispatchTo

public void dispatchTo(Dispatch<? super T> dispatch)

Dispatches to the given handler. The handler does not have to be thread-safe.

dispatch

public void dispatch(T message)

Description copied from interface: Dispatch

Dispatches the next message. Blocks until the messages has been accepted but generally does not wait for the message to be processed. Delivery guarantees are implementation specific.

Specified by:

dispatch in interface Dispatch<T>

Parameters:

message - The message.

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