Package ome.smuggler.core.msg

Interface Summary

Interface	Description
ChannelSink<T>	Encapsulates the consumption of an asynchronous message received from a channel.
ChannelSource<T>	Encapsulates the sending of an asynchronous message along a channel.
MessageSink<M,D>	Encapsulates the consumption of an asynchronous message received from a channel.
MessageSource<M,D>	Encapsulates the sending of an asynchronous message along a channel that supports metadata.
RepeatConsumer<T>	Plugs into a channel sink to consume its data and optionally request that the same data be delivered again.
Reschedulable<T>	A task that consumes a channel sink's output and optionally requests the channel to deliver again some more data at a later point in time.
SchedulingSource<T>	A channel source that allows the scheduling of messages to send.

Class Summary

Class	Description
ChannelMessage<M,D>	Imposes a minimal structure to a message exchanged on a channel.
CountedSchedule	Channel metadata to request the scheduling of a message and the sending of a counter to indicate how many times the message has been scheduled for delivery.
MessageRepeater<T>	Plugs into a ReschedulingSink to deliver the same message to sink's consumers multiple times at predefined intervals for a finite number of times.
OnceOffRepeatConsumer<T>	Makes message consumers returning RepeatActions work well when used for once-off schedules.
OnceOffSchedule<T>	Plugs into a ReschedulingSink to deliver messages to sink's consumers exactly once.
ReschedulableFactory	Builds Reschedulables.
ReschedulingSink<T>	A channel sink feeding the channel output to a task that may produce more input to be delivered on the channel at a later point in time.
SourceQueue<M,D>	A channel source that queues messages in memory and allows to retrieve the head of the queue to consume messages or do a bulk retrieval of all queued messages.

Enum Summary

Enum	Description
RepeatAction	Indicates whether a message should be re-delivered after being consumed.