public class MessageAsync<M extends Message> extends SingleSender<M> implements MessageReceiver<M>
SingleSenderwhich lets the drain's receive method run asynchronouously in a separate thread.
MessageReceiver.receive(Message)method of the current drain is executed in a loop in an own, specially constructed
Thread, consuming all these messages asynchronouously.
receive(Message)thus returns immediately, after writing the message into a buffer object. (This is currently a
|Constructor and Description|
|Modifier and Type||Method and Description|
Returns immediately after storing the message to the internal buffer.
public void receive(M m)
see also the complete user documentation .