ome.smuggler.core.msg

Interface ChannelSink<T>

All Known Subinterfaces:

MessageSink<M,D>

All Known Implementing Classes:

CountedScheduleSink, ReschedulingSink

public interface ChannelSink<T>

Encapsulates the consumption of an asynchronous message received from a channel.

Method Summary

Modifier and Type	Method and Description
void	consume(T data) Consumes a message.

Method Detail

consume

void consume(T data)

Consumes a message.

Parameters:

data - the message data output from the channel.

Throws:

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