Package org.drasyl.pipeline

Class SimpleInboundHandler<I,E,A extends Address>

java.lang.Object

org.drasyl.pipeline.HandlerAdapter

org.drasyl.pipeline.AddressHandlerAdapter<A>

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

All Implemented Interfaces:

Handler

Direct Known Subclasses:

ApplicationMessage2ObjectHolderHandler, GroupsClientHandler, GroupsManagerHandler, SimpleDuplexHandler

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

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

For example here is an implementation which only handle MessageEvent events.

     public class MessageEventHandler extends
             SimpleInboundHandler<ApplicationMessage, MessageEvent,
             CompressedPublicKey> {

        @Override
         protected void matchedEventTriggered(HandlerContext ctx,
             MessageEvent event) {
             System.out.println(event);
         }

        @Override
         protected void matchedRead(HandlerContext ctx,
             CompressedPublicKey sender, ApplicationMessage msg,
             CompletableFuture<Void> future) {
             System.out.println(msg);
         }
     }
 

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SimpleInboundHandler()	Create a new instance which will try to detect the types to match out of the type parameter of the class.
protected	SimpleInboundHandler(Class<? extends I> inboundMessageType, Class<? extends E> inboundEventType, Class<? extends A> addressType)	Create a new instance

Method Summary

Modifier and Type	Method	Description
protected boolean	acceptEvent(Event msg)	Returns true if the given event should be handled.
protected boolean	acceptInbound(Object msg)	Returns true if the given message should be handled.
void	eventTriggered(HandlerContext ctx, Event event, CompletableFuture<Void> future)	Gets called if a Event was emitted.
protected abstract void	matchedEventTriggered(HandlerContext ctx, E event, CompletableFuture<Void> future)	Is called for each event of type SimpleInboundHandler.
protected abstract void	matchedRead(HandlerContext ctx, A sender, I msg, CompletableFuture<Void> future)	Is called for each message of type SimpleInboundHandler.
void	read(HandlerContext ctx, Address sender, Object msg, CompletableFuture<Void> future)	Gets called if a Object was received.

Methods inherited from class org.drasyl.pipeline.AddressHandlerAdapter

acceptAddress

Methods inherited from class org.drasyl.pipeline.HandlerAdapter

exceptionCaught, handlerAdded, handlerRemoved, write

Methods inherited from class java.lang.Object

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

Constructor Details

SimpleInboundHandler

protected SimpleInboundHandler()

Create a new instance which will try to detect the types to match out of the type parameter of the class.

SimpleInboundHandler

protected SimpleInboundHandler(Class<? extends I> inboundMessageType,
 Class<? extends E> inboundEventType,
 Class<? extends A> addressType)

Create a new instance

Parameters:

inboundMessageType - the type of messages to match

inboundEventType - the type of events to match

addressType - the type of the address to match

Method Details

read

public void read(HandlerContext ctx,
 Address sender,
 Object msg,
 CompletableFuture<Void> future)

Description copied from interface: Handler

Gets called if a Object was received.

Specified by:

read in interface Handler

Overrides:

read in class HandlerAdapter

Parameters:

ctx - handler context

sender - the sender of the message

msg - the message

future - a future for the message

eventTriggered

public void eventTriggered(HandlerContext ctx,
 Event event,
 CompletableFuture<Void> future)

Description copied from interface: Handler

Gets called if a Event was emitted.

Specified by:

eventTriggered in interface Handler

Overrides:

eventTriggered in class HandlerAdapter

Parameters:

ctx - handler context

event - the event

future - a future for the message

acceptEvent

protected boolean acceptEvent(Event msg)

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

matchedEventTriggered

protected abstract void matchedEventTriggered(HandlerContext ctx,
 E event,
 CompletableFuture<Void> future)

Is called for each event of type SimpleInboundHandler.

Parameters:

ctx - handler context

event - the event

future - the future of the message

acceptInbound

protected boolean acceptInbound(Object msg)

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

matchedRead

protected abstract void matchedRead(HandlerContext ctx,
 A sender,
 I msg,
 CompletableFuture<Void> future)

Is called for each message of type SimpleInboundHandler.

Parameters:

ctx - handler context

sender - the sender of the message

msg - the message

future - the future of the message