Class OutboundByteBufAggregator

  • All Implemented Interfaces:,

    public final class OutboundByteBufAggregator
    SSL uses 16kb application message packets. This handler aims to combine the ByteBuf into packet-sized chunks, This is due to limitations in the SSL implementation which prefers contiguous messages to process so we must break down composite ByteBuf objects. This Aggregator includes a constructor which accepts a allocator to avoid memory fragmentation. Since we always use 16KB buffers.
    • Nested Class Summary

      • Nested classes/interfaces inherited from interface
    • Field Summary

      Modifier and Type Field Description
      static int SSL_PACKET_SIZE  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void flush​( ctx)  
      void write​( ctx, java.lang.Object msg, promise)  
      • Methods inherited from class

        bind, close, connect, deregister, disconnect, read
      • Methods inherited from class

        ensureNotSharable, exceptionCaught, 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

        exceptionCaught, handlerAdded, handlerRemoved
    • Constructor Detail

      • OutboundByteBufAggregator

        public OutboundByteBufAggregator()
      • OutboundByteBufAggregator

        public OutboundByteBufAggregator​(int packetSize)
      • OutboundByteBufAggregator

        public OutboundByteBufAggregator​(int packetSize,
                                         io.netty.buffer.ByteBufAllocator alloc)
    • Method Detail

      • write

        public void write​( ctx,
                          java.lang.Object msg,
                   throws java.lang.Exception
        Specified by:
        write in interface
        write in class
      • flush

        public void flush​( ctx)
                   throws java.lang.Exception
        Specified by:
        flush in interface
        flush in class