ome.smuggler.core.msg

Interface ChannelSource<T>

All Known Subinterfaces:

MessageSource<M,D>, SchedulingSource<T>

All Known Implementing Classes:

CountedScheduleTask, EnqueueTask, ScheduleTask, SourceQueue

public interface ChannelSource<T>

Encapsulates the sending of an asynchronous message along a channel.

Method Summary

Modifier and Type	Method and Description
void	send(T data) Inputs data into the channel and returns immediately.
default void	uncheckedSend(T data) Same as send but masks any exception as a runtime (unchecked) exception and throws it as such without any wrapping.

Method Detail

send

void send(T data)
   throws java.lang.Exception

Inputs data into the channel and returns immediately. This is an asynchronous operation, so that the sender never waits for the receiver to get the data.

Parameters:

data - the message to send.

Throws:

java.lang.NullPointerException - if the input is null.

java.lang.Exception - if the data could not be input into the channel.

uncheckedSend

default void uncheckedSend(T data)

Same as send but masks any exception as a runtime (unchecked) exception and throws it as such without any wrapping.

Parameters:

data - the message to send.