Package org.drasyl.peer.connection.pipeline

Class SuperPeerMessageSinkHandler

java.lang.Object

org.drasyl.pipeline.HandlerAdapter

org.drasyl.pipeline.AddressHandlerAdapter<A>

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

org.drasyl.peer.connection.pipeline.SuperPeerMessageSinkHandler

All Implemented Interfaces:

Handler

public class SuperPeerMessageSinkHandler
extends SimpleOutboundHandler<Message,CompressedPublicKey>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SUPER_PEER_SINK_HANDLER

Constructor Summary

Constructors

Constructor	Description
SuperPeerMessageSinkHandler(PeerChannelGroup channelGroup, PeersManager peersManager)

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

SUPER_PEER_SINK_HANDLER

public static final String SUPER_PEER_SINK_HANDLER

See Also:

• Constant Field Values

Constructor Details

SuperPeerMessageSinkHandler

public SuperPeerMessageSinkHandler(PeerChannelGroup channelGroup,
 PeersManager peersManager)

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