Package org.drasyl.pipeline

Class SimpleDuplexHandler<I,E,O,A extends Address>

java.lang.Object

org.drasyl.pipeline.HandlerAdapter

org.drasyl.pipeline.AddressHandlerAdapter<A>

org.drasyl.pipeline.SimpleInboundHandler<I,E,A>

org.drasyl.pipeline.SimpleDuplexHandler<I,E,O,A>

All Implemented Interfaces:

Handler

Direct Known Subclasses:

Codec

public abstract class SimpleDuplexHandler<I,E,O,A extends Address>
extends SimpleInboundHandler<I,E,A>

HandlerAdapter which allows to explicit only handle a specific type of messages and events.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SimpleDuplexHandler()
protected	SimpleDuplexHandler(Class<? extends I> inboundMessageType, Class<? extends E> inboundEventType, Class<? extends O> outboundMessageType, Class<? extends A> addressType)

Method Summary

Modifier and Type	Method	Description
protected boolean	acceptOutbound(Object msg)	Returns true if the given message should be handled.
protected abstract void	matchedWrite(HandlerContext ctx, A recipient, O msg, CompletableFuture<Void> future)	Is called for each message of type SimpleDuplexHandler.
void	write(HandlerContext ctx, Address recipient, Object msg, CompletableFuture<Void> future)	Gets called if a Object was send from the application to a recipient.

Methods inherited from class org.drasyl.pipeline.SimpleInboundHandler

acceptEvent, acceptInbound, eventTriggered, matchedEventTriggered, matchedRead, read

Methods inherited from class org.drasyl.pipeline.AddressHandlerAdapter

acceptAddress

Methods inherited from class org.drasyl.pipeline.HandlerAdapter

exceptionCaught, handlerAdded, handlerRemoved

Methods inherited from class java.lang.Object

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

Constructor Details

SimpleDuplexHandler

protected SimpleDuplexHandler()

SimpleDuplexHandler

protected SimpleDuplexHandler(Class<? extends I> inboundMessageType,
 Class<? extends E> inboundEventType,
 Class<? extends O> outboundMessageType,
 Class<? extends A> addressType)

Method Details

write

public void write(HandlerContext ctx,
 Address recipient,
 Object msg,
 CompletableFuture<Void> future)

Description copied from interface: Handler

Gets called if a Object was send from the application to a recipient.

Specified by:

write in interface Handler

Overrides:

write in class HandlerAdapter

Parameters:

ctx - handler context

recipient - the recipient of the message

msg - the message

future - a future for the message

acceptOutbound

protected boolean acceptOutbound(Object msg)

Returns true if the given message should be handled. If false it will be passed to the next Handler in the Pipeline.

matchedWrite

protected abstract void matchedWrite(HandlerContext ctx,
 A recipient,
 O msg,
 CompletableFuture<Void> future)

Is called for each message of type SimpleDuplexHandler.

Parameters:

ctx - handler context

recipient - the recipient of the message

msg - the message

future - a future for the message