Module id.ICE

Package id.ICE.handlers

Class MessageSender

Object

MessageSender

All Implemented Interfaces:

CompletionHandler<Integer,AsynchronousSocketChannel>

public class MessageSender
extends Object
implements CompletionHandler<Integer,AsynchronousSocketChannel>

Async sends the message and notifies the caller thru the CompletableFuture. This handler is not thread safe and designed to serve only one send request at a time.

Constructor Summary

Constructors

Constructor	Description
MessageSender(AsynchronousSocketChannel channel)

Method Summary

Modifier and Type	Method	Description
void	completed(Integer result, AsynchronousSocketChannel channel)
void	failed(Throwable exc, AsynchronousSocketChannel channel)
CompletableFuture<Void>	send(ByteBuffer message, Consumer<Throwable> errorHandler)	Send data asynchronously and return the future which will be completed once all data is sent.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MessageSender

public MessageSender(AsynchronousSocketChannel channel)

Method Details

completed

public void completed(Integer result,
 AsynchronousSocketChannel channel)

Specified by:

completed in interface CompletionHandler<Integer,AsynchronousSocketChannel>

failed

public void failed(Throwable exc,
 AsynchronousSocketChannel channel)

Specified by:

failed in interface CompletionHandler<Integer,AsynchronousSocketChannel>

send

public CompletableFuture<Void> send(ByteBuffer message,
 Consumer<Throwable> errorHandler)

Send data asynchronously and return the future which will be completed once all data is sent.