ome.smuggler.core.msg

Interface MessageSink<M,D>

All Superinterfaces:

ChannelSink<ChannelMessage<M,D>>

All Known Implementing Classes:

CountedScheduleSink, ReschedulingSink

public interface MessageSink<M,D>
extends ChannelSink<ChannelMessage<M,D>>

Encapsulates the consumption of an asynchronous message received from a channel. Messages have data to consume and possibly associated metadata.

See Also:

ChannelMessage, MessageSource

Method Summary

Modifier and Type	Method and Description
default ChannelSink<D>	asDataSink() Builds a channel sink that uses this message sink to consume data items D.
static <M,D> MessageSink<M,D>	forwardDataTo(ChannelSink<D> target) Builds a message sink that forwards message data to the given consumer, while discarding any message metadata.

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

consume

Method Detail

forwardDataTo

static <M,D> MessageSink<M,D> forwardDataTo(ChannelSink<D> target)

Builds a message sink that forwards message data to the given consumer, while discarding any message metadata.

Type Parameters:

M - the metadata type.

D - the data type.

Parameters:

target - consumes message data.

Returns:

a message sink adapter.

Throws:

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

asDataSink

default ChannelSink<D> asDataSink()

Builds a channel sink that uses this message sink to consume data items D. The messages forwarded to the underlying consumer will all have empty metadata as any received metadata is discarded.

Returns:

a channel sink adapter.