ome.smuggler.core.msg

Interface MessageSource<M,D>

All Superinterfaces:

ChannelSource<ChannelMessage<M,D>>

All Known Subinterfaces:

SchedulingSource<T>

All Known Implementing Classes:

CountedScheduleTask, EnqueueTask, ScheduleTask, SourceQueue

public interface MessageSource<M,D>
extends ChannelSource<ChannelMessage<M,D>>

Encapsulates the sending of an asynchronous message along a channel that supports metadata. This channel source imposes a minimal structure to the data being sent over the channel, namely that of a message containing data meant to be consumed by the receiving end and optionally metadata, typically used to configure the sending of the message.

See Also:

ChannelMessage, MessageSink

Method Summary

Modifier and Type	Method and Description
default ChannelSource<D>	asDataSource() Builds a channel source that uses this message source to send data items D.

Methods inherited from interface ome.smuggler.core.msg.ChannelSource

send, uncheckedSend

Method Detail

asDataSource

default ChannelSource<D> asDataSource()

Builds a channel source that uses this message source to send data items D. The underlying messages will all have empty metadata.

Returns:

a channel source adapter.