Package org.drasyl.peer.connection.pipeline

Class DirectConnectionMessageSinkHandler

java.lang.Object

org.drasyl.pipeline.HandlerAdapter

org.drasyl.pipeline.AddressHandlerAdapter<A>

org.drasyl.pipeline.SimpleOutboundHandler<Message,CompressedPublicKey>

org.drasyl.peer.connection.pipeline.DirectConnectionMessageSinkHandler

All Implemented Interfaces:

Handler

public class DirectConnectionMessageSinkHandler
extends SimpleOutboundHandler<Message,CompressedPublicKey>

This handler tries to send outgoing messages via TCP-based direct connection to another peers.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DIRECT_CONNECTION_MESSAGE_SINK_HANDLER

Constructor Summary

Constructors

Constructor	Description
DirectConnectionMessageSinkHandler(PeerChannelGroup channelGroup)

Method Summary

Modifier and Type	Method	Description
protected void	matchedWrite(HandlerContext ctx, CompressedPublicKey recipient, Message msg, CompletableFuture<Void> future)	Is called for each message of type SimpleOutboundHandler.

Methods inherited from class org.drasyl.pipeline.SimpleOutboundHandler

acceptOutbound, write

Methods inherited from class org.drasyl.pipeline.AddressHandlerAdapter

acceptAddress

Methods inherited from class org.drasyl.pipeline.HandlerAdapter

eventTriggered, exceptionCaught, handlerAdded, handlerRemoved, read

Methods inherited from class java.lang.Object

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

Field Details

DIRECT_CONNECTION_MESSAGE_SINK_HANDLER

public static final String DIRECT_CONNECTION_MESSAGE_SINK_HANDLER

See Also:

• Constant Field Values

Constructor Details

DirectConnectionMessageSinkHandler

public DirectConnectionMessageSinkHandler(PeerChannelGroup channelGroup)

Method Details

matchedWrite

protected void matchedWrite(HandlerContext ctx,
 CompressedPublicKey recipient,
 Message msg,
 CompletableFuture<Void> future)

Description copied from class: SimpleOutboundHandler

Is called for each message of type SimpleOutboundHandler.

Specified by:

matchedWrite in class SimpleOutboundHandler<Message,CompressedPublicKey>

Parameters:

ctx - handler context

recipient - the recipient of the message

msg - the message

future - a future for the message