Package org.drasyl.peer.connection.pipeline

Class LoopbackMessageSinkHandler

java.lang.Object

org.drasyl.pipeline.HandlerAdapter

org.drasyl.pipeline.AddressHandlerAdapter<A>

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

org.drasyl.peer.connection.pipeline.LoopbackMessageSinkHandler

All Implemented Interfaces:

Handler

public class LoopbackMessageSinkHandler
extends SimpleOutboundHandler<Message,CompressedPublicKey>

This handler delivers outgoing messages addressed to the local node.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	LOOPBACK_MESSAGE_SINK_HANDLER

Constructor Summary

Constructors

Constructor	Description
LoopbackMessageSinkHandler(AtomicBoolean started, int networkId, Identity identity, PeersManager peersManager, Set<Endpoint> endpoints)

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

LOOPBACK_MESSAGE_SINK_HANDLER

public static final String LOOPBACK_MESSAGE_SINK_HANDLER

See Also:

• Constant Field Values

Constructor Details

LoopbackMessageSinkHandler

public LoopbackMessageSinkHandler(AtomicBoolean started,
 int networkId,
 Identity identity,
 PeersManager peersManager,
 Set<Endpoint> endpoints)

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