Package org.drasyl.handler.logging

Class MessagesThroughputHandler

java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelInboundHandlerAdapter
io.netty.channel.ChannelDuplexHandler
org.drasyl.handler.logging.MessagesThroughputHandler
All Implemented Interfaces:
io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, io.netty.channel.ChannelOutboundHandler
public class MessagesThroughputHandler extends io.netty.channel.ChannelDuplexHandler
Helper class to visualize the number of inbound and outbound messages per second. Can be added to any position in a ChannelPipeline.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

    io.netty.channel.ChannelHandler.Sharable

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final Duration
    INTERVAL
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    MessagesThroughputHandler()
    Creates a new handler which visualizes the number of inbound and outbound messages per second.
    MessagesThroughputHandler(BiPredicate<SocketAddress,Object> consumeOutbound, BiPredicate<SocketAddress,Object> consumeInbound)
    Creates a new handler which visualizes the number of inbound and outbound messages per second, consumes outbound message matching consumeOutbound, and inbound messages matching consumeInbound.
    MessagesThroughputHandler(BiPredicate<SocketAddress,Object> consumeOutbound, BiPredicate<SocketAddress,Object> consumeInbound, io.netty.channel.EventLoopGroup eventLoopGroup)
    Creates a new handler which visualizes the number of inbound and outbound messages per second, consumes outbound message matching consumeOutbound, and inbound messages matching consumeInbound.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    channelActive(io.netty.channel.ChannelHandlerContext ctx)
     
    void
    channelInactive(io.netty.channel.ChannelHandlerContext ctx)
     
    void
    channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)
     
    void
    write(io.netty.channel.ChannelHandlerContext ctx, Object msg, io.netty.channel.ChannelPromise promise)
     

    Methods inherited from class io.netty.channel.ChannelDuplexHandler

    bind, close, connect, deregister, disconnect, flush, read

    Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

    channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

    Methods inherited from class io.netty.channel.ChannelHandlerAdapter

    ensureNotSharable, handlerAdded, handlerRemoved, isSharable

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface io.netty.channel.ChannelHandler

    handlerAdded, handlerRemoved

  • Field Details

    • INTERVAL

      public static final Duration INTERVAL

  • Constructor Details

    • MessagesThroughputHandler

      public MessagesThroughputHandler(BiPredicate<SocketAddress,Object> consumeOutbound, BiPredicate<SocketAddress,Object> consumeInbound, io.netty.channel.EventLoopGroup eventLoopGroup)
      Creates a new handler which visualizes the number of inbound and outbound messages per second, consumes outbound message matching consumeOutbound, and inbound messages matching consumeInbound.
      Parameters:
      consumeOutbound - predicate that consumes outbound messages on match
      consumeInbound - predicate that consumes inbound messages on match
      eventLoopGroup - eventLoopGroup on which this handler is executed

    • MessagesThroughputHandler

      public MessagesThroughputHandler(BiPredicate<SocketAddress,Object> consumeOutbound, BiPredicate<SocketAddress,Object> consumeInbound)
      Creates a new handler which visualizes the number of inbound and outbound messages per second, consumes outbound message matching consumeOutbound, and inbound messages matching consumeInbound.
      Parameters:
      consumeOutbound - predicate that consumes outbound messages on match
      consumeInbound - predicate that consumes inbound messages on match

    • MessagesThroughputHandler

      public MessagesThroughputHandler()
      Creates a new handler which visualizes the number of inbound and outbound messages per second.

  • Method Details

    • write

      public void write(io.netty.channel.ChannelHandlerContext ctx, Object msg, io.netty.channel.ChannelPromise promise)
      Specified by:
      write in interface io.netty.channel.ChannelOutboundHandler
      Overrides:
      write in class io.netty.channel.ChannelDuplexHandler

    • channelRead

      public void channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)
      Specified by:
      channelRead in interface io.netty.channel.ChannelInboundHandler
      Overrides:
      channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

    • channelActive

      public void channelActive(io.netty.channel.ChannelHandlerContext ctx)
      Specified by:
      channelActive in interface io.netty.channel.ChannelInboundHandler
      Overrides:
      channelActive in class io.netty.channel.ChannelInboundHandlerAdapter

    • channelInactive

      public void channelInactive(io.netty.channel.ChannelHandlerContext ctx)
      Specified by:
      channelInactive in interface io.netty.channel.ChannelInboundHandler
      Overrides:
      channelInactive in class io.netty.channel.ChannelInboundHandlerAdapter