Class SslClientHelloHandler<T>

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Field Details

• MAX_CLIENT_HELLO_LENGTH

  public static final int MAX_CLIENT_HELLO_LENGTH

  The maximum length of client hello message as defined by RFC5246.

  See Also:

  • Constant Field Values

Constructor Details

• SslClientHelloHandler

  public SslClientHelloHandler()

• SslClientHelloHandler

  protected SslClientHelloHandler(int maxClientHelloLength)

Method Details

• decode

  protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception

  Description copied from class: ByteToMessageDecoder

  Decode the from one ByteBuf to an other. This method will be called till either the input ByteBuf has nothing to read when return from this method or till nothing was read from the input ByteBuf.

  Specified by:

  decode in class ByteToMessageDecoder

  Parameters:

  ctx - the ChannelHandlerContext which this ByteToMessageDecoder belongs to

  in - the ByteBuf from which to read data

  out - the List to which decoded messages should be added

  Throws:

  Exception - is thrown if an error occurs

• handlerRemoved0

  protected void handlerRemoved0(ChannelHandlerContext ctx) throws Exception

  Description copied from class: ByteToMessageDecoder

  Gets called after the ByteToMessageDecoder was removed from the actual context and it doesn't handle events anymore.

  Overrides:

  handlerRemoved0 in class ByteToMessageDecoder

  Throws:

  Exception

• lookup

  protected abstract Future<T> lookup(ChannelHandlerContext ctx, ByteBuf clientHello) throws Exception

  Kicks off a lookup for the given ClientHello and returns a Future which in turn will notify the onLookupComplete(ChannelHandlerContext, Future) on completion. See https://tools.ietf.org/html/rfc5246#section-7.4.1.2

  struct {
   ProtocolVersion client_version;
   Random random;
   SessionID session_id;
   CipherSuite cipher_suitesinvalid input: '<'2..2^16-2>;
   CompressionMethod compression_methodsinvalid input: '<'1..2^8-1>;
   select (extensions_present) {
   case false:
   struct {};
   case true:
   Extension extensionsinvalid input: '<'0..2^16-1>;
   };
  } ClientHello;
  

  Throws:

  Exception

  See Also:

  • onLookupComplete(ChannelHandlerContext, Future)

• onLookupComplete

  protected abstract void onLookupComplete(ChannelHandlerContext ctx, Future<T> future) throws Exception

  Called upon completion of the lookup(ChannelHandlerContext, ByteBuf) Future.

  Throws:

  Exception

  See Also:

  • lookup(ChannelHandlerContext, ByteBuf)

• read

  public void read(ChannelHandlerContext ctx) throws Exception

  Description copied from interface: ChannelOutboundHandler

  Intercepts ChannelHandlerContext.read().

  Specified by:

  read in interface ChannelOutboundHandler

  Throws:

  Exception

• bind

  public void bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) throws Exception

  Description copied from interface: ChannelOutboundHandler

  Called once a bind operation is made.

  Specified by:

  bind in interface ChannelOutboundHandler

  Parameters:

  ctx - the ChannelHandlerContext for which the bind operation is made

  localAddress - the SocketAddress to which it should bound

  promise - the ChannelPromise to notify once the operation completes

  Throws:

  Exception - thrown if an error occurs

• connect

  public void connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) throws Exception

  Description copied from interface: ChannelOutboundHandler

  Called once a connect operation is made.

  Specified by:

  connect in interface ChannelOutboundHandler

  Parameters:

  ctx - the ChannelHandlerContext for which the connect operation is made

  remoteAddress - the SocketAddress to which it should connect

  localAddress - the SocketAddress which is used as source on connect

  promise - the ChannelPromise to notify once the operation completes

  Throws:

  Exception - thrown if an error occurs

• disconnect

  public void disconnect(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception

  Description copied from interface: ChannelOutboundHandler

  Called once a disconnect operation is made.

  Specified by:

  disconnect in interface ChannelOutboundHandler

  Parameters:

  ctx - the ChannelHandlerContext for which the disconnect operation is made

  promise - the ChannelPromise to notify once the operation completes

  Throws:

  Exception - thrown if an error occurs

• close

  public void close(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception

  Description copied from interface: ChannelOutboundHandler

  Called once a close operation is made.

  Specified by:

  close in interface ChannelOutboundHandler

  Parameters:

  ctx - the ChannelHandlerContext for which the close operation is made

  promise - the ChannelPromise to notify once the operation completes

  Throws:

  Exception - thrown if an error occurs

• deregister

  public void deregister(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception

  Description copied from interface: ChannelOutboundHandler

  Called once a deregister operation is made from the current registered EventLoop.

  Specified by:

  deregister in interface ChannelOutboundHandler

  Parameters:

  ctx - the ChannelHandlerContext for which the close operation is made

  promise - the ChannelPromise to notify once the operation completes

  Throws:

  Exception - thrown if an error occurs

• write

  public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception

  Description copied from interface: ChannelOutboundHandler

  Called once a write operation is made. The write operation will write the messages through the ChannelPipeline. Those are then ready to be flushed to the actual Channel once Channel.flush() is called

  Specified by:

  write in interface ChannelOutboundHandler

  Parameters:

  ctx - the ChannelHandlerContext for which the write operation is made

  msg - the message to write

  promise - the ChannelPromise to notify once the operation completes

  Throws:

  Exception - thrown if an error occurs

• flush

  public void flush(ChannelHandlerContext ctx) throws Exception

  Description copied from interface: ChannelOutboundHandler

  Called once a flush operation is made. The flush operation will try to flush out all previous written messages that are pending.

  Specified by:

  flush in interface ChannelOutboundHandler

  Parameters:

  ctx - the ChannelHandlerContext for which the flush operation is made

  Throws:

  Exception - thrown if an error occurs